public abstract class KafkaJsonTableSourceFactory extends Object implements org.apache.flink.table.sources.TableSourceFactory<Row>
KafkaJsonTableSource
.Constructor and Description |
---|
KafkaJsonTableSourceFactory() |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.sources.TableSource<Row> |
create(Map<String,String> properties) |
protected abstract KafkaJsonTableSource.Builder |
createBuilder() |
protected abstract String |
kafkaVersion() |
Map<String,String> |
requiredContext() |
List<String> |
supportedProperties() |
public Map<String,String> requiredContext()
requiredContext
in interface org.apache.flink.table.sources.TableSourceFactory<Row>
public List<String> supportedProperties()
supportedProperties
in interface org.apache.flink.table.sources.TableSourceFactory<Row>
public org.apache.flink.table.sources.TableSource<Row> create(Map<String,String> properties)
create
in interface org.apache.flink.table.sources.TableSourceFactory<Row>
protected abstract KafkaJsonTableSource.Builder createBuilder()
protected abstract String kafkaVersion()
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.