|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MROperPlan | |
---|---|
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | |
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans | |
org.apache.pig.tools.pigstats.mapreduce |
Uses of MROperPlan in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer |
---|
Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer that return MROperPlan | |
---|---|
MROperPlan |
MRCompiler.compile()
The front-end method that the user calls to compile the plan. |
MROperPlan |
MapReduceLauncher.compile(PhysicalPlan php,
PigContext pc)
|
MROperPlan |
MRCompiler.getMRPlan()
Used to get the compiled plan |
Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type MROperPlan | |
---|---|
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. |
org.apache.hadoop.mapred.jobcontrol.JobControl |
JobControlCompiler.compile(MROperPlan plan,
String grpName)
Compiles all jobs that have no dependencies removes them from the plan and returns. |
Constructors in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type MROperPlan | |
---|---|
AccumulatorOptimizer(MROperPlan plan)
|
|
CombinerOptimizer(MROperPlan plan,
boolean doMapAgg)
|
|
CombinerOptimizer(MROperPlan plan,
boolean doMapAgg,
CompilationMessageCollector messageCollector)
|
|
KeyTypeDiscoveryVisitor(MROperPlan plan)
|
|
LimitAdjuster(MROperPlan plan,
PigContext pigContext)
|
|
SampleOptimizer(MROperPlan plan,
PigContext pigContext)
|
|
SecondaryKeyOptimizer(MROperPlan plan)
|
Uses of MROperPlan in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans |
---|
Constructors in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans with parameters of type MROperPlan | |
---|---|
DotMRPrinter(MROperPlan plan,
PrintStream ps)
|
|
EndOfAllInputSetter(MROperPlan plan)
|
|
MRIntermediateDataVisitor(MROperPlan plan)
|
|
MROpPlanVisitor(MROperPlan plan,
PlanWalker<MapReduceOper,MROperPlan> walker)
|
|
MRPrinter(PrintStream ps,
MROperPlan plan)
|
|
POPackageAnnotator(MROperPlan plan)
|
|
XMLMRPrinter(PrintStream ps,
MROperPlan plan)
|
Constructor parameters in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans with type arguments of type MROperPlan | |
---|---|
MROpPlanVisitor(MROperPlan plan,
PlanWalker<MapReduceOper,MROperPlan> walker)
|
Uses of MROperPlan in org.apache.pig.tools.pigstats.mapreduce |
---|
Methods in org.apache.pig.tools.pigstats.mapreduce with parameters of type MROperPlan | |
---|---|
void |
MRScriptState.addWorkflowAdjacenciesToConf(MROperPlan mrop,
org.apache.hadoop.conf.Configuration conf)
|
static void |
MRPigStatsUtil.startCollection(PigContext pc,
org.apache.hadoop.mapred.JobClient client,
JobControlCompiler jcc,
MROperPlan plan)
Starts collecting statistics for the given MR plan |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |