org.apache.ignite.hadoop

Interface HadoopMapReducePlanner

All Known Implementing Classes:

HadoopAbstractMapReducePlanner, HadoopTestRoundRobinMrPlanner, IgniteHadoopWeightedMapReducePlanner

public interface HadoopMapReducePlanner

Map-reduce execution planner.

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.

Method Detail

preparePlan

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

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

Parameters:

job - Job.

top - Topology.

oldPlan - Old plan in case of partial failure.

Returns:

Map reduce plan.

Throws:

IgniteCheckedException - If an error occurs.