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

Packages that use CoreOptions.StartupMode

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

Uses of CoreOptions.StartupMode in org.apache.paimon

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

Modifier and Type	Field and Description
static ConfigOption<CoreOptions.StartupMode>	CoreOptions.SCAN_MODE

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

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

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

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

Constructor and Description

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)