T
- The return type of the TableSink
.public class StreamExecLegacySink<T> extends CommonExecLegacySink<T> implements StreamExecNode<Object>
isStreaming, needRetraction, tableSink, upsertKeys
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecLegacySink(TableSink<T> tableSink,
String[] upsertKeys,
boolean needRetraction,
InputProperty inputProperty,
LogicalType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected RowType |
checkAndConvertInputTypeIfNeeded(RowType inputRowType)
Check whether the given row type is legal and do some conversion if needed.
|
translateToPlanInternal
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 StreamExecLegacySink(TableSink<T> tableSink, @Nullable String[] upsertKeys, boolean needRetraction, InputProperty inputProperty, LogicalType outputType, String description)
protected RowType checkAndConvertInputTypeIfNeeded(RowType inputRowType)
CommonExecLegacySink
checkAndConvertInputTypeIfNeeded
in class CommonExecLegacySink<T>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.