org.apache.flink.streaming.connectors.kafka

Class Kafka011AvroTableSource

java.lang.Object

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

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

org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSource

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>

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
public class Kafka011AvroTableSource
extends KafkaAvroTableSource

Kafka StreamTableSource for Kafka 0.11.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Kafka011AvroTableSource.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

Constructor and Description
Kafka011AvroTableSource(String topic, Properties properties, org.apache.flink.table.api.TableSchema schema, Class<? extends org.apache.avro.specific.SpecificRecordBase> record) Deprecated. Use table descriptors instead of implementation-specific builders.

Method Summary

Modifier and Type	Method and Description
static Kafka011AvroTableSource.Builder	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).
protected FlinkKafkaConsumerBase<Row>	createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Deprecated. Creates a version-specific Kafka consumer.
void	setFieldMapping(Map<String,String> fieldMapping) Deprecated. Use table descriptors instead of implementation-specific builders.
void	setProctimeAttribute(String proctimeAttribute) Deprecated. Use table descriptors instead of implementation-specific builders.
void	setRowtimeAttributeDescriptor(org.apache.flink.table.sources.RowtimeAttributeDescriptor rowtimeAttributeDescriptor) Deprecated. Use table descriptors instead of implementation-specific builders.

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

explainSource

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Kafka011AvroTableSource

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

Deprecated. Use table descriptors instead of implementation-specific builders.

Creates a Kafka 0.11 Avro StreamTableSource using a given SpecificRecord.

Parameters:

topic - Kafka topic to consume.

properties - Properties for the Kafka consumer.

schema - Schema of the produced table.

record - Avro specific record.

Method Detail

setFieldMapping

@Deprecated
public void setFieldMapping(Map<String,String> fieldMapping)

Deprecated. Use table descriptors instead of implementation-specific builders.

Sets a mapping from schema fields to fields of the produced Avro record.

A field mapping is required if the fields of produced tables should be named different than the fields of the Avro record. The key of the provided Map refers to the field of the table schema, the value to the field of the Avro record.

Overrides:

setFieldMapping in class KafkaTableSource

Parameters:

fieldMapping - A mapping from schema fields to Avro fields.

setProctimeAttribute

@Deprecated
public void setProctimeAttribute(String proctimeAttribute)

Deprecated. Use table descriptors instead of implementation-specific builders.

Declares a field of the schema to be a processing time attribute.

Overrides:

setProctimeAttribute in class KafkaTableSource

Parameters:

proctimeAttribute - The name of the field that becomes the processing time field.

setRowtimeAttributeDescriptor

@Deprecated
public void setRowtimeAttributeDescriptor(org.apache.flink.table.sources.RowtimeAttributeDescriptor rowtimeAttributeDescriptor)

Deprecated. Use table descriptors instead of implementation-specific builders.

Declares a field of the schema to be a rowtime attribute.

Parameters:

rowtimeAttributeDescriptor - The descriptor of the rowtime attribute.

createKafkaConsumer

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

Deprecated.

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

builder

@Deprecated
public static Kafka011AvroTableSource.Builder 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).

Returns a builder to configure and create a Kafka011AvroTableSource.

Returns:

A builder to configure and create a Kafka011AvroTableSource.