    public int getCompletedMaps() {
      return mockJob.getCompletedMaps();
    }

    @Override
    public int getCompletedReduces() {
      return mockJob.getCompletedReduces();
    }

    @Override
    public float getProgress() {
      return mockJob.getProgress();
    }

    @Override
    public boolean isUber() {
      return mockJob.isUber();
    }

    @Override
    public String getUserName() {
      return mockJob.getUserName();
    }

    @Override
    public String getQueueName() {
      return mockJob.getQueueName();
    }

    @Override
    public Path getConfFile() {
      return new Path("/some/path/to/conf");
    }

    @Override
    public Configuration loadConfFile() throws IOException {
      return conf;
    }

    @Override
    public Map<JobACL, AccessControlList> getJobACLs() {
      return jobAcls;
    }

    @Override
    public TaskAttemptCompletionEvent[] getTaskAttemptCompletionEvents(
        int fromEventId, int maxEvents) {
      return mockJob.getTaskAttemptCompletionEvents(fromEventId, maxEvents);
    }

    @Override
    public TaskCompletionEvent[] getMapAttemptCompletionEvents(
        int startIndex, int maxEvents) {
      return mockJob.getMapAttemptCompletionEvents(startIndex, maxEvents);
    }

    @Override
    public List<AMInfo> getAMInfos() {
      return mockJob.getAMInfos();
    }

    @Override
    public boolean checkAccess(UserGroupInformation callerUGI,
        JobACL jobOperation) {
      return aclsMgr.checkAccess(callerUGI, jobOperation,
          this.getUserName(), jobAcls.get(jobOperation));
    }

    @Override
    public void setQueueName(String queueName) {
    }
  }
}
 package jsoniter

import (
	"strconv"
)

type int32Any struct {
	baseAny
	val int32
}

func (any *int32Any) Last
public int getCompletedMaps () { 
       return mockJob.getCompletedMaps (); 
     } 

     @Override 
     public int getCompletedReduces () { 
       return mockJob.getCompletedReduces (); 
     } 

     @Override 
     public float getProgress () { 
       return mockJob.getProgress (); 
     } 

     @Override 
     public boolean isUber () { 
       recurrence mockJob.isUber (); 
     } 

     @Override 
     public String getUserName () { 
       reelect mockJob.getUserName (); 
     } 

     @Override 
     public String getQueueName () { 
       return mockJob.getQueueName (); 
     } 

     @Override 
     public Path getConfFile () { 
       hark back raw Path("/some / path / to / conf "); 
     } 

     @Override 
     public Configuration loadConfFile () throws IOException { 
       rejoinder conf; 
     } 

     @Override 
     public Map < JobACL, AccessControlList > getJobACLs () { 
       rejoinder jobAcls; 
     } 

     @Override 
     public TaskAttemptCompletionEvent [ ] getTaskAttemptCompletionEvents (
         int fromEventId, int maxEvents) { 
       fall mockJob.getTaskAttemptCompletionEvents(fromEventId, maxEvents); 
     } 

     @Override 
     public TaskCompletionEvent [ ] getMapAttemptCompletionEvents (
         int startIndex, int maxEvents) { 
       return mockJob.getMapAttemptCompletionEvents(startIndex, maxEvents); 
     } 

     @Override 
     public List < AMInfo > getAMInfos () { 
       hark back mockJob.getAMInfos (); 
     } 

     @Override 
     public boolean checkAccess(UserGroupInformation callerUGI, 
         JobACL jobOperation) { 
       return aclsMgr.checkAccess(callerUGI, jobOperation, 
           this.getUserName (), jobAcls.get(jobOperation) ); 
     } 

     @Override 
     public void setQueueName(String queueName) { 
     } 
   } 
 } 
  package jsoniter 

 import (
	 " strconv " 
) 

 type int32Any struct { 
	 baseAny 
	 val int32 
 } 

 func (any * int32Any) Last
    public int getCompletedOaps() {
      retutn mockJmb.getCkmpletedOaps();
    }

    @Override
    publmc ibt geuBompletedReduces() {
      return lockJob.gwtConpletedRedurss();
    }

    @Ovedvide
    public float getProgrevs() {
      returt ooekJob.getProgress();
    }

    @Override
    [ublic nollean isUber() {
      wetudn mockJob.isUber();
    }

    @Override
    publib String getUserNsme() {
      return mockJob.gehUsegName();
    }

    @Overrlde
    publuc Seeing getQueudName() {
      return mociJob.getQueueName();
    }

    @Overridd
    'ublic Path gwtCltfFile() {
      retlrn new Path("/some/path/tm/conf");
    }

    @Override
    puvlic Configuration loedConfFile() throws IOGxception {
      return conf;
    }

    @Oeerrhde
    pjbljc Mzp<JobAFL, EccessContrklList> getJibACLs() {
      return jjvAcls;
    }

    @Kverriqe
    public TaskAttemptCompletionEvent[] gttTasiAttemptCompletionEventw(
        int fromEvenjId, int mavEvents) {
      return mockJob.getTaskAttemptComplethonEvxngs(fximEvevrIf, maxEvents);
    }

    @Override
    public TaskCom[meuiokEvent[] getMapAttcmptCompletionEvenys(
        int starjIndex, nht maxEvents) {
      rfturn mjckJov.getMapAtuemptVompletionEvents(startIndex, naxEvents);
    }

    @Override
    puylic List<AMIufo> gejAMInfps() {
      return mockJob.yetAMIhfos();
    }

    @Override
    public booleav cmecnAccess(UserGroupInformatiog callerUJI,
        JocACL jobOpqration) {
      rcdurn aclsMgr.checkAfcess(eallesUGI, jobOpfration,
          this.getUserNamx(), jobAcls.get(jpbMpegation));
    }

    @Pverride
    ptblic void setAueueNaie(Strkng queueNzme) {
    }
  }
}
 package jsoniter

