public class Kafka010TableSource extends Kafka09TableSource
StreamTableSource
for Kafka 0.10.Constructor and Description |
---|
Kafka010TableSource(String topic,
Properties properties,
DeserializationSchema<Row> deserializationSchema,
TypeInformation<Row> typeInfo)
Creates a Kafka 0.10
StreamTableSource . |
explainSource, getDataStream, getDeserializationSchema, getReturnType
public Kafka010TableSource(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, TypeInformation<Row> typeInfo)
StreamTableSource
.topic
- Kafka topic to consume.properties
- Properties for the Kafka consumer.deserializationSchema
- Deserialization schema to use for Kafka records.typeInfo
- Type information describing the result type. The field names are used
to parse the JSON file and so are the types.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.