public class StreamExecSink extends CommonExecSink implements StreamExecNode<Object>
ExecNode
to to write data into an external sink defined by a DynamicTableSink
.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_INPUT_CHANGELOG_MODE |
static String |
FIELD_NAME_REQUIRE_UPSERT_MATERIALIZE |
FIELD_NAME_DYNAMIC_TABLE_SINK, tableSinkSpec
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecSink(DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
InputProperty inputProperty,
LogicalType outputType,
boolean upsertMaterialize,
String description) |
StreamExecSink(DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
int id,
List<InputProperty> inputProperties,
LogicalType outputType,
boolean upsertMaterialize,
String description) |
Modifier and Type | Method and Description |
---|---|
protected Transformation<Object> |
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
Internal method, translates this node into a Flink operator.
|
createSinkTransformation, getTableSinkSpec
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 static final String FIELD_NAME_INPUT_CHANGELOG_MODE
public static final String FIELD_NAME_REQUIRE_UPSERT_MATERIALIZE
public StreamExecSink(DynamicTableSinkSpec tableSinkSpec, ChangelogMode inputChangelogMode, InputProperty inputProperty, LogicalType outputType, boolean upsertMaterialize, String description)
public StreamExecSink(DynamicTableSinkSpec tableSinkSpec, ChangelogMode inputChangelogMode, int id, List<InputProperty> inputProperties, LogicalType outputType, boolean upsertMaterialize, String description)
protected Transformation<Object> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
ExecNodeBase
translateToPlanInternal
in class ExecNodeBase<Object>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.