org.apache.flink.streaming.connectors.kafka

Class KafkaAvroTableSource

java.lang.Object

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

org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource

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>

Direct Known Subclasses:

Kafka010AvroTableSource, Kafka011AvroTableSource, Kafka08AvroTableSource, Kafka09AvroTableSource

Deprecated.

Use the Kafka descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also TableEnvironment.connect(ConnectorDescriptor).

@Deprecated
 @Internal
public abstract class KafkaAvroTableSource
extends KafkaTableSource

A version-agnostic Kafka Avro StreamTableSource.

The version-specific Kafka consumers need to extend this class and override KafkaTableSource.createKafkaConsumer(String, Properties, DeserializationSchema)}.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	KafkaAvroTableSource.Builder<T extends KafkaAvroTableSource,B extends KafkaAvroTableSource.Builder> Deprecated. Use the Kafka descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also TableEnvironment.connect(ConnectorDescriptor).

Constructor Summary

Constructors

Modifier

Constructor and Description

protected

KafkaAvroTableSource(String topic, Properties properties, org.apache.flink.table.api.TableSchema schema, Class<? extends org.apache.avro.specific.SpecificRecordBase> avroRecordClass) Deprecated. Use the Kafka descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also TableEnvironment.connect(ConnectorDescriptor).

Method Summary

Modifier and Type	Method and Description
String	explainSource() Deprecated.

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

createKafkaConsumer, equals, 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

KafkaAvroTableSource

@Deprecated
protected KafkaAvroTableSource(String topic,
                                           Properties properties,
                                           org.apache.flink.table.api.TableSchema schema,
                                           Class<? extends org.apache.avro.specific.SpecificRecordBase> avroRecordClass)

Deprecated. Use the Kafka descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also TableEnvironment.connect(ConnectorDescriptor).

Creates a generic Kafka Avro StreamTableSource using a given SpecificRecord.

Parameters:

topic - Kafka topic to consume.

properties - Properties for the Kafka consumer.

schema - Schema of the produced table.

avroRecordClass - Class of the Avro record that is read from the Kafka topic.

Method Detail

explainSource

public String explainSource()

Deprecated.

Specified by:

explainSource in interface org.apache.flink.table.sources.TableSource<Row>

Overrides:

explainSource in class KafkaTableSource