Uses of Class
org.apache.flink.cdc.debezium.table.DebeziumChangelogMode

Packages that use DebeziumChangelogMode

Package	Description
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.source.config
org.apache.flink.cdc.connectors.postgres.table
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.debezium.event
org.apache.flink.cdc.debezium.table

Uses of DebeziumChangelogMode in org.apache.flink.cdc.connectors.mysql.source

Constructors in org.apache.flink.cdc.connectors.mysql.source with parameters of type DebeziumChangelogMode

Constructor	Description
MySqlEventDeserializer(DebeziumChangelogMode changelogMode, boolean includeSchemaChanges, boolean tinyInt1isBit, boolean isTableIdCaseInsensitive)
MySqlEventDeserializer(DebeziumChangelogMode changelogMode, boolean includeSchemaChanges, List<MySqlReadableMetadata> readableMetadataList, boolean includeComments, boolean tinyInt1isBit, boolean isTableIdCaseInsensitive)

Uses of DebeziumChangelogMode in org.apache.flink.cdc.connectors.oracle.source

Constructors in org.apache.flink.cdc.connectors.oracle.source with parameters of type DebeziumChangelogMode

Constructor	Description
OracleEventDeserializer(DebeziumChangelogMode changelogMode, boolean includeSchemaChanges, List<OracleReadableMetaData> readableMetadataList)

Uses of DebeziumChangelogMode in org.apache.flink.cdc.connectors.postgres.source

Constructors in org.apache.flink.cdc.connectors.postgres.source with parameters of type DebeziumChangelogMode

Constructor	Description
PostgresEventDeserializer(DebeziumChangelogMode changelogMode)
PostgresEventDeserializer(DebeziumChangelogMode changelogMode, List<PostgreSQLReadableMetadata> readableMetadataList)
PostgresEventDeserializer(DebeziumChangelogMode changelogMode, List<PostgreSQLReadableMetadata> readableMetadataList, boolean includeDatabaseInTableId)
PostgresEventDeserializer(DebeziumChangelogMode changelogMode, List<PostgreSQLReadableMetadata> readableMetadataList, boolean includeDatabaseInTableId, String databaseName)

Uses of DebeziumChangelogMode in org.apache.flink.cdc.connectors.postgres.source.config

Fields in org.apache.flink.cdc.connectors.postgres.source.config with type parameters of type DebeziumChangelogMode

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<DebeziumChangelogMode>	PostgresSourceOptions.CHANGELOG_MODE

Uses of DebeziumChangelogMode in org.apache.flink.cdc.connectors.postgres.table

Constructors in org.apache.flink.cdc.connectors.postgres.table with parameters of type DebeziumChangelogMode

Constructor

Description

PostgreSQLTableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema, int port, String hostname, String database, String schemaName, String tableName, String username, String password, String pluginName, String slotName, DebeziumChangelogMode changelogMode, Properties dbzProperties, boolean enableParallelRead, int splitSize, int splitMetaGroupSize, int fetchSize, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, double distributionFactorUpper, double distributionFactorLower, java.time.Duration heartbeatInterval, StartupOptions startupOptions, String chunkKeyColumn, boolean closeIdleReaders, boolean skipSnapshotBackfill, boolean isScanNewlyAddedTableEnabled, int lsnCommitCheckpointsDelay, boolean assignUnboundedChunkFirst, boolean appendOnly, boolean includePartitionedTables, boolean releaseSnapshotMetadataEnabled)

Uses of DebeziumChangelogMode in org.apache.flink.cdc.connectors.sqlserver.source

Constructors in org.apache.flink.cdc.connectors.sqlserver.source with parameters of type DebeziumChangelogMode

Constructor	Description
SqlServerEventDeserializer(DebeziumChangelogMode changelogMode, boolean includeSchemaChanges)
SqlServerEventDeserializer(DebeziumChangelogMode changelogMode, boolean includeSchemaChanges, List<SqlServerReadableMetadata> readableMetadataList)

Uses of DebeziumChangelogMode in org.apache.flink.cdc.debezium.event

Fields in org.apache.flink.cdc.debezium.event declared as DebeziumChangelogMode

Modifier and Type	Field	Description
protected DebeziumChangelogMode	DebeziumEventDeserializationSchema.changelogMode	Changelog Mode to use for encoding changes in Flink internal data structure.

Constructors in org.apache.flink.cdc.debezium.event with parameters of type DebeziumChangelogMode

Constructor	Description
DebeziumEventDeserializationSchema(SchemaDataTypeInference schemaDataTypeInference, DebeziumChangelogMode changelogMode)

Uses of DebeziumChangelogMode in org.apache.flink.cdc.debezium.table

Methods in org.apache.flink.cdc.debezium.table that return DebeziumChangelogMode

Modifier and Type	Method	Description
static DebeziumChangelogMode	DebeziumChangelogMode.valueOf(String name)	Returns the enum constant of this type with the specified name.
static DebeziumChangelogMode[]	DebeziumChangelogMode.values()	Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.apache.flink.cdc.debezium.table with parameters of type DebeziumChangelogMode

Modifier and Type	Method	Description
RowDataDebeziumDeserializeSchema.Builder	RowDataDebeziumDeserializeSchema.Builder.setChangelogMode(DebeziumChangelogMode changelogMode)