Package org.apache.drill.exec.store.pojo

Interface PojoWriter

All Known Implementing Classes:
AbstractPojoWriter, PojoWriters.BitWriter, PojoWriters.DecimalWriter, PojoWriters.DoubleWriter, PojoWriters.EnumWriter, PojoWriters.FloatWriter, PojoWriters.IntWriter, PojoWriters.LongWriter, PojoWriters.NBigIntWriter, PojoWriters.NBooleanWriter, PojoWriters.NDoubleWriter, PojoWriters.NFloatWriter, PojoWriters.NIntWriter, PojoWriters.NTimeStampWriter, PojoWriters.StringWriter
public interface PojoWriter
Pojo writer interface for writers based on types supported for pojo.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    allocate()
    Allocates new buffer for value vector.
    void
    cleanup()
    Performs clean up if needed.
    void
    init(OutputMutator output)
    Initializes value vector.
    void
    setValueCount(int recordCount)
    Sets number of written records.
    void
    writeField(Object value, int outboundIndex)
    Writes given value to the given position of the bit to set.

  • Method Details

    • writeField

      void writeField(Object value, int outboundIndex)
      Writes given value to the given position of the bit to set.
      Parameters:
      value - values to be written
      outboundIndex - position of the bit

    • init

      void init(OutputMutator output) throws SchemaChangeException
      Initializes value vector.
      Parameters:
      output - output mutator
      Throws:
      SchemaChangeException

    • allocate

      void allocate()
      Allocates new buffer for value vector.

    • setValueCount

      void setValueCount(int recordCount)
      Sets number of written records.
      Parameters:
      recordCount - record count

    • cleanup

      void cleanup()
      Performs clean up if needed.