Constructor and Description |
---|
BatchExecSink(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(DynamicTableSinkSpec tableSinkSpec,
ChangelogMode changelogMode,
boolean isBounded,
int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
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) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.