Package org.apache.iceberg.data.orc
Class GenericOrcWriter
- java.lang.Object
-
- org.apache.iceberg.data.orc.GenericOrcWriter
-
- All Implemented Interfaces:
OrcRowWriter<Record>
public class GenericOrcWriter extends java.lang.Object implements OrcRowWriter<Record>
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static OrcRowWriter<Record>buildWriter(Schema expectedSchema, org.apache.orc.TypeDescription fileSchema)java.util.stream.Stream<FieldMetrics<?>>metrics()Returns a stream ofFieldMetricsthat this OrcRowWriter keeps track of.voidwrite(Record value, 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
-
buildWriter
public static OrcRowWriter<Record> buildWriter(Schema expectedSchema, org.apache.orc.TypeDescription fileSchema)
-
write
public void write(Record value, org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch output)
Description copied from interface:OrcRowWriterWrites or appends a row to ORC's VectorizedRowBatch.- Specified by:
writein interfaceOrcRowWriter<Record>- Parameters:
value- the row data value to write.output- the VectorizedRowBatch to which the output will be written.
-
writers
public java.util.List<OrcValueWriter<?>> writers()
- Specified by:
writersin interfaceOrcRowWriter<Record>
-
metrics
public java.util.stream.Stream<FieldMetrics<?>> metrics()
Description copied from interface:OrcRowWriterReturns a stream ofFieldMetricsthat this OrcRowWriter keeps track of.- Specified by:
metricsin interfaceOrcRowWriter<Record>
-
-