Package org.apache.calcite.adapter.pig
Class PigTableScan
- java.lang.Object
-
- org.apache.calcite.rel.AbstractRelNode
-
- org.apache.calcite.rel.core.TableScan
-
- org.apache.calcite.adapter.pig.PigTableScan
-
- All Implemented Interfaces:
java.lang.Cloneable
,PigRel
,RelOptNode
,RelNode
public class PigTableScan extends TableScan implements PigRel
Implementation ofTableScan
inPig calling convention
.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.calcite.adapter.pig.PigRel
PigRel.Implementor
-
Nested classes/interfaces inherited from interface org.apache.calcite.rel.RelNode
RelNode.Context
-
-
Field Summary
-
Fields inherited from class org.apache.calcite.rel.AbstractRelNode
digest, id, rowType, traitSet
-
Fields inherited from interface org.apache.calcite.adapter.pig.PigRel
CONVENTION
-
-
Constructor Summary
Constructors Constructor Description PigTableScan(RelOptCluster cluster, RelTraitSet traitSet, RelOptTable table)
Creates a PigTableScan.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private java.lang.String
getConcatenatedFieldNameAndTypeForPigSchema(PigRel.Implementor implementor, RelDataTypeField field)
private PigTable
getPigTable(java.lang.String name)
private java.lang.String
getSchemaForPigStatement(PigRel.Implementor implementor)
void
implement(PigRel.Implementor implementor)
Converts this node to a Pig Latin statement.void
register(RelOptPlanner planner)
Registers any special rules specific to this kind of relational expression.-
Methods inherited from class org.apache.calcite.rel.core.TableScan
accept, computeSelfCost, deriveRowType, estimateRowCount, explainTerms, getCollationList, getTable, identity, identity, project
-
Methods inherited from class org.apache.calcite.rel.AbstractRelNode
accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, copy, explain, getChildExps, getCluster, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, replaceInput, sole, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.calcite.rel.RelNode
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, computeSelfCost, copy, estimateRowCount, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, replaceInput
-
Methods inherited from interface org.apache.calcite.plan.RelOptNode
getCluster, getDescription, getDigest, getId, getTraitSet
-
-
-
-
Constructor Detail
-
PigTableScan
public PigTableScan(RelOptCluster cluster, RelTraitSet traitSet, RelOptTable table)
Creates a PigTableScan.
-
-
Method Detail
-
implement
public void implement(PigRel.Implementor implementor)
Description copied from interface:PigRel
Converts this node to a Pig Latin statement.
-
getPigTable
private PigTable getPigTable(java.lang.String name)
-
getSchemaForPigStatement
private java.lang.String getSchemaForPigStatement(PigRel.Implementor implementor)
-
getConcatenatedFieldNameAndTypeForPigSchema
private java.lang.String getConcatenatedFieldNameAndTypeForPigSchema(PigRel.Implementor implementor, RelDataTypeField field)
-
register
public void register(RelOptPlanner planner)
Description copied from interface:RelNode
Registers any special rules specific to this kind of relational expression.The planner calls this method this first time that it sees a relational expression of this class. The derived class should call
RelOptPlanner.addRule(org.apache.calcite.plan.RelOptRule)
for each rule, and then callsuper.register
.- Specified by:
register
in interfaceRelNode
- Overrides:
register
in classAbstractRelNode
- Parameters:
planner
- Planner to be used to register additional relational expressions
-
-