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

Class JsonMessageReader

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable, MessageReader

public class JsonMessageReader
extends Object
implements MessageReader

MessageReader class which will convert ConsumerRecord into JSON and writes to VectorContainerWriter of JsonReader

Constructor Summary

Constructors

Constructor	Description
JsonMessageReader()

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)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

JsonMessageReader

public JsonMessageReader()

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

getResultSetLoader

public ResultSetLoader getResultSetLoader()

Specified by:

getResultSetLoader in interface MessageReader

getConsumer

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

Specified by:

getConsumer in interface MessageReader

endBatch

public boolean endBatch()

Specified by:

endBatch in interface MessageReader

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

toString

public String toString()

Overrides:

toString in class Object