| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.hadoop |
Contains Hadoop APIs.
|
| Modifier and Type | Method and Description |
|---|---|
GridHadoopJobId |
GridHadoopJob.id()
Gets job ID.
|
GridHadoopJobId |
GridHadoopJobStatus.jobId() |
GridHadoopJobId |
GridHadoopTaskInfo.jobId() |
abstract GridHadoopJobId |
IgniteHadoopProcessorAdapter.nextJobId() |
GridHadoopJobId |
IgniteHadoopNoopProcessor.nextJobId() |
GridHadoopJobId |
GridHadoop.nextJobId()
Generate next job ID.
|
| Modifier and Type | Method and Description |
|---|---|
abstract GridHadoopCounters |
IgniteHadoopProcessorAdapter.counters(GridHadoopJobId jobId)
Returns Hadoop job counters.
|
GridHadoopCounters |
IgniteHadoopNoopProcessor.counters(GridHadoopJobId jobId)
Returns Hadoop job counters.
|
GridHadoopCounters |
GridHadoop.counters(GridHadoopJobId jobId)
Returns job counters.
|
GridHadoopJob |
GridHadoopJobInfo.createJob(GridHadoopJobId jobId,
IgniteLogger log)
Creates new job instance for the given ID.
|
abstract IgniteInternalFuture<?> |
IgniteHadoopProcessorAdapter.finishFuture(GridHadoopJobId jobId)
Gets Hadoop job finish future.
|
IgniteInternalFuture<?> |
IgniteHadoopNoopProcessor.finishFuture(GridHadoopJobId jobId)
Gets Hadoop job finish future.
|
IgniteInternalFuture<?> |
GridHadoop.finishFuture(GridHadoopJobId jobId)
Gets Hadoop finish future for particular job.
|
abstract boolean |
IgniteHadoopProcessorAdapter.kill(GridHadoopJobId jobId)
Kills job.
|
boolean |
IgniteHadoopNoopProcessor.kill(GridHadoopJobId jobId)
Kills job.
|
boolean |
GridHadoop.kill(GridHadoopJobId jobId)
Kills job.
|
abstract GridHadoopJobStatus |
IgniteHadoopProcessorAdapter.status(GridHadoopJobId jobId)
Gets Hadoop job execution status.
|
GridHadoopJobStatus |
IgniteHadoopNoopProcessor.status(GridHadoopJobId jobId)
Gets Hadoop job execution status.
|
GridHadoopJobStatus |
GridHadoop.status(GridHadoopJobId jobId)
Gets Hadoop job execution status.
|
abstract IgniteInternalFuture<?> |
IgniteHadoopProcessorAdapter.submit(GridHadoopJobId jobId,
GridHadoopJobInfo jobInfo)
Submits job to job tracker.
|
IgniteInternalFuture<?> |
IgniteHadoopNoopProcessor.submit(GridHadoopJobId jobId,
GridHadoopJobInfo jobInfo)
Submits job to job tracker.
|
IgniteInternalFuture<?> |
GridHadoop.submit(GridHadoopJobId jobId,
GridHadoopJobInfo jobInfo)
Submits job to job tracker.
|
void |
GridHadoopCounterWriter.write(GridHadoopJobInfo jobInfo,
GridHadoopJobId jobId,
GridHadoopCounters cntrs)
Writes counters of given job to some statistics storage.
|
| Constructor and Description |
|---|
GridHadoopJobStatus(GridHadoopJobId jobId,
String jobName,
String usr,
int pendingMapperCnt,
int pendingReducerCnt,
int totalMapperCnt,
int totalReducerCnt,
GridHadoopJobPhase jobPhase,
boolean failed,
long ver)
Constructor.
|
GridHadoopTaskInfo(GridHadoopTaskType type,
GridHadoopJobId jobId,
int taskNum,
int attempt,
GridHadoopInputSplit inputSplit)
Creates new task info.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 17 2015