T
- The return type of the TableSink
.public class BatchExecLegacySink<T> extends CommonExecLegacySink<T> implements BatchExecNode<T>
isStreaming, needRetraction, tableSink, upsertKeys
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
BatchExecLegacySink(TableSink<T> tableSink,
String[] upsertKeys,
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 BatchExecLegacySink(TableSink<T> tableSink, @Nullable String[] upsertKeys, InputProperty inputProperty, LogicalType outputType, String description)
protected RowType checkAndConvertInputTypeIfNeeded(RowType inputRowType)
CommonExecLegacySink
checkAndConvertInputTypeIfNeeded
in class CommonExecLegacySink<T>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.