Package 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 Details

  • Method Details

    • 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