Class LogicalScriptTransform
- java.lang.Object
-
- org.apache.calcite.rel.AbstractRelNode
-
- org.apache.calcite.rel.SingleRel
-
- org.apache.flink.table.planner.plan.nodes.hive.LogicalScriptTransform
-
- All Implemented Interfaces:
Cloneable
,org.apache.calcite.plan.RelOptNode
,org.apache.calcite.rel.RelNode
public class LogicalScriptTransform extends org.apache.calcite.rel.SingleRel
LogicalScriptTransform is used to represent the sql semantic "TRANSFORM c1, c2, xx USING 'script'".
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.calcite.rel.RelNode
accept(org.apache.calcite.rel.RelShuttle shuttle)
LogicalScriptTransform
copy(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)
static LogicalScriptTransform
create(org.apache.calcite.rel.RelNode input, int[] fieldIndices, String script, ScriptTransformIOInfo scriptTransformIOInfo, org.apache.calcite.rel.type.RelDataType outputRowType)
org.apache.calcite.rel.type.RelDataType
deriveRowType()
org.apache.calcite.rel.RelWriter
explainTerms(org.apache.calcite.rel.RelWriter pw)
int[]
getFieldIndices()
String
getScript()
ScriptTransformIOInfo
getScriptInputOutSchema()
-
Methods inherited from class org.apache.calcite.rel.SingleRel
childrenAccept, estimateRowCount, getInput, getInputs, replaceInput
-
Methods inherited from class org.apache.calcite.rel.AbstractRelNode
accept, collectVariablesSet, collectVariablesUsed, computeSelfCost, deepEquals, deepHashCode, equals, explain, getCluster, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getRelDigest, getRelTypeName, getRowType, getTable, getTraitSet, getVariablesSet, hashCode, isEnforcer, isValid, metadata, onRegister, recomputeDigest, register, sole, toString
-
-
-
-
Method Detail
-
create
public static LogicalScriptTransform create(org.apache.calcite.rel.RelNode input, int[] fieldIndices, String script, ScriptTransformIOInfo scriptTransformIOInfo, org.apache.calcite.rel.type.RelDataType outputRowType)
-
copy
public LogicalScriptTransform copy(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)
- Specified by:
copy
in interfaceorg.apache.calcite.rel.RelNode
- Overrides:
copy
in classorg.apache.calcite.rel.AbstractRelNode
-
accept
public org.apache.calcite.rel.RelNode accept(org.apache.calcite.rel.RelShuttle shuttle)
- Specified by:
accept
in interfaceorg.apache.calcite.rel.RelNode
- Overrides:
accept
in classorg.apache.calcite.rel.AbstractRelNode
-
getScript
public String getScript()
-
getFieldIndices
public int[] getFieldIndices()
-
getScriptInputOutSchema
public ScriptTransformIOInfo getScriptInputOutSchema()
-
deriveRowType
public org.apache.calcite.rel.type.RelDataType deriveRowType()
- Overrides:
deriveRowType
in classorg.apache.calcite.rel.SingleRel
-
explainTerms
public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)
- Overrides:
explainTerms
in classorg.apache.calcite.rel.SingleRel
-
-