Constructor and Description |
---|
BatchExecSink(ReadableConfig tableConfig,
DynamicTableSinkSpec tableSinkSpec,
InputProperty inputProperty,
LogicalType outputType,
String description) |
Modifier and Type | Field and Description |
---|---|
protected DynamicTableSinkSpec |
CommonExecSink.tableSinkSpec |
Modifier and Type | Method and Description |
---|---|
DynamicTableSinkSpec |
CommonExecSink.getTableSinkSpec() |
Constructor and Description |
---|
CommonExecSink(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
boolean isBounded,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
Constructor and Description |
---|
StreamExecSink(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
List<InputProperty> inputProperties,
LogicalType outputType,
boolean upsertMaterialize,
int[] inputUpsertKey,
String description) |
StreamExecSink(ReadableConfig tableConfig,
DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
InputProperty inputProperty,
LogicalType outputType,
boolean upsertMaterialize,
int[] inputUpsertKey,
String description) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.