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 |
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 | 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() |
ChangelogMode |
KinesisDynamicSink.getChangelogMode(ChangelogMode requestedMode) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
KinesisDynamicSink.getChangelogMode(ChangelogMode requestedMode) |
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 |
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 |
ScalaExternalQueryOperation.getChangelogMode() |
ChangelogMode |
JavaExternalQueryOperation.getChangelogMode() |
Modifier and Type | Method and Description |
---|---|
Optional<ChangelogMode> |
ExternalModifyOperation.getChangelogMode() |
Constructor and Description |
---|
ExternalModifyOperation(ObjectIdentifier tableIdentifier,
QueryOperation child,
ResolvedSchema resolvedSchema,
ChangelogMode changelogMode,
DataType physicalDataType) |
JavaExternalQueryOperation(ObjectIdentifier identifier,
DataStream<E> dataStream,
DataType physicalDataType,
boolean isTopLevelRecord,
ChangelogMode changelogMode,
ResolvedSchema resolvedSchema) |
ScalaExternalQueryOperation(ObjectIdentifier identifier,
DataStream<E> dataStream,
DataType physicalDataType,
boolean isTopLevelRecord,
ChangelogMode changelogMode,
ResolvedSchema resolvedSchema) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSourceUtils.convertDataStreamToRel(boolean isStreamingMode,
ReadableConfig config,
org.apache.flink.table.planner.calcite.FlinkRelBuilder relBuilder,
ObjectIdentifier identifier,
ResolvedSchema schema,
DataStream<?> dataStream,
DataType physicalDataType,
boolean isTopLevelRecord,
ChangelogMode changelogMode)
Converts a given
DataStream to a RelNode . |
Constructor and Description |
---|
CommonExecSink(DynamicTableSinkSpec tableSinkSpec,
ChangelogMode changelogMode,
boolean isBounded,
int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
ChangelogModeJsonDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser jsonParser,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext deserializationContext) |
Modifier and Type | Method and Description |
---|---|
void |
ChangelogModeJsonSerializer.serialize(ChangelogMode changelogMode,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator jsonGenerator,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider serializerProvider) |
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 |
---|---|
ChangelogMode |
ModifyKindSet.toChangelogMode()
Returns the default
ChangelogMode from this ModifyKindSet . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.