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.HadoopMapReducePlanner
job
- Job.top
- Topology.oldPlan
- Old plan in case of partial failure.IgniteCheckedException
protected int reducerNodeWeight(ClusterNode node, int splitCnt)
node
- Node.splitCnt
- Splits mapped to this node.
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015