org.apache.flink.streaming.connectors.kafka

Class Kafka09TableSource

java.lang.Object

org.apache.flink.streaming.connectors.kafka.KafkaTableSource

org.apache.flink.streaming.connectors.kafka.Kafka09TableSource

All Implemented Interfaces:

org.apache.flink.table.sources.DefinedFieldMapping, org.apache.flink.table.sources.DefinedProctimeAttribute, org.apache.flink.table.sources.DefinedRowtimeAttributes, org.apache.flink.table.sources.StreamTableSource<Row>, org.apache.flink.table.sources.TableSource<Row>

@Internal
public class Kafka09TableSource
extends KafkaTableSource

Kafka StreamTableSource for Kafka 0.9.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource

KafkaTableSource.Builder<T extends KafkaTableSource,B extends KafkaTableSource.Builder>

Constructor Summary

Constructors

Constructor and Description
Kafka09TableSource(org.apache.flink.table.api.TableSchema schema, Optional<String> proctimeAttribute, List<org.apache.flink.table.sources.RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets) Creates a Kafka 0.9 StreamTableSource.
Kafka09TableSource(org.apache.flink.table.api.TableSchema schema, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Creates a Kafka 0.9 StreamTableSource.

Method Summary

Modifier and Type	Method and Description
protected FlinkKafkaConsumerBase<Row>	createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Creates a version-specific Kafka consumer.

Methods inherited from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource

equals, explainSource, getDataStream, getDeserializationSchema, getFieldMapping, getKafkaConsumer, getProctimeAttribute, getProperties, getReturnType, getRowtimeAttributeDescriptors, getTableSchema, hashCode, setFieldMapping, setProctimeAttribute, setRowtimeAttributeDescriptors, setSpecificStartupOffsets, setStartupMode

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Kafka09TableSource

public Kafka09TableSource(org.apache.flink.table.api.TableSchema schema,
                          Optional<String> proctimeAttribute,
                          List<org.apache.flink.table.sources.RowtimeAttributeDescriptor> rowtimeAttributeDescriptors,
                          Optional<Map<String,String>> fieldMapping,
                          String topic,
                          Properties properties,
                          DeserializationSchema<Row> deserializationSchema,
                          StartupMode startupMode,
                          Map<KafkaTopicPartition,Long> specificStartupOffsets)

Creates a Kafka 0.9 StreamTableSource.

Parameters:

schema - Schema of the produced table.

proctimeAttribute - Field name of the processing time attribute.

rowtimeAttributeDescriptors - Descriptor for a rowtime attribute

fieldMapping - Mapping for the fields of the table schema to fields of the physical returned type.

topic - Kafka topic to consume.

properties - Properties for the Kafka consumer.

deserializationSchema - Deserialization schema for decoding records from Kafka.

startupMode - Startup mode for the contained consumer.

specificStartupOffsets - Specific startup offsets; only relevant when startup mode is StartupMode.SPECIFIC_OFFSETS.

Kafka09TableSource

public Kafka09TableSource(org.apache.flink.table.api.TableSchema schema,
                          String topic,
                          Properties properties,
                          DeserializationSchema<Row> deserializationSchema)

Creates a Kafka 0.9 StreamTableSource.

Parameters:

schema - Schema of the produced table.

topic - Kafka topic to consume.

properties - Properties for the Kafka consumer.

deserializationSchema - Deserialization schema for decoding records from Kafka.

Method Detail

createKafkaConsumer

protected FlinkKafkaConsumerBase<Row> createKafkaConsumer(String topic,
                                                          Properties properties,
                                                          DeserializationSchema<Row> deserializationSchema)

Description copied from class: KafkaTableSource

Creates a version-specific Kafka consumer.

Specified by:

createKafkaConsumer in class KafkaTableSource

Parameters:

topic - Kafka topic to consume.

properties - Properties for the Kafka consumer.

deserializationSchema - Deserialization schema to use for Kafka records.

Returns:

The version-specific Kafka consumer