Kafka
descriptor together
with descriptors for schema and format instead. Descriptors allow for
implementation-agnostic definition of tables. See also
TableEnvironment.connect(ConnectorDescriptor)
.@Deprecated @Internal public abstract class KafkaJsonTableSource extends KafkaTableSource
StreamTableSource
.
The version-specific Kafka consumers need to extend this class and
override KafkaTableSource.createKafkaConsumer(String, Properties, DeserializationSchema)
}.
The field names are used to parse the JSON file and so are the types.
Modifier and Type | Class and Description |
---|---|
protected static class |
KafkaJsonTableSource.Builder<T extends KafkaJsonTableSource,B extends KafkaJsonTableSource.Builder>
Deprecated.
Use the
Kafka descriptor together
with descriptors for schema and format instead. Descriptors allow for
implementation-agnostic definition of tables. See also
TableEnvironment.connect(ConnectorDescriptor) . |
Modifier | Constructor and Description |
---|---|
protected |
KafkaJsonTableSource(String topic,
Properties properties,
org.apache.flink.table.api.TableSchema tableSchema,
org.apache.flink.table.api.TableSchema jsonSchema)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
Modifier and Type | Method and Description |
---|---|
String |
explainSource()
Deprecated.
|
protected void |
setFailOnMissingField(boolean failOnMissingField)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
createKafkaConsumer, equals, getDataStream, getDeserializationSchema, getFieldMapping, getKafkaConsumer, getProctimeAttribute, getProperties, getReturnType, getRowtimeAttributeDescriptors, getTableSchema, hashCode, setFieldMapping, setProctimeAttribute, setRowtimeAttributeDescriptors, setSpecificStartupOffsets, setStartupMode
@Deprecated protected KafkaJsonTableSource(String topic, Properties properties, org.apache.flink.table.api.TableSchema tableSchema, org.apache.flink.table.api.TableSchema jsonSchema)
StreamTableSource
.topic
- Kafka topic to consume.properties
- Properties for the Kafka consumer.tableSchema
- The schema of the table.jsonSchema
- The schema of the JSON messages to decode from Kafka.public String explainSource()
explainSource
in interface org.apache.flink.table.sources.TableSource<Row>
explainSource
in class KafkaTableSource
@Deprecated protected void setFailOnMissingField(boolean failOnMissingField)
failOnMissingField
- Flag that specifies the TableSource behavior in case of missing fields.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.