Uses of Class
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper

Packages that use MapReduceOper

org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans
org.apache.pig.tools.pigstats.mapreduce

Uses of MapReduceOper in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

Subclasses of MapReduceOper in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

class

NativeMapReduceOper

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer that return types with arguments of type MapReduceOper

Map<org.apache.hadoop.mapred.jobcontrol.Job,MapReduceOper>

JobControlCompiler.getJobMroMap() Gets the map of Job and the MR Operator

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type MapReduceOper

void	JobControlCompiler.adjustNumReducers(MROperPlan plan, MapReduceOper mro, org.apache.hadoop.mapreduce.Job nwJob) Adjust the number of reducers based on the default_parallel, requested parallel and estimated parallel.
int	PigReducerEstimator.estimateNumberOfReducers(org.apache.hadoop.mapreduce.Job job, MapReduceOper mapReduceOper) Estimate the number of reducers for a given job based on the collection of load funcs passed.
static int	JobControlCompiler.estimateNumberOfReducers(org.apache.hadoop.mapreduce.Job job, MapReduceOper mapReducerOper) Looks up the estimator from REDUCER_ESTIMATOR_KEY and invokes it to find the number of reducers to use.
int	InputSizeReducerEstimator.estimateNumberOfReducers(org.apache.hadoop.mapreduce.Job job, MapReduceOper mapReduceOper) Determines the number of reducers to be used.
static void	MRUtil.simpleConnectMapToReduce(MapReduceOper mro, String scope, NodeIdGenerator nig)
void	SecondaryKeyOptimizer.visitMROp(MapReduceOper mr)
void	SampleOptimizer.visitMROp(MapReduceOper mr)
void	LimitAdjuster.visitMROp(MapReduceOper mr)
void	KeyTypeDiscoveryVisitor.visitMROp(MapReduceOper mr)
void	CombinerOptimizer.visitMROp(MapReduceOper mr)
void	AccumulatorOptimizer.visitMROp(MapReduceOper mr)

Uses of MapReduceOper in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans with parameters of type MapReduceOper

protected String[]	DotMRPrinter.getAttributes(MapReduceOper op)
protected String	DotMRPrinter.getName(MapReduceOper op)
protected Collection<DotMRPrinter.InnerPlan>	DotMRPrinter.getNestedPlans(MapReduceOper op)
void	XMLMRPrinter.visitMROp(MapReduceOper mr)
void	POPackageAnnotator.visitMROp(MapReduceOper mr)
void	MRPrinter.visitMROp(MapReduceOper mr)
void	MROpPlanVisitor.visitMROp(MapReduceOper mr)
void	MRIntermediateDataVisitor.visitMROp(MapReduceOper mr)
void	EndOfAllInputSetter.visitMROp(MapReduceOper mr)

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans with type arguments of type MapReduceOper

MROpPlanVisitor(MROperPlan plan, PlanWalker<MapReduceOper,MROperPlan> walker)

Uses of MapReduceOper in org.apache.pig.tools.pigstats.mapreduce

Methods in org.apache.pig.tools.pigstats.mapreduce with parameters of type MapReduceOper

void	MRScriptState.addSettingsToConf(MapReduceOper mro, org.apache.hadoop.conf.Configuration conf)
String	MRScriptState.getAlias(MapReduceOper mro)
String	MRScriptState.getAliasLocation(MapReduceOper mro)
String	MRScriptState.getPigFeature(MapReduceOper mro)

Method parameters in org.apache.pig.tools.pigstats.mapreduce with type arguments of type MapReduceOper

static void

MRPigStatsUtil.updateJobMroMap(Map<org.apache.hadoop.mapred.jobcontrol.Job,MapReduceOper> jobMroMap) Updates the PigStats.JobGraph of the PigStats.