private java.lang.String |
PigTableScan.getConcatenatedFieldNameAndTypeForPigSchema(PigRel.Implementor implementor,
RelDataTypeField field) |
|
private java.util.List<java.lang.String> |
PigAggregate.getDistinctCalls(PigRel.Implementor implementor) |
A agg function call like COUNT(DISTINCT COL) in Pig is
achieved via two statements in a FOREACH that follows a GROUP statement:
TABLE = GROUP TABLE ALL;
TABLE = FOREACH TABLE {
COL.DISTINCT = DISTINCT COL;
GENERATE COUNT(COL.DISTINCT) AS C;
}
|
private java.util.List<java.lang.String> |
PigAggregate.getPigAggregateCalls(PigRel.Implementor implementor) |
|
private java.lang.String |
PigAggregate.getPigAggregateStatement(PigRel.Implementor implementor) |
Generates a GROUP BY statement, followed by an optional FOREACH statement
for all aggregate functions used.
|
private java.lang.String |
PigFilter.getPigFilterStatement(PigRel.Implementor implementor) |
Generates Pig Latin filtering statements, for example
|
private java.lang.String |
PigAggregate.getPigForEachGenerate(PigRel.Implementor implementor) |
Generates a FOREACH statement containing invocation of aggregate functions
and projection of grouped fields.
|
private java.lang.String |
PigAggregate.getPigGenerateCall(PigRel.Implementor implementor) |
|
private java.lang.String |
PigAggregate.getPigGroupBy(PigRel.Implementor implementor) |
Generates the GROUP BY statement, e.g.
|
private java.lang.String |
PigJoin.getPigJoinStatement(PigRel.Implementor implementor) |
Constructs a Pig JOIN statement in the form of
|
private java.lang.String |
PigTableScan.getSchemaForPigStatement(PigRel.Implementor implementor) |
|
private java.lang.String |
PigFilter.getSingleFilterCondition(PigRel.Implementor implementor,
java.lang.String op,
RexCall call) |
|
private java.lang.String |
PigFilter.getSingleFilterCondition(PigRel.Implementor implementor,
RexNode node) |
|
void |
PigAggregate.implement(PigRel.Implementor implementor) |
|
void |
PigFilter.implement(PigRel.Implementor implementor) |
|
void |
PigJoin.implement(PigRel.Implementor implementor) |
|
void |
PigProject.implement(PigRel.Implementor implementor) |
|
void |
PigRel.implement(PigRel.Implementor implementor) |
Converts this node to a Pig Latin statement.
|
void |
PigTableScan.implement(PigRel.Implementor implementor) |
|