public class Kafka09JsonTableSource extends KafkaJsonTableSource
StreamTableSource
for Kafka 0.9.Constructor and Description |
---|
Kafka09JsonTableSource(String topic,
Properties properties,
String[] fieldNames,
Class<?>[] fieldTypes)
Creates a Kafka 0.9 JSON
StreamTableSource . |
Kafka09JsonTableSource(String topic,
Properties properties,
String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Creates a Kafka 0.9 JSON
StreamTableSource . |
setFailOnMissingField
getDataStream, getDeserializationSchema, getReturnType
public Kafka09JsonTableSource(String topic, Properties properties, String[] fieldNames, TypeInformation<?>[] fieldTypes)
StreamTableSource
.topic
- Kafka topic to consume.properties
- Properties for the Kafka consumer.fieldNames
- Row field names.fieldTypes
- Row field types.public Kafka09JsonTableSource(String topic, Properties properties, String[] fieldNames, Class<?>[] fieldTypes)
StreamTableSource
.topic
- Kafka topic to consume.properties
- Properties for the Kafka consumer.fieldNames
- Row field names.fieldTypes
- Row field types.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.