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 ofFieldMetricsthat this OrcRowWriter keeps track of.voidwrite(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 ofFieldMetricsthat this OrcRowWriter keeps track of.
-
-