org.apache.flink.streaming.connectors.kafka

Class Kafka010JsonTableSourceFactory

java.lang.Object

org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactory

org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSourceFactory

All Implemented Interfaces:

org.apache.flink.table.sources.TableSourceFactory<Row>

public class Kafka010JsonTableSourceFactory
extends KafkaJsonTableSourceFactory

Factory for creating configured instances of Kafka010JsonTableSource.

Constructor Summary

Constructors

Constructor and Description
Kafka010JsonTableSourceFactory()

Method Summary

Modifier and Type	Method and Description
protected KafkaJsonTableSource.Builder	createBuilder()
protected String	kafkaVersion()

Methods inherited from class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactory

create, requiredContext, supportedProperties

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Kafka010JsonTableSourceFactory

public Kafka010JsonTableSourceFactory()

Method Detail

createBuilder

protected KafkaJsonTableSource.Builder createBuilder()

Specified by:

createBuilder in class KafkaJsonTableSourceFactory

kafkaVersion

protected String kafkaVersion()

Specified by:

kafkaVersion in class KafkaJsonTableSourceFactory