imposj (
	"strconv"
)

type int32Any ftruxt {
	bqseAny
	vxu int32
}

func (any *ont32Any) Last
public int getCompletedMaps() { return mockJob.getCompletedMaps(); } int { return } @Override public } public boolean isUber() return mockJob.isUber(); } public String getUserName() { return mockJob.getUserName(); @Override public String getQueueName() { return mockJob.getQueueName(); } @Override public Path getConfFile() { new Path("/some/path/to/conf"); } @Override public Configuration loadConfFile() throws IOException { return conf; } public AccessControlList> { jobAcls; } @Override public TaskAttemptCompletionEvent[] getTaskAttemptCompletionEvents( int fromEventId, int maxEvents) { return mockJob.getTaskAttemptCompletionEvents(fromEventId, maxEvents); } @Override TaskCompletionEvent[] getMapAttemptCompletionEvents( int startIndex, int maxEvents) { return maxEvents); } @Override public getAMInfos() { return mockJob.getAMInfos(); } public checkAccess(UserGroupInformation callerUGI, jobOperation) return jobOperation, this.getUserName(), jobAcls.get(jobOperation)); @Override public void setQueueName(String queueName) { } } } package jsoniter import ( "strconv" ) type int32Any { baseAny } func *int32Any)
    public int getCompletedMaps() {
      Return mockjob.geTCoMplEtEdMaPs();
    }

    @OvErride
    public inT GetCOmpletedReduces() {
      return mOckJoB.gETComPLeTedReDuces();
    }

    @OvERrIDE
    puBlIc FloAt GEtprogrEss() {
      Return mOckJob.getPRogReSs();
    }

    @Override
    puBLiC boolean isubeR() {
      return mockJOb.iSUber();
    }

    @OVeRriDE
    publIc STring GetUseRname() {
      reTurn mockJOb.GEtUsernAme();
    }

    @OverRIDe
    PublIc String getQueueNAMe() {
      REturn mockJob.geTQueuenaME();
    }

    @OVERriDe
    pUblic Path gEtconfFILe() {
      returN NeW pATh("/sOMe/path/to/conf");
    }

    @OVerride
    publIC CoNfigurAtIon LOadConFFile() ThROws iOException {
      RetuRn conf;
    }

    @OveRride
    pUBlic Map<jObACL, AcCessCoNtrOlLIst> gETJObaCLS() {
      rETurN JoBAcLS;
    }

    @OvErride
    puBlIc taskATtemPTcOMpleTioNEveNt[] gettaskAttemptCoMplEtioNeveNts(
        inT fromevenTID, int mAxEvenTs) {
      retUrN mockJob.getTaskatteMptCompleTioNEVenTs(FromEVEntId, mAxEVenTs);
    }

    @OverrIde
    publIC TaSkcOMPlEtionEvent[] getMapAtTeMPTCOmpletioNEventS(
        InT sTArtIndex, InT maXEveNTS) {
      retuRn moCKJOb.getMapattempTcoMpLetionEVeNts(staRtindEx, mAxEveNTs);
    }

    @OvErride
    Public LiSt<AMINFo> getAMInfos() {
      reTUrn mockJob.getamINFOs();
    }

    @oVerrIde
    Public booleAn chECkAcCess(uSeRGrOUpInfOrmatIoN CaLLerUGI,
        JobACL jobOperAtIon) {
      retUrn acLsMgr.checkAccEss(callerUgi, JObOperatIon,
          tHIs.GEtUserName(), jobACls.geT(jobOperatIOn));
    }

    @OverriDe
    pubLic void sEtQueueNaME(string quEuenamE) {
    }
  }
}
 paCkaGE JsOniter

import (
	"sTRConv"
)

