| 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 | 
|---|
LOCogroup(LogicalPlan plan)
Constructor for use in defining rule patterns 
 | 
LOCross(LogicalPlan plan)  | 
LOCube(LogicalPlan plan)  | 
LODistinct(LogicalPlan plan)  | 
LOFilter(LogicalPlan plan)  | 
LOFilter(LogicalPlan plan,
        boolean sample)  | 
LOFilter(LogicalPlan plan,
        LogicalExpressionPlan filterPlan)  | 
LOFilter(LogicalPlan plan,
        LogicalExpressionPlan filterPlan,
        boolean sample)  | 
LogicalPlan(LogicalPlan other)  | 
LogicalPlanData(LogicalPlan lp)  | 
LOInnerLoad(LogicalPlan plan,
           LOForEach foreach,
           ProjectExpression projectExpression)  | 
LOJoin(LogicalPlan plan)  | 
LOJoin(LogicalPlan plan,
      MultiMap<java.lang.Integer,LogicalExpressionPlan> joinPlans,
      LOJoin.JOINTYPE jt,
      boolean[] isInner)  | 
LOLimit(LogicalPlan plan)  | 
LOLimit(LogicalPlan plan,
       LogicalExpressionPlan limitPlan)  | 
LOLimit(LogicalPlan plan,
       long limit)  | 
LOLoad(FileSpec loader,
      LogicalSchema schema,
      LogicalPlan plan,
      org.apache.hadoop.conf.Configuration conf,
      LoadFunc loadFunc,
      java.lang.String signature)
Used from the LogicalPlanBuilder 
 | 
LOLoad(LogicalSchema schema,
      LogicalPlan plan)
used for pattern matching 
 | 
LOSplitOutput(LogicalPlan plan)  | 
LOSplitOutput(LogicalPlan plan,
             LogicalExpressionPlan filterPlan)  | 
LOStore(LogicalPlan plan,
       FileSpec outputFileSpec,
       StoreFuncInterface storeFunc,
       java.lang.String signature)  | 
LOStore(LogicalPlan plan,
       FileSpec outputFileSpec,
       StoreFuncInterface storeFunc,
       java.lang.String signature,
       boolean disambiguationEnabled)  | 
LOStream(LogicalPlan plan,
        ExecutableManager exeManager,
        StreamingCommand cmd,
        LogicalSchema schema)  | 
| 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 | 
|---|
PigPlans(LogicalPlan lp)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ScriptState.setScriptFeatures(LogicalPlan plan)  | 
Copyright © 2007-2025 The Apache Software Foundation