org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
Class MRUtil

java.lang.Object
  org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRUtil

public class MRUtil
extends Object

Constructor Summary

MRUtil()

Method Summary

static POForEach	getPlainForEachOP(String scope, NodeIdGenerator nig)
static void	simpleConnectMapToReduce(MapReduceOper mro, String scope, NodeIdGenerator nig)

Methods inherited from class java.lang.Object

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

Constructor Detail

MRUtil

public MRUtil()

Method Detail

simpleConnectMapToReduce

public static void simpleConnectMapToReduce(MapReduceOper mro,
                                            String scope,
                                            NodeIdGenerator nig)
                                     throws PlanException

Throws:

PlanException

getPlainForEachOP

public static POForEach getPlainForEachOP(String scope,
                                          NodeIdGenerator nig)