org.apache.drill.exec.store.kafka

Class ReadOptions

java.lang.Object

org.apache.drill.exec.store.kafka.ReadOptions

public class ReadOptions
extends Object

Holds all system / session options that are used during data read from Kafka.

Constructor Summary

Constructors

Constructor and Description
ReadOptions(OptionManager optionManager)

Method Summary

Modifier and Type	Method and Description
String	getMessageReader()
long	getPollTimeOut()
boolean	isAllowEscapeAnyChar()
boolean	isAllowNanInf()
boolean	isAllTextMode()
boolean	isEnableUnionType()
boolean	isReadNumbersAsDouble()
boolean	isSkipInvalidRecords()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadOptions

public ReadOptions(OptionManager optionManager)

Method Detail

getMessageReader

public String getMessageReader()

getPollTimeOut

public long getPollTimeOut()

isAllTextMode

public boolean isAllTextMode()

isReadNumbersAsDouble

public boolean isReadNumbersAsDouble()

isEnableUnionType

public boolean isEnableUnionType()

isSkipInvalidRecords

public boolean isSkipInvalidRecords()

isAllowNanInf

public boolean isAllowNanInf()

isAllowEscapeAnyChar

public boolean isAllowEscapeAnyChar()

toString

public String toString()

Overrides:

toString in class Object