org.apache.drill.exec.store.kafka.decoders

Class AvroMessageReader

java.lang.Object

org.apache.drill.exec.store.kafka.decoders.AvroMessageReader

All Implemented Interfaces:

Closeable, AutoCloseable, MessageReader

public class AvroMessageReader
extends Object
implements MessageReader

Constructor Summary

Constructors

Constructor and Description
AvroMessageReader()

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	endBatch()
org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]>	getConsumer(KafkaStoragePlugin plugin)
ResultSetLoader	getResultSetLoader()
void	init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin)
void	readMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AvroMessageReader

public AvroMessageReader()

Method Detail

init

public void init(SchemaNegotiator negotiator,
                 ReadOptions readOptions,
                 KafkaStoragePlugin plugin)

Specified by:

init in interface MessageReader

readMessage

public void readMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)

Specified by:

readMessage in interface MessageReader

getConsumer

public org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]> getConsumer(KafkaStoragePlugin plugin)

Specified by:

getConsumer in interface MessageReader

getResultSetLoader

public ResultSetLoader getResultSetLoader()

Specified by:

getResultSetLoader in interface MessageReader

endBatch

public boolean endBatch()

Specified by:

endBatch in interface MessageReader

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException