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