Package | Description |
---|---|
org.apache.pig |
Public interfaces and classes for Pig.
|
org.apache.pig.backend.executionengine | |
org.apache.pig.backend.hadoop.executionengine | |
org.apache.pig.newplan.logical | |
org.apache.pig.newplan.logical.relational | |
org.apache.pig.newplan.logical.visitor | |
org.apache.pig.parser | |
org.apache.pig.pen | |
org.apache.pig.pen.util | |
org.apache.pig.tools | |
org.apache.pig.tools.pigstats |
Modifier and Type | Method and Description |
---|---|
LogicalPlan |
PigServer.Graph.getLogicalPlan() |
LogicalPlan |
PigServer.Graph.getPlan(java.lang.String alias) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,LogicalPlan> |
PigServer.getAliases()
Return a map containing the logical plan associated with each alias.
|
Modifier and Type | Method and Description |
---|---|
protected PigStats |
PigServer.launchPlan(LogicalPlan lp,
java.lang.String jobName)
A common method for launching the jobs according to the logical plan
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutionEngine.explain(LogicalPlan lp,
PigContext pc,
java.io.PrintStream ps,
java.lang.String format,
boolean verbose,
java.io.File dir,
java.lang.String suffix)
This method handles the backend processing of the Explain command.
|
PigStats |
ExecutionEngine.launchPig(LogicalPlan lp,
java.lang.String grpName,
PigContext pc)
This method is responsible for the actual execution of a LogicalPlan.
|
Modifier and Type | Method and Description |
---|---|
PhysicalPlan |
HExecutionEngine.compile(LogicalPlan plan,
java.util.Properties properties) |
void |
HExecutionEngine.explain(LogicalPlan lp,
PigContext pc,
java.io.PrintStream ps,
java.lang.String format,
boolean verbose,
java.io.File file,
java.lang.String suffix) |
java.util.Map<LOForEach,java.util.Map<LogicalRelationalOperator,PhysicalOperator>> |
HExecutionEngine.getForEachInnerLogToPhyMap(LogicalPlan plan) |
PigStats |
HExecutionEngine.launchPig(LogicalPlan lp,
java.lang.String grpName,
PigContext pc) |
Modifier and Type | Method and Description |
---|---|
static LOForEach |
Util.addForEachAfter(LogicalPlan plan,
LogicalRelationalOperator op,
int branch,
java.util.Set<java.lang.Integer> columnsToDrop) |
static <C extends LogicalRelationalOperator> |
Util.getLogicalRelationalOperators(LogicalPlan plan,
java.lang.Class<C> opClass)
Returns a LinkedList of operators contained within the physical plan
which implement the supplied class, in dependency order.
|
Modifier and Type | Method and Description |
---|---|
LogicalPlan |
LOForEach.getInnerPlan() |
Modifier and Type | Method and Description |
---|---|
Operator |
LOSort.getInput(LogicalPlan plan) |
Operator |
LOLimit.getInput(LogicalPlan plan) |
Operator |
LOFilter.getInput(LogicalPlan plan) |
Operator |
LODistinct.getInput(LogicalPlan plan) |
java.util.List<Operator> |
LOUnion.getInputs(LogicalPlan plan) |
java.util.List<Operator> |
LOJoin.getInputs(LogicalPlan plan) |
java.util.List<Operator> |
LOCube.getInputs(LogicalPlan plan) |
java.util.List<Operator> |
LOCogroup.getInputs(LogicalPlan plan) |
void |
LOForEach.setInnerPlan(LogicalPlan p) |
Constructor and Description |
---|
CastLineageSetter(LogicalPlan plan,
CompilationMessageCollector msgCollector) |
ImplicitSplitInsertVisitor(LogicalPlan plan) |
Modifier and Type | Method and Description |
---|---|
LogicalPlan |
QueryParserDriver.parse(java.lang.String query) |
Modifier and Type | Method and Description |
---|---|
static void |
QueryParserUtils.attachStorePlan(java.lang.String scope,
LogicalPlan lp,
java.lang.String fileName,
java.lang.String func,
Operator input,
java.lang.String alias,
PigContext pigContext) |
Modifier and Type | Method and Description |
---|---|
static java.util.Map<LogicalRelationalOperator,java.util.Collection<IdentityHashSet<Tuple>>> |
EquivalenceClasses.getLoToEqClassMap(PhysicalPlan plan,
LogicalPlan lp,
java.util.Map<Operator,PhysicalOperator> logToPhyMap,
java.util.Map<Operator,DataBag> logToDataMap,
java.util.Map<LOForEach,java.util.Map<LogicalRelationalOperator,PhysicalOperator>> forEachInnerLogToPhyMap,
java.util.HashMap<PhysicalOperator,java.util.Collection<IdentityHashSet<Tuple>>> poToEqclassesMap) |
Constructor and Description |
---|
ExampleGenerator(LogicalPlan plan,
PigContext hadoopPigContext) |
LineageTrimmingVisitor(LogicalPlan plan,
java.util.Map<LOLoad,DataBag> baseData,
ExampleGenerator eg,
java.util.Map<Operator,PhysicalOperator> LogToPhyMap,
PhysicalPlan physPlan,
PigContext pc) |
Modifier and Type | Method and Description |
---|---|
static void |
DisplayExamples.printSimple(Operator op,
LogicalPlan lp,
java.util.Map<Operator,DataBag> exampleData) |
static java.lang.String |
DisplayExamples.printTabular(LogicalPlan lp,
java.util.Map<Operator,DataBag> exampleData,
java.util.Map<LOForEach,java.util.Map<LogicalRelationalOperator,DataBag>> forEachInnerLogToDataMap) |
Modifier and Type | Field and Description |
---|---|
LogicalPlan |
ToolsPigServer.PigPlans.lp |
Modifier and Type | Method and Description |
---|---|
java.util.List<ExecJob> |
ToolsPigServer.runPlan(LogicalPlan newPlan,
java.lang.String jobName)
Given a (modified) new logical plan, run the script.
|
Constructor and Description |
---|
ToolsPigServer.PigPlans(LogicalPlan lp) |
Modifier and Type | Method and Description |
---|---|
void |
ScriptState.setScriptFeatures(LogicalPlan plan) |
Copyright © 2007-2012 The Apache Software Foundation