|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method private sendExecutionRequest(proc HadoopProcess, job HadoopJobEx, tasks Collection<HadoopTaskInfo>) : void in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method public write(job HadoopJobEx, cntrs HadoopCounters) : void in class org.apache.ignite.internal.processors.hadoop.delegate.HadoopFileSystemCounterWriterDelegate |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method public write(job HadoopJobEx, cntrs HadoopCounters) : void in class org.apache.ignite.hadoop.fs.IgniteHadoopFileSystemCounterWriter |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method private prepareForJob(proc HadoopProcess, job HadoopJobEx, plan HadoopMapReducePlan) : void in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor |
From |
To |
|
Change Parameter Type jobCls : Class<? extends HadoopJob> to jobCls : Class<? extends HadoopJobEx> in method public createJob(jobCls Class<? extends HadoopJobEx>, jobId HadoopJobId, log IgniteLogger, libNames String[], helper HadoopHelper) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.impl.shuffle.collections.HadoopAbstractMapTest.JobInfo |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method public HadoopV2TaskContext(taskInfo HadoopTaskInfo, job HadoopJobEx, jobId HadoopJobId, locNodeId UUID, jobConfDataInput DataInput) in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method private startProcess(job HadoopJobEx, plan HadoopMapReducePlan) : HadoopProcess in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method private startJavaProcess(childProcId UUID, startMeta HadoopExternalTaskMetadata, job HadoopJobEx, igniteWorkDir String) : Process in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor |
From |
To |
|
Change Parameter Type jobCls : Class<? extends HadoopJob> to jobCls : Class<? extends HadoopJobEx> in method public createJob(jobCls Class<? extends HadoopJobEx>, jobId HadoopJobId, log IgniteLogger, libNames String[], helper HadoopHelper) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.HadoopJobInfo |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method protected HadoopTaskContext(taskInfo HadoopTaskInfo, job HadoopJobEx) in class org.apache.ignite.internal.processors.hadoop.HadoopTaskContext |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method private jobConfDataInput(job HadoopJobEx) : DataInput in class org.apache.ignite.internal.processors.hadoop.impl.HadoopTestTaskContext |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method public run(job HadoopJobEx, tasks Collection<HadoopTaskInfo>) : void in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor |
From |
To |
|
Change Parameter Type gridJob : HadoopJob to gridJob : HadoopJobEx in method public HadoopTestTaskContext(taskInfo HadoopTaskInfo, gridJob HadoopJobEx) in class org.apache.ignite.internal.processors.hadoop.impl.HadoopTestTaskContext |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method public write(job HadoopJobEx, cntrs HadoopCounters) : void in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopFileSystemCounterWriterDelegateImpl |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method public abstract run(job HadoopJobEx, tasks Collection<HadoopTaskInfo>) : void in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskExecutorAdapter |
From |
To |
|
Change Parameter Type gridJob : HadoopJob to gridJob : HadoopJobEx in method private runMapCombineTask(fileBlock HadoopFileBlock, gridJob HadoopJobEx) : HadoopTestTaskContext in class org.apache.ignite.internal.processors.hadoop.impl.HadoopTasksAllVersionsTest |
From |
To |
|
Change Parameter Type gridJob : HadoopJob to gridJob : HadoopJobEx in method private runTaskWithInput(gridJob HadoopJobEx, taskType HadoopTaskType, taskNum int, words String...) : HadoopTestTaskContext in class org.apache.ignite.internal.processors.hadoop.impl.HadoopTasksAllVersionsTest |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method public HadoopShuffleJob(locReduceAddr T, log IgniteLogger, job HadoopJobEx, mem GridUnsafeMemory, totalReducerCnt int, locReducers int[], locMappersCnt int, embedded boolean) in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method private delegate(job HadoopJobEx) : HadoopFileSystemCounterWriterDelegate in class org.apache.ignite.hadoop.fs.IgniteHadoopFileSystemCounterWriter |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method public run(job HadoopJobEx, tasks Collection<HadoopTaskInfo>) : void in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopEmbeddedTaskExecutor |
From |
To |
|
Change Parameter Type jobCls : Class<? extends HadoopJob> to jobCls : Class<? extends HadoopJobEx> in method public createJob(jobCls Class<? extends HadoopJobEx>, jobId HadoopJobId, log IgniteLogger, libNames String[], helper HadoopHelper) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.impl.HadoopPlannerMockJob.JobInfo |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method protected HadoopRunnableTask(log IgniteLogger, job HadoopJobEx, mem GridUnsafeMemory, info HadoopTaskInfo, nodeId UUID) in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopRunnableTask |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method private reducerTasks(reducers int[], job HadoopJobEx) : Collection<HadoopTaskInfo> in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker |
From |
To |
|
Change Parameter Type job : HadoopJob to job : HadoopJobEx in method public write(job HadoopJobEx, cntrs HadoopCounters) : void in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterWriter |
From |
To |
|
Change Parameter Type jobCls : Class<? extends HadoopJob> to jobCls : Class<? extends HadoopJobEx> in method public createJob(jobCls Class<? extends HadoopJobEx>, jobId HadoopJobId, log IgniteLogger, libNames String[], helper HadoopHelper) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.HadoopDefaultJobInfo |
From |
To |
|
Change Return Type HadoopJob to HadoopJobEx in method public createJob(jobCls Class<? extends HadoopJobEx>, jobId HadoopJobId, log IgniteLogger, libNames String[], helper HadoopHelper) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.HadoopJobInfo |
From |
To |
|
Change Return Type HadoopJob to HadoopJobEx in method public createJob(jobCls Class<? extends HadoopJobEx>, jobId HadoopJobId, log IgniteLogger, libNames String[], helper HadoopHelper) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.impl.shuffle.collections.HadoopAbstractMapTest.JobInfo |
From |
To |
|
Change Return Type HadoopJob to HadoopJobEx in method public abstract getHadoopJob(inFile String, outFile String) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.impl.HadoopTasksAllVersionsTest |
From |
To |
|
Change Return Type HadoopJob to HadoopJobEx in method public createJob(jobCls Class<? extends HadoopJobEx>, jobId HadoopJobId, log IgniteLogger, libNames String[], helper HadoopHelper) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.HadoopDefaultJobInfo |
From |
To |
|
Change Return Type HadoopJob to HadoopJobEx in method public job(jobId HadoopJobId, jobInfo HadoopJobInfo) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker |
From |
To |
|
Change Return Type HadoopJob to HadoopJobEx in method public getHadoopJob(inFile String, outFile String) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.impl.HadoopTasksV1Test |
From |
To |
|
Change Return Type HadoopJob to HadoopJobEx in method public getHadoopJob(inFile String, outFile String) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.impl.HadoopTasksV2Test |
From |
To |
|
Change Return Type HadoopJob to HadoopJobEx in method public createJob(jobCls Class<? extends HadoopJobEx>, jobId HadoopJobId, log IgniteLogger, libNames String[], helper HadoopHelper) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.impl.HadoopPlannerMockJob.JobInfo |
From |
To |
|
Change Return Type HadoopJob to HadoopJobEx in method public job() : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.HadoopTaskContext |
From |
To |
|
Change Variable Type job : HadoopJob to job : HadoopJobEx in method public submit(jobId HadoopJobId, info HadoopJobInfo) : IgniteInternalFuture<HadoopJobId> in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker |
From |
To |
|
Change Variable Type job : HadoopJob to job : HadoopJobEx in method public onJobStateChanged(meta HadoopJobMetadata) : void in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor |
From |
To |
|
Change Variable Type job : HadoopJob to job : HadoopJobEx in method public run(taskCtx HadoopTaskContext) : void in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1ReduceTask |
From |
To |
|
Change Variable Type job : HadoopJob to job : HadoopJobEx in method private processNodeLeft(evt DiscoveryEvent) : void in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker |
From |
To |
|
Change Variable Type job : HadoopJob to job : HadoopJobEx in method private processJobMetaUpdate(jobId HadoopJobId, meta HadoopJobMetadata, locNodeId UUID) : void in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker |
From |
To |
|
Change Variable Type constructor : Constructor<? extends HadoopJob> to constructor : Constructor<? extends HadoopJobEx> in method public createJob(jobCls Class<? extends HadoopJobEx>, jobId HadoopJobId, log IgniteLogger, libNames String[], helper HadoopHelper) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.HadoopDefaultJobInfo |
From |
To |
|
Change Variable Type gridJob : HadoopJob to gridJob : HadoopJobEx in method public testCombinerTask() : void in class org.apache.ignite.internal.processors.hadoop.impl.HadoopTasksAllVersionsTest |
From |
To |
|
Change Variable Type job : HadoopJob to job : HadoopJobEx in method public run(taskCtx HadoopTaskContext) : void in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1MapTask |
From |
To |
|
Change Variable Type gridJob : HadoopJob to gridJob : HadoopJobEx in method public testReduceTask() : void in class org.apache.ignite.internal.processors.hadoop.impl.HadoopTasksAllVersionsTest |
From |
To |
|
Change Variable Type gridJob : HadoopJob to gridJob : HadoopJobEx in method public testAllTasks() : void in class org.apache.ignite.internal.processors.hadoop.impl.HadoopTasksAllVersionsTest |
From |
To |
|
Change Variable Type job : HadoopJob to job : HadoopJobEx in method public job(jobId HadoopJobId, jobInfo HadoopJobInfo) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker |
From |
To |
|
Change Variable Type job : HadoopJob to job : HadoopJobEx in method public testCustomSerializationApplying() : void in class org.apache.ignite.internal.processors.hadoop.impl.HadoopV2JobSelfTest |
From |
To |
|
Change Variable Type fut : GridFutureAdapter<HadoopJob> to fut : GridFutureAdapter<HadoopJobEx> in method public job(jobId HadoopJobId, jobInfo HadoopJobInfo) : HadoopJobEx in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker |
From |
To |
|
Change Variable Type gridJob : HadoopJob to gridJob : HadoopJobEx in method public testMapTask() : void in class org.apache.ignite.internal.processors.hadoop.impl.HadoopTasksAllVersionsTest |
From |
To |