org.apache.ignite.hadoop.planner

Class HadoopTestRoundRobinMrPlanner

java.lang.Object

org.apache.ignite.hadoop.planner.HadoopTestRoundRobinMrPlanner

All Implemented Interfaces:

HadoopMapReducePlanner

public class HadoopTestRoundRobinMrPlanner
extends Object
implements HadoopMapReducePlanner

Round-robin mr planner.

Constructor Summary

Constructors

Constructor and Description
HadoopTestRoundRobinMrPlanner()

Method Summary

Modifier and Type	Method and Description
HadoopMapReducePlan	preparePlan(HadoopJob job, Collection<ClusterNode> top, @Nullable HadoopMapReducePlan oldPlan) Prepares map-reduce execution plan for the given job and topology.

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopTestRoundRobinMrPlanner

public HadoopTestRoundRobinMrPlanner()

Method Detail

preparePlan

public HadoopMapReducePlan preparePlan(HadoopJob job,
                                       Collection<ClusterNode> top,
                                       @Nullable
                                       @Nullable HadoopMapReducePlan oldPlan)
                                throws IgniteCheckedException

Prepares map-reduce execution plan for the given job and topology.

Specified by:

preparePlan in interface HadoopMapReducePlanner

Parameters:

job - Job.

top - Topology.

oldPlan - Old plan in case of partial failure.

Returns:

Map reduce plan.

Throws:

IgniteCheckedException - If an error occurs.