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 and Description
default java.util.stream.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.
java.util.List<OrcValueWriter<?>>	writers()

Method Detail

write

void write(T row,
           org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch output)
    throws java.io.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:

java.io.IOException - if there's any IO error while writing the data value.

writers

java.util.List<OrcValueWriter<?>> writers()

metrics

default java.util.stream.Stream<FieldMetrics<?>> metrics()

Returns a stream of FieldMetrics that this OrcRowWriter keeps track of.