org.apache.flink.streaming.connectors.kafka

Class KafkaAvroTableSource.Builder<T extends KafkaAvroTableSource,B extends KafkaAvroTableSource.Builder>

java.lang.Object

org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder<T,B>

org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource.Builder<T,B>

Type Parameters:

T - Type of the KafkaAvroTableSource produced by the builder.

B - Type of the KafkaAvroTableSource.Builder subclass.

Direct Known Subclasses:

Kafka010AvroTableSource.Builder, Kafka011AvroTableSource.Builder, Kafka08AvroTableSource.Builder, Kafka09AvroTableSource.Builder

Enclosing class:

KafkaAvroTableSource

protected abstract static class KafkaAvroTableSource.Builder<T extends KafkaAvroTableSource,B extends KafkaAvroTableSource.Builder>
extends KafkaTableSource.Builder<T,B>

Abstract builder for a KafkaAvroTableSource to be extended by builders of subclasses of KafkaAvroTableSource.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Builder()

Method Summary

Modifier and Type	Method and Description
protected void	configureTableSource(T source) Configures a TableSource with optional parameters.
B	forAvroRecordClass(Class<? extends org.apache.avro.specific.SpecificRecordBase> avroClass) Sets the class of the Avro records that aree read from the Kafka topic.
protected Class<? extends org.apache.avro.specific.SpecificRecordBase>	getAvroRecordClass() Returns the configured Avro class.
B	withTableToAvroMapping(Map<String,String> schemaToAvroMapping) Sets a mapping from schema fields to fields of the produced Avro record.

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

build, builder, forTopic, fromEarliest, fromGroupOffsets, fromLatest, fromSpecificOffsets, getKafkaProps, getTableSchema, getTopic, supportsKafkaTimestamps, withKafkaProperties, withKafkaTimestampAsRowtimeAttribute, withProctimeAttribute, withRowtimeAttribute, withSchema

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

protected Builder()

Method Detail

forAvroRecordClass

public B forAvroRecordClass(Class<? extends org.apache.avro.specific.SpecificRecordBase> avroClass)

Sets the class of the Avro records that aree read from the Kafka topic.

Parameters:

avroClass - The class of the Avro records that are read from the Kafka topic.

Returns:

The builder.

withTableToAvroMapping

public B withTableToAvroMapping(Map<String,String> schemaToAvroMapping)

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.

Parameters:

schemaToAvroMapping - A mapping from schema fields to Avro fields.

Returns:

The builder.

getAvroRecordClass

protected Class<? extends org.apache.avro.specific.SpecificRecordBase> getAvroRecordClass()

Returns the configured Avro class.

Returns:

The configured Avro class.

configureTableSource

protected void configureTableSource(T source)

Description copied from class: KafkaTableSource.Builder

Configures a TableSource with optional parameters.

Overrides:

configureTableSource in class KafkaTableSource.Builder<T extends KafkaAvroTableSource,B extends KafkaAvroTableSource.Builder>

Parameters:

source - The TableSource to configure.