public class BatchExecCorrelate extends CommonExecCorrelate implements BatchExecNode<RowData>
CORRELATE_TRANSFORMATION, FIELD_NAME_CONDITION, FIELD_NAME_FUNCTION_CALL, FIELD_NAME_JOIN_TYPE
FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_STATE, FIELD_NAME_TYPE
Constructor and Description |
---|
BatchExecCorrelate(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
translateToPlanInternal
accept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, getTransformation, inputsContainSingleton, replaceInputEdge, setCompiled, setInputEdges, supportFusionCodegen, translateToFusionCodegenSpec, translateToFusionCodegenSpecInternal, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setCompiled, setInputEdges
translateToPlan
supportFusionCodegen, translateToFusionCodegenSpec
public BatchExecCorrelate(ReadableConfig tableConfig, FlinkJoinType joinType, org.apache.calcite.rex.RexCall invocation, @Nullable org.apache.calcite.rex.RexNode condition, InputProperty inputProperty, RowType outputType, String description)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.