Uses of Class
org.apache.ignite.internal.processors.hadoop.HadoopJobId

Packages that use HadoopJobId

Package	Description
org.apache.ignite.internal.processors.hadoop	Contains Hadoop APIs.
org.apache.ignite.internal.processors.hadoop.shuffle

Uses of HadoopJobId in org.apache.ignite.internal.processors.hadoop

Methods in org.apache.ignite.internal.processors.hadoop that return HadoopJobId

Modifier and Type	Method and Description
abstract HadoopJobId	HadoopJobEx.id() Gets job ID.
HadoopJobId	HadoopJobStatus.jobId()
HadoopJobId	HadoopTaskInfo.jobId()
HadoopJobId	HadoopNoopProcessor.nextJobId()
abstract HadoopJobId	HadoopProcessorAdapter.nextJobId()
HadoopJobId	Hadoop.nextJobId() Generate next job ID.

Methods in org.apache.ignite.internal.processors.hadoop with parameters of type HadoopJobId

Modifier and Type	Method and Description
HadoopCounters	HadoopNoopProcessor.counters(HadoopJobId jobId) Returns Hadoop job counters.
abstract HadoopCounters	HadoopProcessorAdapter.counters(HadoopJobId jobId) Returns Hadoop job counters.
HadoopCounters	Hadoop.counters(HadoopJobId jobId) Returns job counters.
HadoopJobEx	HadoopDefaultJobInfo.createJob(Class<? extends HadoopJobEx> jobCls, HadoopJobId jobId, IgniteLogger log, String[] libNames, HadoopHelper helper) Creates new job instance for the given ID.
HadoopJobEx	HadoopJobInfo.createJob(Class<? extends HadoopJobEx> jobCls, HadoopJobId jobId, IgniteLogger log, String[] libNames, HadoopHelper helper) Creates new job instance for the given ID.
IgniteInternalFuture<?>	HadoopNoopProcessor.finishFuture(HadoopJobId jobId) Gets Hadoop job finish future.
abstract IgniteInternalFuture<?>	HadoopProcessorAdapter.finishFuture(HadoopJobId jobId) Gets Hadoop job finish future.
IgniteInternalFuture<?>	Hadoop.finishFuture(HadoopJobId jobId) Gets Hadoop finish future for particular job.
boolean	HadoopNoopProcessor.kill(HadoopJobId jobId) Kills job.
abstract boolean	HadoopProcessorAdapter.kill(HadoopJobId jobId) Kills job.
boolean	Hadoop.kill(HadoopJobId jobId) Kills job.
static String	HadoopClassLoader.nameForJob(HadoopJobId jobId) Classloader name for job.
HadoopJobStatus	HadoopNoopProcessor.status(HadoopJobId jobId) Gets Hadoop job execution status.
abstract HadoopJobStatus	HadoopProcessorAdapter.status(HadoopJobId jobId) Gets Hadoop job execution status.
HadoopJobStatus	Hadoop.status(HadoopJobId jobId) Gets Hadoop job execution status.
IgniteInternalFuture<?>	HadoopNoopProcessor.submit(HadoopJobId jobId, HadoopJobInfo jobInfo) Submits job to job tracker.
abstract IgniteInternalFuture<?>	HadoopProcessorAdapter.submit(HadoopJobId jobId, HadoopJobInfo jobInfo) Submits job to job tracker.
IgniteInternalFuture<?>	Hadoop.submit(HadoopJobId jobId, HadoopJobInfo jobInfo) Submits job to job tracker.

Constructors in org.apache.ignite.internal.processors.hadoop with parameters of type HadoopJobId

Constructor and Description
HadoopJobStatus(HadoopJobId jobId, String jobName, String usr, int pendingMapperCnt, int pendingReducerCnt, int totalMapperCnt, int totalReducerCnt, HadoopJobPhase jobPhase, boolean failed, long ver) Constructor.
HadoopTaskInfo(HadoopTaskType type, HadoopJobId jobId, int taskNum, int attempt, HadoopInputSplit inputSplit) Creates new task info.

Uses of HadoopJobId in org.apache.ignite.internal.processors.hadoop.shuffle

Methods in org.apache.ignite.internal.processors.hadoop.shuffle that return HadoopJobId

Modifier and Type	Method and Description
HadoopJobId	HadoopDirectShuffleMessage.jobId()
HadoopJobId	HadoopShuffleFinishResponse.jobId()
HadoopJobId	HadoopShuffleFinishRequest.jobId()
HadoopJobId	HadoopShuffleMessage.jobId()
HadoopJobId	HadoopShuffleAck.jobId()

Constructors in org.apache.ignite.internal.processors.hadoop.shuffle with parameters of type HadoopJobId

Constructor and Description
HadoopDirectShuffleMessage(HadoopJobId jobId, int reducer, int cnt, byte[] buf, int bufLen, int dataLen) Constructor.
HadoopShuffleAck(long msgId, HadoopJobId jobId)
HadoopShuffleFinishRequest(HadoopJobId jobId, long msgCnt) Constructor.
HadoopShuffleFinishResponse(HadoopJobId jobId) Constructor.
HadoopShuffleMessage(HadoopJobId jobId, int reducer, int size)