|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of LogicalRelationalOperator in org.apache.pig.backend.hadoop.executionengine |
|---|
| Methods in org.apache.pig.backend.hadoop.executionengine that return types with arguments of type LogicalRelationalOperator | |
|---|---|
Map<LOForEach,Map<LogicalRelationalOperator,PhysicalOperator>> |
HExecutionEngine.getForEachInnerLogToPhyMap(LogicalPlan plan)
|
| Uses of LogicalRelationalOperator in org.apache.pig.newplan.logical |
|---|
| Methods in org.apache.pig.newplan.logical with type parameters of type LogicalRelationalOperator | ||
|---|---|---|
static
|
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. |
|
| Methods in org.apache.pig.newplan.logical with parameters of type LogicalRelationalOperator | |
|---|---|
static LOForEach |
Util.addForEachAfter(LogicalPlan plan,
LogicalRelationalOperator op,
int branch,
Set<Integer> columnsToDrop)
|
| Uses of LogicalRelationalOperator in org.apache.pig.newplan.logical.expression |
|---|
| Fields in org.apache.pig.newplan.logical.expression declared as LogicalRelationalOperator | |
|---|---|
protected LogicalRelationalOperator |
ExpToPhyTranslationVisitor.currentOp
|
| Methods in org.apache.pig.newplan.logical.expression that return LogicalRelationalOperator | |
|---|---|
LogicalRelationalOperator |
ProjectExpression.findReferent()
Find the LogicalRelationalOperator that this projection refers to. |
LogicalRelationalOperator |
ProjectExpression.getAttachedRelationalOp()
|
| Methods in org.apache.pig.newplan.logical.expression with parameters of type LogicalRelationalOperator | |
|---|---|
void |
ProjectExpression.setAttachedRelationalOp(LogicalRelationalOperator attachedRelationalOp)
|
| Constructors in org.apache.pig.newplan.logical.expression with parameters of type LogicalRelationalOperator | |
|---|---|
ExpToPhyTranslationVisitor(OperatorPlan plan,
LogicalRelationalOperator op,
PhysicalPlan phyPlan,
Map<Operator,PhysicalOperator> map)
|
|
ExpToPhyTranslationVisitor(OperatorPlan plan,
PlanWalker walker,
LogicalRelationalOperator op,
PhysicalPlan phyPlan,
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,
String alias,
Operator projectedOp,
LogicalRelationalOperator attachedRelationalOp)
Adds projection to the plan. |
|
| Uses of LogicalRelationalOperator in org.apache.pig.newplan.logical.optimizer |
|---|
| Fields in org.apache.pig.newplan.logical.optimizer declared as LogicalRelationalOperator | |
|---|---|
protected LogicalRelationalOperator |
AllExpressionVisitor.currentOp
|
| Methods in org.apache.pig.newplan.logical.optimizer with parameters of type LogicalRelationalOperator | |
|---|---|
protected abstract void |
AllSameRalationalNodesVisitor.execute(LogicalRelationalOperator op)
Method to call on every node in the logical plan. |
| Uses of LogicalRelationalOperator in org.apache.pig.newplan.logical.relational |
|---|
| Subclasses of LogicalRelationalOperator in org.apache.pig.newplan.logical.relational | |
|---|---|
class |
LOCogroup
|
class |
LOCross
|
class |
LOCube
CUBE operator implementation for data cube computation. |
class |
LODistinct
|
class |
LOFilter
|
class |
LOForEach
|
class |
LOGenerate
|
class |
LOInnerLoad
Operator 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 |
LORank
RANK operator implementation. |
class |
LOSort
|
class |
LOSplit
|
class |
LOSplitOutput
|
class |
LOStore
|
class |
LOStream
|
class |
LOUnion
|
| Methods in org.apache.pig.newplan.logical.relational with parameters of type LogicalRelationalOperator | |
|---|---|
protected boolean |
LogicalRelationalOperator.checkEquality(LogicalRelationalOperator other)
Do some basic equality checks on two relational operators. |
| Uses of LogicalRelationalOperator in org.apache.pig.newplan.logical.rules |
|---|
| Methods in org.apache.pig.newplan.logical.rules with parameters of type LogicalRelationalOperator | |
|---|---|
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)
|
| Uses of LogicalRelationalOperator in org.apache.pig.newplan.logical.visitor |
|---|
| Methods in org.apache.pig.newplan.logical.visitor with parameters of type LogicalRelationalOperator | |
|---|---|
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 |
| Constructors in org.apache.pig.newplan.logical.visitor with parameters of type LogicalRelationalOperator | |
|---|---|
ResetProjectionAttachedRelationalOpVisitor(LogicalExpressionPlan plan,
LogicalRelationalOperator op)
|
|
TypeCheckingExpVisitor(OperatorPlan expPlan,
CompilationMessageCollector msgCollector,
LogicalRelationalOperator relOp)
|
|
| Uses of LogicalRelationalOperator in org.apache.pig.pen |
|---|
| Methods in org.apache.pig.pen that return types with arguments of type LogicalRelationalOperator | |
|---|---|
Map<LogicalRelationalOperator,Collection<IdentityHashSet<Tuple>>> |
ExampleGenerator.getLoToEqClassMap()
|
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)
|
| Method parameters in org.apache.pig.pen with type arguments of type LogicalRelationalOperator | |
|---|---|
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)
|
| Uses of LogicalRelationalOperator in org.apache.pig.pen.util |
|---|
| Method parameters in org.apache.pig.pen.util with type arguments of type LogicalRelationalOperator | |
|---|---|
static float |
MetricEvaluation.getCompleteness(Operator op,
Map<Operator,DataBag> exampleData,
Map<LogicalRelationalOperator,Collection<IdentityHashSet<Tuple>>> OperatorToEqClasses,
boolean overallCompleteness)
|
static float |
MetricEvaluation.getConciseness(Operator op,
Map<Operator,DataBag> exampleData,
Map<LogicalRelationalOperator,Collection<IdentityHashSet<Tuple>>> OperatorToEqClasses,
boolean overallConciseness)
|
static String |
DisplayExamples.printTabular(LogicalPlan lp,
Map<Operator,DataBag> exampleData,
Map<LOForEach,Map<LogicalRelationalOperator,DataBag>> forEachInnerLogToDataMap)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||