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(String alias) |
Modifier and Type | Method and Description |
---|---|
Map<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,
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,
PrintStream ps,
String format,
boolean verbose,
File dir,
String suffix)
This method handles the backend processing of the Explain command.
|
PigStats |
ExecutionEngine.launchPig(LogicalPlan lp,
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,
Properties properties) |
void |
HExecutionEngine.explain(LogicalPlan lp,
PigContext pc,
PrintStream ps,
String format,
boolean verbose,
File file,
String suffix) |
Map<LOForEach,Map<LogicalRelationalOperator,PhysicalOperator>> |
HExecutionEngine.getForEachInnerLogToPhyMap(LogicalPlan plan) |
PigStats |
HExecutionEngine.launchPig(LogicalPlan lp,
String grpName,
PigContext pc) |
Modifier and Type | Method and Description |
---|---|
static LOForEach |
Util.addForEachAfter(LogicalPlan plan,
LogicalRelationalOperator op,
int branch,
Set<Integer> columnsToDrop) |
static <C extends LogicalRelationalOperator> |
Util.getLogicalRelationalOperators(LogicalPlan plan,
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) |
List<Operator> |
LOUnion.getInputs(LogicalPlan plan) |
List<Operator> |
LOJoin.getInputs(LogicalPlan plan) |
List<Operator> |
LOCube.getInputs(LogicalPlan plan) |
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(String query) |
Modifier and Type | Method and Description |
---|---|
static void |
QueryParserUtils.attachStorePlan(String scope,
LogicalPlan lp,
String fileName,
String func,
Operator input,
String alias,
PigContext pigContext) |
Modifier and Type | Method and Description |
---|---|
static Map<LogicalRelationalOperator,Collection<IdentityHashSet<Tuple>>> |
EquivalenceClasses.getLoToEqClassMap(PhysicalPlan plan,
LogicalPlan lp,
Map<Operator,PhysicalOperator> logToPhyMap,
Map<Operator,DataBag> logToDataMap,
Map<LOForEach,Map<LogicalRelationalOperator,PhysicalOperator>> forEachInnerLogToPhyMap,
HashMap<PhysicalOperator,Collection<IdentityHashSet<Tuple>>> poToEqclassesMap) |
Constructor and Description |
---|
ExampleGenerator(LogicalPlan plan,
PigContext hadoopPigContext) |
LineageTrimmingVisitor(LogicalPlan plan,
Map<LOLoad,DataBag> baseData,
ExampleGenerator eg,
Map<Operator,PhysicalOperator> LogToPhyMap,
PhysicalPlan physPlan,
PigContext pc) |
Modifier and Type | Method and Description |
---|---|
static void |
DisplayExamples.printSimple(Operator op,
LogicalPlan lp,
Map<Operator,DataBag> exampleData) |
static String |
DisplayExamples.printTabular(LogicalPlan lp,
Map<Operator,DataBag> exampleData,
Map<LOForEach,Map<LogicalRelationalOperator,DataBag>> forEachInnerLogToDataMap) |
Modifier and Type | Field and Description |
---|---|
LogicalPlan |
ToolsPigServer.PigPlans.lp |
Modifier and Type | Method and Description |
---|---|
List<ExecJob> |
ToolsPigServer.runPlan(LogicalPlan newPlan,
String jobName)
Given a (modified) new logical plan, run the script.
|
Constructor and Description |
---|
PigPlans(LogicalPlan lp) |
Modifier and Type | Method and Description |
---|---|
void |
ScriptState.setScriptFeatures(LogicalPlan plan) |
Copyright © 2007-2017 The Apache Software Foundation