Uses of Class
org.apache.paimon.CoreOptions.LogChangelogMode

Packages that use CoreOptions.LogChangelogMode

Package	Description
org.apache.paimon
org.apache.paimon.flink.kafka

Uses of CoreOptions.LogChangelogMode in org.apache.paimon

Fields in org.apache.paimon with type parameters of type CoreOptions.LogChangelogMode

Modifier and Type	Field and Description
static ConfigOption<CoreOptions.LogChangelogMode>	CoreOptions.LOG_CHANGELOG_MODE

Methods in org.apache.paimon that return CoreOptions.LogChangelogMode

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

Uses of CoreOptions.LogChangelogMode in org.apache.paimon.flink.kafka

Constructors in org.apache.paimon.flink.kafka with parameters of type CoreOptions.LogChangelogMode

Constructor and Description
KafkaLogSerializationSchema(String topic, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> primaryKeySerializer, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> valueSerializer, CoreOptions.LogChangelogMode changelogMode)
KafkaLogSinkProvider(String topic, Properties properties, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> primaryKeySerializer, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> valueSerializer, CoreOptions.LogConsistency consistency, CoreOptions.LogChangelogMode changelogMode)