Package 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	Description
AvroMessageReader()

Method Summary

Modifier and Type	Method	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 Details

AvroMessageReader

public AvroMessageReader()

Method Details

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 AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException