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

Class MessageReaderFactory

java.lang.Object

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

public class MessageReaderFactory
extends Object

Constructor Summary

Constructors

Constructor and Description
MessageReaderFactory()

Method Summary

Modifier and Type	Method and Description
static MessageReader	getMessageReader(String messageReaderKlass) Initialize kafka message reader based on store.kafka.record.reader session property

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageReaderFactory

public MessageReaderFactory()

Method Detail

getMessageReader

public static MessageReader getMessageReader(String messageReaderKlass)

Initialize kafka message reader based on store.kafka.record.reader session property

Parameters:

messageReaderKlass - value of store.kafka.record.reader session property

Returns:

kafka message reader

Throws:

UserException - in case of any message reader initialization