Uses of Class
org.apache.flink.streaming.connectors.kafka.config.StartupMode

Packages that use StartupMode

Package	Description
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.config
org.apache.flink.streaming.connectors.kafka.table
org.apache.flink.table.descriptors

Uses of StartupMode in org.apache.flink.streaming.connectors.kafka

Methods in org.apache.flink.streaming.connectors.kafka with parameters of type StartupMode

Modifier and Type	Method and Description
protected KafkaTableSourceBase	KafkaTableSourceSinkFactory.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis)
protected KafkaTableSourceBase	Kafka011TableSourceSinkFactory.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis)
protected KafkaTableSourceBase	Kafka010TableSourceSinkFactory.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis)
protected abstract KafkaTableSourceBase	KafkaTableSourceSinkFactoryBase.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Constructs the version-specific Kafka table source.

Constructors in org.apache.flink.streaming.connectors.kafka with parameters of type StartupMode

Constructor and Description
Kafka010TableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Creates a Kafka 0.10 StreamTableSource.
Kafka011TableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Creates a Kafka 0.11 StreamTableSource.
KafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Creates a generic Kafka StreamTableSource.
KafkaTableSourceBase(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Creates a generic Kafka StreamTableSource.

Uses of StartupMode in org.apache.flink.streaming.connectors.kafka.config

Methods in org.apache.flink.streaming.connectors.kafka.config that return StartupMode

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

Uses of StartupMode in org.apache.flink.streaming.connectors.kafka.table

Fields in org.apache.flink.streaming.connectors.kafka.table declared as StartupMode

Modifier and Type	Field and Description
protected StartupMode	KafkaDynamicSourceBase.startupMode The startup mode for the contained consumer (default is GROUP_OFFSETS).
StartupMode	KafkaOptions.StartupOptions.startupMode

Methods in org.apache.flink.streaming.connectors.kafka.table with parameters of type StartupMode

Modifier and Type	Method and Description
protected KafkaDynamicSourceBase	KafkaDynamicTableFactory.createKafkaTableSource(DataType producedDataType, String topic, Properties properties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis)
protected KafkaDynamicSourceBase	Kafka011DynamicTableFactory.createKafkaTableSource(DataType producedDataType, String topic, Properties properties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis)
protected KafkaDynamicSourceBase	Kafka010DynamicTableFactory.createKafkaTableSource(DataType producedDataType, String topic, Properties properties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis)
protected abstract KafkaDynamicSourceBase	KafkaDynamicTableFactoryBase.createKafkaTableSource(DataType producedDataType, String topic, Properties properties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Constructs the version-specific Kafka table source.

Constructors in org.apache.flink.streaming.connectors.kafka.table with parameters of type StartupMode

Constructor and Description
Kafka010DynamicSource(DataType outputDataType, String topic, Properties properties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Creates a Kafka 0.10 StreamTableSource.
Kafka011DynamicSource(DataType outputDataType, String topic, Properties properties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Creates a Kafka 0.11 ScanTableSource.
KafkaDynamicSource(DataType outputDataType, String topic, Properties properties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Creates a generic Kafka StreamTableSource.
KafkaDynamicSourceBase(DataType outputDataType, String topic, Properties properties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Creates a generic Kafka StreamTableSource.

Uses of StartupMode in org.apache.flink.table.descriptors

Methods in org.apache.flink.table.descriptors with parameters of type StartupMode

Modifier and Type	Method and Description
static String	KafkaValidator.normalizeStartupMode(StartupMode startupMode)