T
- Type of the KafkaAvroTableSource produced by the builder.B
- Type of the KafkaAvroTableSource.Builder subclass.Kafka
descriptor together
with descriptors for schema and format instead. Descriptors allow for
implementation-agnostic definition of tables. See also
TableEnvironment.connect(ConnectorDescriptor)
.@Deprecated protected abstract static class KafkaAvroTableSource.Builder<T extends KafkaAvroTableSource,B extends KafkaAvroTableSource.Builder> extends KafkaTableSource.Builder<T,B>
KafkaAvroTableSource
to be extended by builders of subclasses of
KafkaAvroTableSource.Modifier | Constructor and Description |
---|---|
protected |
Builder()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
configureTableSource(T source)
Deprecated.
Configures a TableSource with optional parameters.
|
B |
forAvroRecordClass(Class<? extends org.apache.avro.specific.SpecificRecordBase> avroClass)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
protected Class<? extends org.apache.avro.specific.SpecificRecordBase> |
getAvroRecordClass()
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
B |
withTableToAvroMapping(Map<String,String> schemaToAvroMapping)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
build, builder, forTopic, fromEarliest, fromGroupOffsets, fromLatest, fromSpecificOffsets, getKafkaProps, getTableSchema, getTopic, supportsKafkaTimestamps, withKafkaProperties, withKafkaTimestampAsRowtimeAttribute, withProctimeAttribute, withRowtimeAttribute, withSchema
@Deprecated public B forAvroRecordClass(Class<? extends org.apache.avro.specific.SpecificRecordBase> avroClass)
avroClass
- The class of the Avro records that are read from the Kafka topic.@Deprecated public B withTableToAvroMapping(Map<String,String> schemaToAvroMapping)
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.
schemaToAvroMapping
- A mapping from schema fields to Avro fields.@Deprecated protected Class<? extends org.apache.avro.specific.SpecificRecordBase> getAvroRecordClass()
protected void configureTableSource(T source)
KafkaTableSource.Builder
configureTableSource
in class KafkaTableSource.Builder<T extends KafkaAvroTableSource,B extends KafkaAvroTableSource.Builder>
source
- The TableSource to configure.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.