public class HadoopContext extends Object
| Constructor and Description |
|---|
HadoopContext(GridKernalContext ctx,
HadoopConfiguration cfg,
HadoopJobTracker jobTracker,
HadoopTaskExecutorAdapter taskExecutor,
HadoopShuffle shuffle) |
| Modifier and Type | Method and Description |
|---|---|
List<HadoopComponent> |
components()
Gets list of managers.
|
HadoopConfiguration |
configuration()
Gets Hadoop configuration.
|
boolean |
isParticipating(HadoopJobMetadata meta) |
HadoopJobTracker |
jobTracker() |
boolean |
jobUpdateLeader() |
GridKernalContext |
kernalContext()
Gets kernal context.
|
UUID |
localNodeId()
Gets local node ID.
|
long |
localNodeOrder()
Gets local node order.
|
Collection<ClusterNode> |
nodes() |
HadoopMapReducePlanner |
planner() |
HadoopShuffle |
shuffle() |
HadoopTaskExecutorAdapter |
taskExecutor() |
public HadoopContext(GridKernalContext ctx, HadoopConfiguration cfg, HadoopJobTracker jobTracker, HadoopTaskExecutorAdapter taskExecutor, HadoopShuffle shuffle)
ctx - Kernal context.public List<HadoopComponent> components()
public GridKernalContext kernalContext()
public HadoopConfiguration configuration()
public UUID localNodeId()
kernalContext().localNodeId().public long localNodeOrder()
public Collection<ClusterNode> nodes()
public boolean jobUpdateLeader()
True ifpublic boolean isParticipating(HadoopJobMetadata meta)
meta - Job metadata.true If local node is participating in job execution.public HadoopJobTracker jobTracker()
public HadoopTaskExecutorAdapter taskExecutor()
public HadoopShuffle shuffle()
public HadoopMapReducePlanner planner()
Follow @ApacheIgnite
Ignite Fabric : ver. 2.5.1-p166 Release Date : September 3 2019