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

Modifier and Type	Method and Description
static OrcRowWriter<Record>	buildWriter(Schema expectedSchema, org.apache.orc.TypeDescription fileSchema)
java.util.stream.Stream<FieldMetrics<?>>	metrics() Returns a stream of FieldMetrics that this OrcRowWriter keeps track of.
void	write(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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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: OrcRowWriter

Writes or appends a row to ORC's VectorizedRowBatch.

Specified by:

write in interface OrcRowWriter<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:

writers in interface OrcRowWriter<Record>

metrics

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

Description copied from interface: OrcRowWriter

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

Specified by:

metrics in interface OrcRowWriter<Record>