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 static class Kafka010AvroTableSource.Builder extends KafkaAvroTableSource.Builder<Kafka010AvroTableSource,Kafka010AvroTableSource.Builder>
Kafka010AvroTableSource
.Constructor and Description |
---|
Builder()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Kafka010AvroTableSource |
build()
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
protected Kafka010AvroTableSource.Builder |
builder()
Deprecated.
Returns the builder.
|
protected boolean |
supportsKafkaTimestamps()
Deprecated.
True if the KafkaSource supports Kafka timestamps, false otherwise.
|
configureTableSource, forAvroRecordClass, getAvroRecordClass, withTableToAvroMapping
forTopic, fromEarliest, fromGroupOffsets, fromLatest, fromSpecificOffsets, getKafkaProps, getTableSchema, getTopic, withKafkaProperties, withKafkaTimestampAsRowtimeAttribute, withProctimeAttribute, withRowtimeAttribute, withSchema
protected boolean supportsKafkaTimestamps()
KafkaTableSourceBase.Builder
supportsKafkaTimestamps
in class KafkaTableSourceBase.Builder<Kafka010AvroTableSource,Kafka010AvroTableSource.Builder>
protected Kafka010AvroTableSource.Builder builder()
KafkaTableSourceBase.Builder
builder
in class KafkaTableSourceBase.Builder<Kafka010AvroTableSource,Kafka010AvroTableSource.Builder>
@Deprecated public Kafka010AvroTableSource build()
Kafka010AvroTableSource
.build
in class KafkaTableSourceBase.Builder<Kafka010AvroTableSource,Kafka010AvroTableSource.Builder>
Kafka010AvroTableSource
.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.