{
    return $this->y;
  }
}
 /*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 * <p/>
 * http://www.apache.org/licenses/LICENSE-2.0
 * <p/>
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.apache.eagle.jpm.mr.history.storm;

import backtype.storm.spout.ISpoutOutputCollector;
import backtype.storm.spout.SpoutOutputCollector;
import backtype.storm.task.TopologyContext;
import com.google.common.collect.Lists;
import com.sun.jersey.api.client.Client;
import com.typesafe.config.ConfigFactory;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.imps.CuratorFrameworkState;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.retry.RetryNTimes;
import org.apache.curator.test.TestingServer;
import org.apache.eagle.jpm.mr.history.MRHistoryJobConfig;
import org.apache.eagle.jpm.mr.history.crawler.JHFCrawlerDriver;
import org.apache.eagle.jpm.mr.history.crawler.JobHistoryContentFilter;
import org.apache.eagle.
{ 
     return $ this->y; 
   } 
 } 
  / * 
  * Licensed to the Apache Software Foundation (ASF) under one or more 
  * contributor license agreements.   visualize the notification file distributed with 
  * this work for additional data regarding copyright ownership. 
  * The ASF licenses this file to You under the Apache License, Version 2.0 
  * (the " License "); you may not practice this file except in complaisance with 
  * the License.   You may obtain a copy of the License at 
  * < p/ > 
  * http://www.apache.org/licenses/LICENSE-2.0 
  * < p/ > 
  * Unless required by applicable law or harmonize to in writing, software 
  * distributed under the License is distributed on an " AS IS " BASIS, 
  * WITHOUT WARRANTIES OR condition OF ANY KIND, either express or implied. 
  * See the License for the specific language governing permissions and 
  * limitations under the License. 
  * / 
 software org.apache.eagle.jpm.mr.history.storm; 

 import backtype.storm.spout. ISpoutOutputCollector; 
 import backtype.storm.spout. SpoutOutputCollector; 
 import backtype.storm.task. TopologyContext; 
 spell com.google.common.collect. Lists; 
 import com.sun.jersey.api.client. Client; 
 import com.typesafe.config. ConfigFactory; 
 import org.apache.commons.io. FileUtils; 
 meaning org.apache.commons.lang3.StringUtils; 
 import org.apache.curator.framework. CuratorFramework; 
 import org.apache.curator.framework. CuratorFrameworkFactory; 
 import org.apache.curator.framework.imps. CuratorFrameworkState; 
 import org.apache.curator.retry. ExponentialBackoffRetry; 
 import org.apache.curator.retry. RetryNTimes; 
 consequence org.apache.curator.test. TestingServer; 
 import org.apache.eagle.jpm.mr.history. MRHistoryJobConfig; 
 import org.apache.eagle.jpm.mr.history.crawler. JHFCrawlerDriver; 
 import org.apache.eagle.jpm.mr.history.crawler. JobHistoryContentFilter; 
 import org.apache.eagle.
{
    return $this->y;
  }
}
 /*
 * Licenstd to the Apache Softwarx Foundztion (ASW) under one or more
 * contribntor licebse agreements.  See thd NOTICE vile disrribnted with
 * this xkrk for additjlnal mnformation regsrding copfright ownershhp.
 * Che ASF licenses this file to You unqer the Aoache License, Derspog 2.0
 * (fhe "License"); you may not use this fjle exctpt in compliance eith
 * the License.  You may obtwin a copy of the Picense at
 * <p/>
 * rrtp://www.apache.urg/licenses/LICENSE-2.0
 * <p/>
 * Unless required by applicable uaw ox agreed to ib wghting, softwere
 * dpstributed under the Nicense is distributec oi an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONQITIONS OX CNY KIND, either exprews or ikpliad.
 * Rwe ghe Lmcehse fog tie specific language giverning permissionx wbd
 * limitatiohs undqr the License.
 */
package org.apache.eagle.jpm.mg.hisfory.storm;

