org.apache.ignite.internal.processors.hadoop

Class HadoopContext

java.lang.Object

org.apache.ignite.internal.processors.hadoop.HadoopContext

public class HadoopContext
extends Object

Hadoop accelerator context.

Constructor Summary

Constructors

Constructor and Description
HadoopContext(GridKernalContext ctx, HadoopConfiguration cfg, HadoopJobTracker jobTracker, HadoopTaskExecutorAdapter taskExecutor, HadoopShuffle shuffle)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HadoopContext

public HadoopContext(GridKernalContext ctx,
                     HadoopConfiguration cfg,
                     HadoopJobTracker jobTracker,
                     HadoopTaskExecutorAdapter taskExecutor,
                     HadoopShuffle shuffle)

Parameters:

ctx - Kernal context.

Method Detail

components

public List<HadoopComponent> components()

Gets list of managers.

Returns:

List of managers.

kernalContext

public GridKernalContext kernalContext()

Gets kernal context.

Returns:

Grid kernal context instance.

configuration

public HadoopConfiguration configuration()

Gets Hadoop configuration.

Returns:

Hadoop configuration.

localNodeId

public UUID localNodeId()

Gets local node ID. Shortcut for kernalContext().localNodeId().

Returns:

Local node ID.

localNodeOrder

public long localNodeOrder()

Gets local node order.

Returns:

Local node order.

nodes

public Collection<ClusterNode> nodes()

Returns:

Hadoop-enabled nodes.

jobUpdateLeader

public boolean jobUpdateLeader()

Returns:

True if

isParticipating

public boolean isParticipating(HadoopJobMetadata meta)

Parameters:

meta - Job metadata.

Returns:

true If local node is participating in job execution.

jobTracker

public HadoopJobTracker jobTracker()

Returns:

Jon tracker instance.

taskExecutor

public HadoopTaskExecutorAdapter taskExecutor()

Returns:

Task executor.

shuffle

public HadoopShuffle shuffle()

Returns:

Shuffle.

planner

public HadoopMapReducePlanner planner()

Returns:

Map-reduce planner.