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
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default java.util.stream.Stream<FieldMetrics<?>>
metrics()
Returns a stream ofFieldMetrics
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 ofFieldMetrics
that this OrcRowWriter keeps track of.
-
-