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

Method Summary

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

MessageReaderFactory

public MessageReaderFactory()

Method Details

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