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 Kafka010JsonTableSource.Builder extends KafkaJsonTableSource.Builder<Kafka010JsonTableSource,Kafka010JsonTableSource.Builder>
Kafka010JsonTableSource
.Constructor and Description |
---|
Builder()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Kafka010JsonTableSource |
build()
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
protected Kafka010JsonTableSource.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<Kafka010JsonTableSource,Kafka010JsonTableSource.Builder>
protected Kafka010JsonTableSource.Builder builder()
KafkaTableSourceBase.Builder
builder
in class KafkaTableSourceBase.Builder<Kafka010JsonTableSource,Kafka010JsonTableSource.Builder>
public Kafka010JsonTableSource build()
Kafka010JsonTableSource
.build
in class KafkaTableSourceBase.Builder<Kafka010JsonTableSource,Kafka010JsonTableSource.Builder>
Kafka010JsonTableSource
.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.