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

Packages that use CoreOptions.LogConsistency

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

Uses of CoreOptions.LogConsistency in org.apache.paimon

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

Modifier and Type	Field and Description
static ConfigOption<CoreOptions.LogConsistency>	CoreOptions.LOG_CONSISTENCY

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

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

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

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

Constructor and Description
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)
KafkaLogSourceProvider(String topic, Properties properties, org.apache.flink.table.types.DataType physicalType, int[] primaryKey, org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData> primaryKeyDeserializer, org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData> valueDeserializer, int[][] projectFields, CoreOptions.LogConsistency consistency, CoreOptions.StartupMode scanMode, Long timestampMills)