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