public class StreamExecDropUpdateBefore extends ExecNodeBase<RowData> implements StreamExecNode<RowData>, SingleTransformationTranslator<RowData>
ExecNode
which will drop the UPDATE_BEFORE messages. This is usually used as an
optimization for the downstream operators that doesn't need the UPDATE_BEFORE messages, but the
upstream operator can't drop it by itself (e.g. the source).FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecDropUpdateBefore(InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecDropUpdateBefore(int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected Transformation<RowData> |
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
Internal method, translates this node into a Flink operator.
|
accept, getDescription, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdges
translateToPlan
public StreamExecDropUpdateBefore(InputProperty inputProperty, RowType outputType, String description)
public StreamExecDropUpdateBefore(int id, List<InputProperty> inputProperties, RowType outputType, String description)
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
ExecNodeBase
translateToPlanInternal
in class ExecNodeBase<RowData>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.