Modifier and Type | Method and Description |
---|---|
ChangelogMode |
DataGenTableSource.getChangelogMode() |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
FileSystemTableSource.getChangelogMode() |
ChangelogMode |
FileSystemTableSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
FileSystemTableSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
KinesisFirehoseDynamicSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
KinesisFirehoseDynamicSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
AbstractHBaseDynamicTableSource.getChangelogMode() |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
HBaseDynamicTableSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
HBaseDynamicTableSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
HBaseDynamicTableSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
HBaseDynamicTableSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
JdbcDynamicTableSource.getChangelogMode() |
ChangelogMode |
JdbcDynamicTableSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
JdbcDynamicTableSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
KinesisDynamicSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
KinesisDynamicSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
HiveTableSource.getChangelogMode() |
ChangelogMode |
HiveTableSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
HiveTableSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
CanalJsonDecodingFormat.getChangelogMode() |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
DebeziumJsonDecodingFormat.getChangelogMode() |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
MaxwellJsonDecodingFormat.getChangelogMode() |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
OggJsonDecodingFormat.getChangelogMode() |
Modifier and Type | Field and Description |
---|---|
static ChangelogMode |
UpsertKafkaDynamicTableFactory.EncodingFormatWrapper.SINK_CHANGELOG_MODE |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
KafkaDynamicSource.getChangelogMode() |
ChangelogMode |
UpsertKafkaDynamicTableFactory.DecodingFormatWrapper.getChangelogMode() |
ChangelogMode |
UpsertKafkaDynamicTableFactory.EncodingFormatWrapper.getChangelogMode() |
ChangelogMode |
KafkaDynamicSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
KafkaDynamicSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
KinesisDynamicSource.getChangelogMode() |
Modifier and Type | Method and Description |
---|---|
protected <T> Table |
AbstractStreamTableEnvironmentImpl.fromStreamInternal(DataStream<T> dataStream,
Schema schema,
String viewPath,
ChangelogMode changelogMode) |
protected <T> DataStream<T> |
AbstractStreamTableEnvironmentImpl.toStreamInternal(Table table,
SchemaTranslator.ProducingResult schemaTranslationResult,
ChangelogMode changelogMode) |
Modifier and Type | Method and Description |
---|---|
Table |
StreamTableEnvironment.fromChangelogStream(DataStream<Row> dataStream,
Schema schema,
ChangelogMode changelogMode)
Converts the given
DataStream of changelog entries into a Table . |
DataStream<Row> |
StreamTableEnvironment.toChangelogStream(Table table,
Schema targetSchema,
ChangelogMode changelogMode)
Converts the given
Table into a DataStream of changelog entries. |
Modifier and Type | Method and Description |
---|---|
Table |
StreamTableEnvironmentImpl.fromChangelogStream(DataStream<Row> dataStream,
Schema schema,
ChangelogMode changelogMode) |
DataStream<Row> |
StreamTableEnvironmentImpl.toChangelogStream(Table table,
Schema targetSchema,
ChangelogMode changelogMode) |
Modifier and Type | Method and Description |
---|---|
static ChangelogMode |
ChangelogMode.all()
Shortcut for a changelog that can contain all
RowKind s. |
ChangelogMode |
ChangelogMode.Builder.build() |
static ChangelogMode |
ChangelogMode.insertOnly()
Shortcut for a simple
RowKind.INSERT -only changelog. |
static ChangelogMode |
ChangelogMode.upsert()
Shortcut for an upsert changelog that describes idempotent updates on a key and thus does not
contain
RowKind.UPDATE_BEFORE rows. |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
Format.getChangelogMode()
Returns the set of changes that a connector (and transitively the planner) can expect during
runtime.
|
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
DynamicTableSink.getChangelogMode(ChangelogMode requestedMode)
Returns the set of changes that the sink accepts during runtime.
|
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
DynamicTableSink.getChangelogMode(ChangelogMode requestedMode)
Returns the set of changes that the sink accepts during runtime.
|
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
ScanTableSource.getChangelogMode()
Returns the set of changes that the planner can expect during runtime.
|
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
ChangelogCsvFormat.getChangelogMode() |
ChangelogMode |
SocketDynamicTableSource.getChangelogMode() |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
ExternalQueryOperation.getChangelogMode() |
Modifier and Type | Method and Description |
---|---|
Optional<ChangelogMode> |
ExternalModifyOperation.getChangelogMode() |
Constructor and Description |
---|
ExternalModifyOperation(ContextResolvedTable contextResolvedTable,
QueryOperation child,
ChangelogMode changelogMode,
DataType physicalDataType) |
ExternalQueryOperation(ContextResolvedTable contextResolvedTable,
DataStream<E> dataStream,
DataType physicalDataType,
boolean isTopLevelRecord,
ChangelogMode changelogMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
CollectDynamicSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSourceUtils.convertDataStreamToRel(boolean isBatchMode,
ReadableConfig config,
FlinkRelBuilder relBuilder,
ContextResolvedTable contextResolvedTable,
DataStream<?> dataStream,
DataType physicalDataType,
boolean isTopLevelRecord,
ChangelogMode changelogMode)
Converts a given
DataStream to a RelNode . |
ChangelogMode |
CollectDynamicSink.getChangelogMode(ChangelogMode requestedMode) |
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,
String description) |
StreamExecSink(ReadableConfig tableConfig,
DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
InputProperty inputProperty,
LogicalType outputType,
boolean upsertMaterialize,
String description) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
ModifyKindSet.toChangelogMode()
Returns the default
ChangelogMode from this ModifyKindSet . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.