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 |
DebeziumJsonDecodingFormat.getChangelogMode() |
Modifier and Type | Field and Description |
---|---|
static ChangelogMode |
UpsertKafkaDynamicTableFactory.EncodingFormatWrapper.SINK_CHANGELOG_MODE |
Modifier and Type | Method and Description |
---|---|
ChangelogMode |
UpsertKafkaDynamicTableFactory.DecodingFormatWrapper.getChangelogMode() |
ChangelogMode |
UpsertKafkaDynamicTableFactory.EncodingFormatWrapper.getChangelogMode() |
ChangelogMode |
KafkaDynamicSource.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 |
---|---|
ChangelogMode |
ChangelogMode.Builder.build() |
static ChangelogMode |
ChangelogMode.insertOnly()
Shortcut for a simple
RowKind.INSERT -only changelog. |
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 |
SocketDynamicTableSource.getChangelogMode() |
ChangelogMode |
ChangelogCsvFormat.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 |
ModifyKindSet.toChangelogMode()
Returns the default
ChangelogMode from this ModifyKindSet . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.