org.apache.flink.table.planner.plan.nodes.hive

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'".

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.rel.RelNode

org.apache.calcite.rel.RelNode.Context

Field Summary

Fields inherited from class org.apache.calcite.rel.SingleRel

input

Fields inherited from class org.apache.calcite.rel.AbstractRelNode

digest, id, rowType, traitSet

Method Summary

Modifier and Type	Method and 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, org.apache.flink.table.runtime.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()
org.apache.flink.table.runtime.script.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

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.calcite.rel.RelNode

explain, fieldIsNullable

Method Detail

create

public static LogicalScriptTransform create(org.apache.calcite.rel.RelNode input,
                                            int[] fieldIndices,
                                            String script,
                                            org.apache.flink.table.runtime.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 interface org.apache.calcite.rel.RelNode

Overrides:

copy in class org.apache.calcite.rel.AbstractRelNode

accept

public org.apache.calcite.rel.RelNode accept(org.apache.calcite.rel.RelShuttle shuttle)

Specified by:

accept in interface org.apache.calcite.rel.RelNode

Overrides:

accept in class org.apache.calcite.rel.AbstractRelNode

getScript

public String getScript()

getFieldIndices

public int[] getFieldIndices()

getScriptInputOutSchema

public org.apache.flink.table.runtime.script.ScriptTransformIOInfo getScriptInputOutSchema()

deriveRowType

public org.apache.calcite.rel.type.RelDataType deriveRowType()

Overrides:

deriveRowType in class org.apache.calcite.rel.SingleRel

explainTerms

public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)

Overrides:

explainTerms in class org.apache.calcite.rel.SingleRel