public abstract class CommonExecSink extends ExecNodeBase<Object> implements MultipleTransformationTranslator<Object>
ExecNode
to write data to an external sink defined by a DynamicTableSink
.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_DYNAMIC_TABLE_SINK |
protected DynamicTableSinkSpec |
tableSinkSpec |
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Modifier | Constructor and Description |
---|---|
protected |
CommonExecSink(DynamicTableSinkSpec tableSinkSpec,
ChangelogMode changelogMode,
boolean isBounded,
int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected Transformation<Object> |
createSinkTransformation(StreamExecutionEnvironment env,
TableConfig tableConfig,
Transformation<RowData> inputTransform,
int rowtimeFieldIndex,
boolean upsertMaterialize) |
DynamicTableSinkSpec |
getTableSinkSpec() |
accept, getDescription, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan, translateToPlanInternal
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
translateToPlan
public static final String FIELD_NAME_DYNAMIC_TABLE_SINK
protected final DynamicTableSinkSpec tableSinkSpec
protected CommonExecSink(DynamicTableSinkSpec tableSinkSpec, ChangelogMode changelogMode, boolean isBounded, int id, List<InputProperty> inputProperties, LogicalType outputType, String description)
public DynamicTableSinkSpec getTableSinkSpec()
protected Transformation<Object> createSinkTransformation(StreamExecutionEnvironment env, TableConfig tableConfig, Transformation<RowData> inputTransform, int rowtimeFieldIndex, boolean upsertMaterialize)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.