public class IgniteHadoopMapReducePlanner extends Object implements org.apache.ignite.internal.processors.hadoop.HadoopMapReducePlanner
| Constructor and Description |
|---|
IgniteHadoopMapReducePlanner() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.ignite.internal.processors.hadoop.HadoopMapReducePlan |
preparePlan(org.apache.ignite.internal.processors.hadoop.HadoopJob job,
Collection<ClusterNode> top,
org.apache.ignite.internal.processors.hadoop.HadoopMapReducePlan oldPlan)
Prepares map-reduce execution plan for the given job and topology.
|
protected int |
reducerNodeWeight(ClusterNode node,
int splitCnt)
Calculate node weight based on node metrics and data co-location.
|
public org.apache.ignite.internal.processors.hadoop.HadoopMapReducePlan preparePlan(org.apache.ignite.internal.processors.hadoop.HadoopJob job,
Collection<ClusterNode> top,
@Nullable
org.apache.ignite.internal.processors.hadoop.HadoopMapReducePlan oldPlan)
throws IgniteCheckedException
preparePlan in interface org.apache.ignite.internal.processors.hadoop.HadoopMapReducePlannerjob - Job.top - Topology.oldPlan - Old plan in case of partial failure.IgniteCheckedExceptionprotected int reducerNodeWeight(ClusterNode node, int splitCnt)
node - Node.splitCnt - Splits mapped to this node.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016