org.apache.flink.streaming.connectors.kafka

Class Kafka08TableSource

java.lang.Object

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

org.apache.flink.streaming.connectors.kafka.Kafka08TableSource

All Implemented Interfaces:

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>

@PublicEvolving
public abstract class Kafka08TableSource
extends KafkaTableSource

Kafka StreamTableSource for Kafka 0.8.

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
Kafka08TableSource(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, org.apache.flink.table.api.TableSchema schema, TypeInformation<Row> typeInfo) Creates a Kafka 0.8 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.
DeserializationSchema<Row>	getDeserializationSchema() Returns the deserialization schema.

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

equals, explainSource, getDataStream, getKafkaConsumer, getProctimeAttribute, getReturnType, getRowtimeAttributeDescriptors, getTableSchema, hashCode, setProctimeAttribute, setRowtimeAttributeDescriptors, setSpecificStartupOffsets, setStartupMode

Methods inherited from class java.lang.Object

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

Constructor Detail

Kafka08TableSource

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

Creates a Kafka 0.8 StreamTableSource.

Parameters:

topic - Kafka topic to consume.

properties - Properties for the Kafka consumer.

deserializationSchema - Deserialization schema to use for Kafka records.

typeInfo - Type information describing the result type. The field names are used to parse the JSON file and so are the types.

Method Detail

getDeserializationSchema

public DeserializationSchema<Row> getDeserializationSchema()

Description copied from class: KafkaTableSource

Returns the deserialization schema.

Specified by:

getDeserializationSchema in class KafkaTableSource

Returns:

The deserialization schema

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