| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.hadoop |
Contains Hadoop APIs.
|
| org.apache.ignite.internal.processors.hadoop.counter |
| Modifier and Type | Field and Description |
|---|---|
protected HadoopJob |
HadoopTaskContext.job |
| Modifier and Type | Method and Description |
|---|---|
HadoopJob |
HadoopJobInfo.createJob(Class<? extends HadoopJob> jobCls,
HadoopJobId jobId,
IgniteLogger log,
String[] libNames,
HadoopHelper helper)
Creates new job instance for the given ID.
|
HadoopJob |
HadoopDefaultJobInfo.createJob(Class<? extends HadoopJob> jobCls,
HadoopJobId jobId,
IgniteLogger log,
String[] libNames,
HadoopHelper helper)
Creates new job instance for the given ID.
|
HadoopJob |
HadoopTaskContext.job() |
| Modifier and Type | Method and Description |
|---|---|
HadoopMapReducePlan |
HadoopMapReducePlanner.preparePlan(HadoopJob job,
Collection<ClusterNode> top,
HadoopMapReducePlan oldPlan)
Prepares map-reduce execution plan for the given job and topology.
|
| Modifier and Type | Method and Description |
|---|---|
HadoopJob |
HadoopJobInfo.createJob(Class<? extends HadoopJob> jobCls,
HadoopJobId jobId,
IgniteLogger log,
String[] libNames,
HadoopHelper helper)
Creates new job instance for the given ID.
|
HadoopJob |
HadoopDefaultJobInfo.createJob(Class<? extends HadoopJob> jobCls,
HadoopJobId jobId,
IgniteLogger log,
String[] libNames,
HadoopHelper helper)
Creates new job instance for the given ID.
|
| Constructor and Description |
|---|
HadoopTaskContext(HadoopTaskInfo taskInfo,
HadoopJob job) |
| Modifier and Type | Method and Description |
|---|---|
void |
HadoopCounterWriter.write(HadoopJob job,
HadoopCounters cntrs)
Writes counters of given job to some statistics storage.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.8.0 Release Date : December 5 2016