| Modifier and Type | Method and Description | 
|---|---|
| java.util.Map<LOForEach,java.util.Map<LogicalRelationalOperator,PhysicalOperator>> | HExecutionEngine. getForEachInnerLogToPhyMap(LogicalPlan plan) | 
| Modifier and Type | Method and Description | 
|---|---|
| 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 | 
|---|---|
| static LOForEach | Util. addForEachAfter(LogicalPlan plan,
               LogicalRelationalOperator op,
               int branch,
               java.util.Set<java.lang.Integer> columnsToDrop) | 
| Modifier and Type | Field and Description | 
|---|---|
| protected LogicalRelationalOperator | ExpToPhyTranslationVisitor. currentOp | 
| Modifier and Type | Method and Description | 
|---|---|
| LogicalRelationalOperator | ProjectExpression. findReferent()Find the LogicalRelationalOperator that this projection refers to. | 
| LogicalRelationalOperator | ProjectExpression. getAttachedRelationalOp() | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ProjectExpression. setAttachedRelationalOp(LogicalRelationalOperator attachedRelationalOp) | 
| Constructor and Description | 
|---|
| ExpToPhyTranslationVisitor(OperatorPlan plan,
                          LogicalRelationalOperator op,
                          PhysicalPlan phyPlan,
                          java.util.Map<Operator,PhysicalOperator> map) | 
| ExpToPhyTranslationVisitor(OperatorPlan plan,
                          PlanWalker walker,
                          LogicalRelationalOperator op,
                          PhysicalPlan phyPlan,
                          java.util.Map<Operator,PhysicalOperator> map) | 
| ProjectExpression(OperatorPlan plan,
                 int inputNum,
                 int colNum,
                 LogicalRelationalOperator attachedRelationalOp)Adds projection to the plan. | 
| ProjectExpression(OperatorPlan plan,
                 int inputNum,
                 LogicalRelationalOperator attachedRelationalOp)Constructor for range projection
 Adds projection to the plan. | 
| ProjectExpression(OperatorPlan plan,
                 int inputNum,
                 java.lang.String alias,
                 Operator projectedOp,
                 LogicalRelationalOperator attachedRelationalOp)Adds projection to the plan. | 
| Modifier and Type | Field and Description | 
|---|---|
| protected LogicalRelationalOperator | AllExpressionVisitor. currentOp | 
| Modifier and Type | Method and Description | 
|---|---|
| protected abstract void | AllSameRalationalNodesVisitor. execute(LogicalRelationalOperator op)Method to call on every node in the logical plan. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | LOCogroup | 
| class  | LOCross | 
| class  | LOCubeCUBE operator implementation for data cube computation. | 
| class  | LODistinct | 
| class  | LOFilter | 
| class  | LOForEach | 
| class  | LOGenerate | 
| class  | LOInnerLoadOperator to map the data into the inner plan of LOForEach
 It can only be used in the inner plan of LOForEach | 
| class  | LOJoin | 
| class  | LOLimit | 
| class  | LOLoad | 
| class  | LONative | 
| class  | LORankRANK operator implementation. | 
| class  | LOSort | 
| class  | LOSplit | 
| class  | LOSplitOutput | 
| class  | LOStore | 
| class  | LOStream | 
| class  | LOUnion | 
| Modifier and Type | Method and Description | 
|---|---|
| protected boolean | LogicalRelationalOperator. checkEquality(LogicalRelationalOperator other)Do some basic equality checks on two relational operators. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected abstract LogicalSchema | TypeCastInserter. determineSchema(LogicalRelationalOperator op) | 
| protected LogicalSchema | StreamTypeCastInserter. determineSchema(LogicalRelationalOperator op) | 
| protected LogicalSchema | LoadTypeCastInserter. determineSchema(LogicalRelationalOperator op)if we are inserting casts in a load and if the loader implements
 determineSchema(), insert casts only where necessary Note that in this
 case, the data coming out of the loader is not a BYTEARRAY but is
 whatever determineSchema() says it is. | 
| protected abstract boolean | TypeCastInserter. isCastAdjusted(LogicalRelationalOperator op) | 
| protected boolean | StreamTypeCastInserter. isCastAdjusted(LogicalRelationalOperator op) | 
| protected boolean | LoadTypeCastInserter. isCastAdjusted(LogicalRelationalOperator op) | 
| protected abstract void | TypeCastInserter. markCastInserted(LogicalRelationalOperator op) | 
| protected void | StreamTypeCastInserter. markCastInserted(LogicalRelationalOperator op) | 
| protected void | LoadTypeCastInserter. markCastInserted(LogicalRelationalOperator op) | 
| protected abstract void | TypeCastInserter. markCastNoNeed(LogicalRelationalOperator op) | 
| protected void | StreamTypeCastInserter. markCastNoNeed(LogicalRelationalOperator op) | 
| protected void | LoadTypeCastInserter. markCastNoNeed(LogicalRelationalOperator op) | 
| Constructor and Description | 
|---|
| ConstantCalculatorExpressionVisitor(OperatorPlan expPlan,
                                   LogicalRelationalOperator currentOp,
                                   PigContext pc) | 
| Constructor and Description | 
|---|
| ConstantCalculatorTransformer(java.util.List<LogicalRelationalOperator> processedOperators,
                             PigContext pc) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ImplicitSplitInsertVisitor. execute(LogicalRelationalOperator op) | 
| protected void | SchemaAliasVisitor. validate(LogicalRelationalOperator op)The logic here is to check if we have duplicate alias in each schema | 
| Constructor and Description | 
|---|
| ResetProjectionAttachedRelationalOpVisitor(LogicalExpressionPlan plan,
                                          LogicalRelationalOperator op) | 
| TypeCheckingExpVisitor(OperatorPlan expPlan,
                      CompilationMessageCollector msgCollector,
                      LogicalRelationalOperator relOp) | 
| Modifier and Type | Method and Description | 
|---|---|
| java.util.Map<LogicalRelationalOperator,java.util.Collection<IdentityHashSet<Tuple>>> | ExampleGenerator. getLoToEqClassMap() | 
| 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) | 
| 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) | 
| Modifier and Type | Method and Description | 
|---|---|
| static float | MetricEvaluation. getCompleteness(Operator op,
               java.util.Map<Operator,DataBag> exampleData,
               java.util.Map<LogicalRelationalOperator,java.util.Collection<IdentityHashSet<Tuple>>> OperatorToEqClasses,
               boolean overallCompleteness) | 
| static float | MetricEvaluation. getConciseness(Operator op,
              java.util.Map<Operator,DataBag> exampleData,
              java.util.Map<LogicalRelationalOperator,java.util.Collection<IdentityHashSet<Tuple>>> OperatorToEqClasses,
              boolean overallConciseness) | 
| static java.lang.String | DisplayExamples. printTabular(LogicalPlan lp,
            java.util.Map<Operator,DataBag> exampleData,
            java.util.Map<LOForEach,java.util.Map<LogicalRelationalOperator,DataBag>> forEachInnerLogToDataMap) | 
Copyright © 2007-2025 The Apache Software Foundation