public static class Kafka010JsonTableSource.Builder extends KafkaJsonTableSource.Builder<Kafka010JsonTableSource,Kafka010JsonTableSource.Builder>
Kafka010JsonTableSource
.Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
Kafka010JsonTableSource |
build()
Builds and configures a
Kafka010JsonTableSource . |
protected Kafka010JsonTableSource.Builder |
builder()
Returns the builder.
|
protected boolean |
supportsKafkaTimestamps()
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()
KafkaTableSource.Builder
supportsKafkaTimestamps
in class KafkaTableSource.Builder<Kafka010JsonTableSource,Kafka010JsonTableSource.Builder>
protected Kafka010JsonTableSource.Builder builder()
KafkaTableSource.Builder
builder
in class KafkaTableSource.Builder<Kafka010JsonTableSource,Kafka010JsonTableSource.Builder>
public Kafka010JsonTableSource build()
Kafka010JsonTableSource
.build
in class KafkaTableSource.Builder<Kafka010JsonTableSource,Kafka010JsonTableSource.Builder>
Kafka010JsonTableSource
.Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.