org.apache.ignite.hadoop.planner

Class HadoopAbstractMapReducePlanner

java.lang.Object

org.apache.ignite.hadoop.planner.HadoopAbstractMapReducePlanner

All Implemented Interfaces:

HadoopMapReducePlanner

Direct Known Subclasses:

IgniteHadoopWeightedMapReducePlanner

public abstract class HadoopAbstractMapReducePlanner
extends Object
implements HadoopMapReducePlanner

Base class for map-reduce planners.

Field Summary

Fields

Modifier and Type	Field and Description
protected Ignite	ignite Injected grid.
protected IgniteLogger	log Logger.

Constructor Summary

Constructors

Constructor and Description
HadoopAbstractMapReducePlanner()

Method Summary

Modifier and Type	Method and Description
protected static Map<String,Collection<UUID>>	groupByHost(Collection<ClusterNode> top) Groups nodes by host names.
protected static org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanTopology	topology(Collection<ClusterNode> nodes) Create plan topology.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.hadoop.HadoopMapReducePlanner

preparePlan

Field Detail

ignite

@IgniteInstanceResource
protected Ignite ignite

Injected grid.

log

@LoggerResource
protected IgniteLogger log

Logger.

Constructor Detail

HadoopAbstractMapReducePlanner

public HadoopAbstractMapReducePlanner()

Method Detail

topology

protected static org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanTopology topology(Collection<ClusterNode> nodes)

Create plan topology.

Parameters:

nodes - Topology nodes.

Returns:

Plan topology.

groupByHost

protected static Map<String,Collection<UUID>> groupByHost(Collection<ClusterNode> top)

Groups nodes by host names.

Parameters:

top - Topology to group.

Returns:

Map.