org.apache.ignite.internal.processors.hadoop.planner

Class HadoopDefaultMapReducePlan

java.lang.Object

org.apache.ignite.internal.processors.hadoop.planner.HadoopDefaultMapReducePlan

All Implemented Interfaces:

Serializable, HadoopMapReducePlan

public class HadoopDefaultMapReducePlan
extends Object
implements HadoopMapReducePlan

Map-reduce plan.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopDefaultMapReducePlan(Map<UUID,Collection<HadoopInputSplit>> mappers, Map<UUID,int[]> reducers)

Method Summary

Modifier and Type	Method and Description
Collection<UUID>	mapperNodeIds()
int	mappers()
Collection<HadoopInputSplit>	mappers(UUID nodeId)
UUID	nodeForReducer(int reducer)
Collection<UUID>	reducerNodeIds()
int	reducers()
int[]	reducers(UUID nodeId)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopDefaultMapReducePlan

public HadoopDefaultMapReducePlan(Map<UUID,Collection<HadoopInputSplit>> mappers,
                                  Map<UUID,int[]> reducers)

Parameters:

mappers - Mappers map.

reducers - Reducers map.

Method Detail

mappers

public int mappers()

Specified by:

mappers in interface HadoopMapReducePlan

reducers

public int reducers()

Specified by:

reducers in interface HadoopMapReducePlan

nodeForReducer

public UUID nodeForReducer(int reducer)

Specified by:

nodeForReducer in interface HadoopMapReducePlan

mappers

@Nullable
public Collection<HadoopInputSplit> mappers(UUID nodeId)

Specified by:

mappers in interface HadoopMapReducePlan

reducers

@Nullable
public int[] reducers(UUID nodeId)

Specified by:

reducers in interface HadoopMapReducePlan

mapperNodeIds

public Collection<UUID> mapperNodeIds()

Specified by:

mapperNodeIds in interface HadoopMapReducePlan

reducerNodeIds

public Collection<UUID> reducerNodeIds()

Specified by:

reducerNodeIds in interface HadoopMapReducePlan