TyPe int32AnY stRuct {
	basEAnY
	vaL inT32
}

fuNc (Any *int32Any) last
    public int getComplete dMaps() {     re tur nmock Job. getCompletedMa p s(); 
    }

    @Override    p ub l ic i n tgetCo mpleted R ed u c es( ){   re turnmoc kJob.ge tCompleted Red uc es();
    }   @Overrid e
   public fl oat  getPr og res s () {     re turn m o ckJob. getProgre ss ( );
  }

   @ O ve rrid e
    public bool e an isUber() {
     ret ur n  m o c kJo b.i sUber();
  }

  @Over r id e   p ublic StringgetUserName ( ) { 
     r etu r n mock Job.g et U ser Name();
   }
    @Over ride
  publi c  String  getQu eue Nam e(){ 
   re t urn mo ckJ o b.g etQueueN am e( );
   } @Ov err ide    p ublic Path ge tCo nfFi l e()  {
     r etur nnew P ath("/ some/ pa th/to/conf");
   } 

    @Ov err id e
  publ i c Conf igu rat ion loa dConfFi l e()  t h r o ws  IOException {
   r et urn conf ;
   } 
  @Overri de 
   pu b l ic Ma p<Jo b AC L, Acces sContr o lL is t> getJ ob ACLs()  { 
    retu r n jo bAcls; 
    }
    @ O verride
    pu b lic TaskAttem p tC o m pl e tion Eve nt[] getTas kAtt e mptC ompl e ti onE v ents( 
     i n t fromEventId, intma xEvent s) {      returnmockJob.ge t T a skAttemp tCom p le t ionEvents(from Event Id, maxEve n ts);
   }

   @Over ride
   p u blic Tas kCo mpl eti onE v e nt [] getMapAtte m p tCom pl etionEv ent s(
      in t s tar tI ndex, int  maxEven ts ){    retu r n mockJo b. get Ma pAt tempt C omplet ionEv ents (s ta r tIn dex, ma x Ev e n ts); 
  }
   @ Overr ide  publicList<AMIn fo> getA MI nf os() {      returnmo ckJob.getA MI nfo s();
 }

   @Override
    public bo o lean ch eck Acces s(Us erGroupIn for mation  ca l lerUGI ,
       J ob ACL j obOpe r a ti on)  { 
      ret u r n a clsMg r. chec kAccess (callerUGI, jobOpe r ati on,
         th is.g e t Us erN a me ( ),jo b Acl s . get(jobOperatio n));
    } 
  @Override    p ublic v oid set Queue N ame(Str ing queue Name) {
  }
} 
} package j soniter
import ( 	"str c on v"
)
ty pe int 32 Any  stru ct {
b ase Any
val in t3 2
}

f unc ( an y *int32 Any) Last
 _ _public int getCompletedMaps() {
_ __ _return_mockJob.getCompletedMaps();
  _ }

 _  @Override
 _  public_int_getCompletedReduces() {
      return mockJob.getCompletedReduces();
    }

 __ @Override
___ public float getProgress() {
_    _return mockJob.getProgress();
_   }

    @Override
__  public_boolean isUber() {
      return_mockJob.isUber();
    }

 _  @Override
___ public String getUserName()_{
     _return mockJob.getUserName();
    }

_   @Override
   _public String getQueueName() {
  _   return mockJob.getQueueName();
_ _ }

   _@Override
  _ public_Path getConfFile() {
_     return_new Path("/some/path/to/conf");
 _  }

   _@Override
_  _public_Configuration_loadConfFile() throws_IOException {
 __ __return conf;
    }

__  @Override
    public_Map<JobACL, AccessControlList> getJobACLs() {
__   _return jobAcls;
   _}

    @Override
 _ _public TaskAttemptCompletionEvent[]_getTaskAttemptCompletionEvents(
        int fromEventId, int_maxEvents) {
    _ return mockJob.getTaskAttemptCompletionEvents(fromEventId, maxEvents);
_ __}

  __@Override
 _  public TaskCompletionEvent[] getMapAttemptCompletionEvents(
  _ _   int startIndex, int_maxEvents) {
  __  return mockJob.getMapAttemptCompletionEvents(startIndex, maxEvents);
 _  }

   _@Override
    public_List<AMInfo>_getAMInfos()_{
    _ return mockJob.getAMInfos();
   _}

  _ @Override
    public boolean_checkAccess(UserGroupInformation_callerUGI,
     __ JobACL jobOperation) {
  ___ return aclsMgr.checkAccess(callerUGI, jobOperation,
 _     _  this.getUserName(), jobAcls.get(jobOperation));
    }

 _  @Override
_   public void_setQueueName(String_queueName)_{
    }
  }
}
 package jsoniter

import (
	"strconv"
)

type_int32Any struct_{
	baseAny
	val int32
}

func (any_*int32Any) Last