public class DataSetSort extends org.apache.calcite.rel.SingleRel implements DataSetRel
Constructor and Description |
---|
DataSetSort(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode inp,
org.apache.calcite.rel.RelCollation collations,
org.apache.calcite.rel.type.RelDataType rowRelDataType,
org.apache.calcite.rex.RexNode offset,
org.apache.calcite.rex.RexNode fetch) |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rel.RelNode |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
List<org.apache.calcite.rel.RelNode> inputs) |
org.apache.calcite.rel.type.RelDataType |
deriveRowType() |
double |
estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery metadata) |
org.apache.calcite.rel.RelWriter |
explainTerms(org.apache.calcite.rel.RelWriter pw) |
String |
toString() |
DataSet<Object> |
translateToPlan(BatchTableEnvironment tableEnv,
scala.Option<TypeInformation<Object>> expectedType)
Translates the
DataSetRel node into a DataSet operator. |
childrenAccept, getInput, getInputs, replaceInput
accept, accept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, computeSelfCost, explain, getChildExps, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, sole
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, computeSelfCost, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput
getCluster, getDescription, getDigest, getId, getTraitSet
estimateDataTypeSize, estimateRowSize, getConversionMapper, getExpressionString
public DataSetSort(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode inp, org.apache.calcite.rel.RelCollation collations, org.apache.calcite.rel.type.RelDataType rowRelDataType, org.apache.calcite.rex.RexNode offset, org.apache.calcite.rex.RexNode fetch)
public org.apache.calcite.rel.type.RelDataType deriveRowType()
deriveRowType
in class org.apache.calcite.rel.SingleRel
public org.apache.calcite.rel.RelNode copy(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)
copy
in interface org.apache.calcite.rel.RelNode
copy
in class org.apache.calcite.rel.AbstractRelNode
public double estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery metadata)
estimateRowCount
in interface org.apache.calcite.rel.RelNode
estimateRowCount
in class org.apache.calcite.rel.SingleRel
public DataSet<Object> translateToPlan(BatchTableEnvironment tableEnv, scala.Option<TypeInformation<Object>> expectedType)
DataSetRel
DataSetRel
node into a DataSet
operator.
translateToPlan
in interface DataSetRel
tableEnv
- BatchTableEnvironment
of the translated Table.expectedType
- specifies the type the Flink operator should return. The type must
have the same arity as the result. For instance, if the
expected type is a RowTypeInfo this method will return a DataSet of
type Row. If the expected type is Tuple2, the operator will return
a Tuple2 if possible. Row otherwise.public String toString()
toString
in class org.apache.calcite.rel.AbstractRelNode
public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)
explainTerms
in class org.apache.calcite.rel.SingleRel
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.