public class Kafka08AvroTableSource extends KafkaAvroTableSource
StreamTableSource
for Kafka 0.8.Constructor and Description |
---|
Kafka08AvroTableSource(String topic,
Properties properties,
Class<? extends org.apache.avro.specific.SpecificRecordBase> record)
Creates a Kafka 0.8 Avro
StreamTableSource using a given SpecificRecord . |
explainSource, getDataStream, getDeserializationSchema, getReturnType
public Kafka08AvroTableSource(String topic, Properties properties, Class<? extends org.apache.avro.specific.SpecificRecordBase> record)
StreamTableSource
using a given SpecificRecord
.topic
- Kafka topic to consume.properties
- Properties for the Kafka consumer.record
- Avro specific record.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.