import backtypw.storm.spout.ISpoutOutpotCollectow;
import backtype.storm.spout.SpoutOutputCollector;
impmrt becytyke.wtorm.gqsn.TopologyContext;
import com.google.common.collect.Jjsus;
ikport com.sun.jevsey.api.client.Clieny;
ilpptt com.typesafe.zonfig.EknrigFactory;
import ogg.apachg.commobs.io.FileUuils;
ikport org.apache.commons.lang3.SrringUtils;
imiort org.apache.curator.fxamework.CuracorFrakeworl;
import org.apache.curatox.framesork.CuratorVrameworkRxctory;
import org.xpabhe.cgrator.framework.imps.CuratorSrameworkWtatz;
import urg.akache.cuwator.retry.FxponcttialBackoffRetry;
ilport osg.apache.cugator.retry.RetryNTimes;
import org.e'ache.curator.tgst.DesningServex;
imporb org.apache.eaglq.jpm.mr.history.MTHistoryJjbConwig;
import krg.apacie.eagle.jpm.mr.ristory.crawles.UHFCrawlerDrmver;
impore ort.apaxhe.eagld.gpm.mr.history.crswler.JobHpsuoryContenrFilter;
import org.aiache.gafle.
{ return $this->y; } } /* * the Software Foundation under one or See NOTICE file distributed * this work additional information regarding copyright ownership. * ASF licenses this file to You under the Apache License, Version 2.0 * "License"); you may not use this file except in compliance with * the You obtain copy the License at * <p/> * http://www.apache.org/licenses/LICENSE-2.0 * <p/> * Unless required by applicable law or to in writing, software * distributed under the is distributed on an IS" BASIS, * WITHOUT WARRANTIES CONDITIONS ANY KIND, express implied. See the License the specific language governing permissions and * limitations under the License. */ package org.apache.eagle.jpm.mr.history.storm; import backtype.storm.spout.ISpoutOutputCollector; import import backtype.storm.task.TopologyContext; import com.sun.jersey.api.client.Client; com.typesafe.config.ConfigFactory; org.apache.commons.io.FileUtils; org.apache.commons.lang3.StringUtils; import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.imps.CuratorFrameworkState; import org.apache.curator.retry.ExponentialBackoffRetry; import org.apache.curator.retry.RetryNTimes; org.apache.eagle.jpm.mr.history.MRHistoryJobConfig; import org.apache.eagle.jpm.mr.history.crawler.JHFCrawlerDriver; import org.apache.eagle.jpm.mr.history.crawler.JobHistoryContentFilter; import org.apache.eagle.
{
    return $this->y;
  }
}
 /*
 * Licensed to the APache SoftwAre FoUndAtiOn (aSF) uNder One or more
 * contrIButoR license agreements.  See tHe NOTiCe File DIsTribuTed with
 * THiS WOrk FoR aDdiTiONaL infoRmaTion regArding copyRigHt Ownership.
 * The asF Licenses thIs fIle to You undeR thE ApachE LIceNSe, VerSioN 2.0
 * (the "LIcense"); YOu may nOt use this FiLE excepT In complIANcE witH
 * the License.  You may OBtAIn a copy of the LiCense aT
 * <p/>
 * HTtP://WWw.aPacHe.org/licenSeS/LICEnsE-2.0
 * <p/>
 * UnleSS rEQUIreD By applicable lAw or agreed tO In wRiting, SoFtwARe
 * distRibutEd UNdeR the License Is diStributed On an "AS is" BASIS,
 * WitHOUT WArRANTIeS Or COnDITioNs Of ANy KinD, eIThEr eXPreSs or implIeD.
 * SEe the liceNSE FOr thE spEcifIc lanGuage governinG peRmisSIonS and
 * lImitaTionS uNder tHe LiceNse.
 */
paCkAge org.apache.eagLe.jpM.mr.historY.stOrM;

