org.apache.ignite.internal.processors.hadoop

Interface GridHadoopMapReducePlanner

public interface GridHadoopMapReducePlanner

Map-reduce execution planner.

Method Summary

Methods

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

Method Detail

preparePlan

GridHadoopMapReducePlan preparePlan(GridHadoopJob job,
                                  Collection<ClusterNode> top,
                                  @Nullable
                                  GridHadoopMapReducePlan 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