Package org.apache.iceberg.orc

Interface OrcRowWriter<T>

All Known Implementing Classes:
FlinkOrcWriter, GenericOrcWriter, SparkOrcWriter
public interface OrcRowWriter<T>
Write data value of a schema.

  • Method Summary

    Modifier and Type
    Method
    Description
    default Stream<FieldMetrics<?>>
    metrics()
    Returns a stream of FieldMetrics that this OrcRowWriter keeps track of.
    void
    write(T row, org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch output)
    Writes or appends a row to ORC's VectorizedRowBatch.
    List<OrcValueWriter<?>>
    writers()
     

  • Method Details

    • write

      void write(T row, org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch output) throws IOException
      Writes or appends a row to ORC's VectorizedRowBatch.
      Parameters:
      row - the row data value to write.
      output - the VectorizedRowBatch to which the output will be written.
      Throws:
      IOException - if there's any IO error while writing the data value.

    • writers

      List<OrcValueWriter<?>> writers()

    • metrics

      default Stream<FieldMetrics<?>> metrics()
      Returns a stream of FieldMetrics that this OrcRowWriter keeps track of.