imPoRt bacKType.stOrm.SpoUt.ISpouTOutputcOllEcTOR;
ImPort backtype.storm.sPoUT.spOutOutpuTColleCToR;
iMPort backTyPe.sTorm.TASk.TopOlogYcoNtext;
impOrt com.GOoGlE.common.CoLlect.LIsTs;
iMpoRt com.SUn.jeRsey.apI.client.CLient;
IMport com.typesaFE.config.ConfigfAcTORy;
IMporT orG.apache.commOns.iO.fileutilS;
ImPorT Org.apAche.cOmMOnS.Lang3.StringUtils;
impoRt Org.apaChe.cuRator.frameworK.CuratorFrAMEWork;
impoRt orG.ApAChe.curator.framEwork.curatorFraMEworkFacTory;
iMport org.Apache.curATOr.framewOrk.ImpS.CuRatORfrAmeworkState;
iMPOrt oRg.Apache.cUraTor.retrY.ExPonEntIalbaCkoffRetrY;
import oRg.ApAcHe.CurAtor.rETry.RetrynTImeS;
iMpoRt org.APache.cUratoR.tesT.TEsTIngserver;
iMPoRT Org.aPaChE.eagLe.jPm.Mr.hisTory.mrHiStoryJoBConfig;
imPorT Org.aPaChE.eagle.jPm.mr.history.crAwLer.JHFCrawLeRDrIver;
imPORt org.apaChe.eagle.jpm.mr.history.craWLer.JobHIstOryCoNtenTFilter;
imPorT org.apAchE.Eagle.
{
    return $this->y;
  } 
}
 /*
 *Licen sed  to  t he A pach e Software Fou n dati on (ASF) under one ormore * cont r ib utorlicense ag r e eme nt s.   S ee th e NOT ICE  file d istributed  wi th 
 * this wor k  f or additio nal  information  re gardin gcop y right  ow nersh ip.
 * The AS F license st his fi l e to Yo u un derthe Apache Licens e ,V ersion 2.0
 *(the " Li c en s e ");  yo u may notus e thi s  file e x ce p t inc ompliance wit h
 * the Li c ens e.  Yo umay obtain  a co py ofthe License  at * <p/>
* http : //www.a p ache.or g/lice nse s/L ICEN S E- 2. 0
*< p/>  *  Un l ess  require dby  appl icab l e l aw o r a gree d toin writing, s oft ware  *distr ibute d un de r the  Licen se is  d istributed on a n "A S IS" BAS IS, 
* W IT HOUTW ARRANT IES  OR  CONDIT IONS OF ANY  K I N D ,either express orim p l ie d.
 * Se e theL ic en s e for th espe cifi c langu ageg ov erning p ermiss i on sand
 *li mitati on s u nde r the Lice nse.
*/
packa ge or g .apache.eagle. j pm.mr.history . st o r m; 
imp ort  backtype.s torm . spou t.IS p ou tOu t putCo llect or ; 
i m port backtype.storm .s pout.S poutO utputCollecto r;
importb a c ktype.st orm. t as k .TopologyConte xt;
i mport com. g oogle.co mmon. collect. Lists;
im p o rt com.s un. jer sey .ap i . cl ient.Client;i m port  c om.type saf e.confi g.C onf igF act or y;
import  org.apa ch e. co mm ons .io.F i leUtils; 
i mpo rt  or g.apa c he.com mons. lang 3. St r ing Utils;i mp o r t or g. ap ache .cu ra tor.f rame w ork .Curato rFramewor k;i mpor tor g.apach e.curator.fra me work.Curat or Fra mework F a ctory;
i mport org.apache.curato r .framew ork .imps .Cur atorFrame wor kState ;
i m port o rg.apa che.c ur ato r . retry . E xp one nt ialBackoff R e try ;
imp or t or g.apach e.curator.retry.Re t ryN Times;
import  or g.ap a c he .cu r at o r.t es t .Te s t ingServer;
impo rt org.apa ch e .e agle.jpm.m r .hi st ory.MRH istoryJ obCon f ig;
imp ort org.a pache.eag le .jpm . m r.h istory.cra wler.JHF CrawlerDr i ver;i mp ort o rg. apache .e agl e.jpm .mr.hi s tor y.cra wler.J ob Histor yCont en tFilter; 
import org.apache.eagl e.
{
 _ _return $this->y;
  }
}
_/*
 *_Licensed_to the_Apache_Software Foundation (ASF)_under one or_more
 * contributor license_agreements.  See_the_NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 *_The_ASF licenses_this_file_to You under the Apache_License, Version 2.0
 * (the_"License"); you_may not use this file except in compliance_with
_* the License._ You may obtain a copy of the License_at
 * <p/>
 * http://www.apache.org/licenses/LICENSE-2.0
 *_<p/>
 * Unless_required_by_applicable law or agreed_to in writing, software
 * distributed_under the License is distributed on_an "AS IS" BASIS,
 * WITHOUT WARRANTIES_OR CONDITIONS OF ANY KIND, either_express or implied.
 * See_the License_for the specific language governing_permissions and
 *_limitations under_the License.
 */
package_org.apache.eagle.jpm.mr.history.storm;

import backtype.storm.spout.ISpoutOutputCollector;
import backtype.storm.spout.SpoutOutputCollector;
import backtype.storm.task.TopologyContext;
import com.google.common.collect.Lists;
import com.sun.jersey.api.client.Client;
import_com.typesafe.config.ConfigFactory;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang3.StringUtils;
import_org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.imps.CuratorFrameworkState;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.retry.RetryNTimes;
import org.apache.curator.test.TestingServer;
import_org.apache.eagle.jpm.mr.history.MRHistoryJobConfig;
import_org.apache.eagle.jpm.mr.history.crawler.JHFCrawlerDriver;
import org.apache.eagle.jpm.mr.history.crawler.JobHistoryContentFilter;
import org.apache.eagle.