Modifier and Type | Method and Description |
---|---|
Map<LOForEach,Map<LogicalRelationalOperator,PhysicalOperator>> |
HExecutionEngine.getForEachInnerLogToPhyMap(LogicalPlan plan) |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
static LOForEach |
Util.addForEachAfter(LogicalPlan plan,
LogicalRelationalOperator op,
int branch,
Set<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,
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.
|
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 |
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 |
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 |
---|
ConstantCalculator.ConstantCalculatorTransformer.ConstantCalculatorExpressionVisitor(OperatorPlan expPlan,
LogicalRelationalOperator currentOp,
PigContext pc) |
Constructor and Description |
---|
ConstantCalculator.ConstantCalculatorTransformer(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 |
---|---|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Copyright © 2007-2012 The Apache Software Foundation