org.apache.iceberg.flink.data

Class FlinkOrcWriter

java.lang.Object

org.apache.iceberg.flink.data.FlinkOrcWriter

All Implemented Interfaces:

OrcRowWriter<org.apache.flink.table.data.RowData>

public class FlinkOrcWriter
extends java.lang.Object
implements OrcRowWriter<org.apache.flink.table.data.RowData>

Method Summary

Modifier and Type	Method and Description
static OrcRowWriter<org.apache.flink.table.data.RowData>	buildWriter(org.apache.flink.table.types.logical.RowType rowType, Schema iSchema)
java.util.stream.Stream<FieldMetrics<?>>	metrics() Returns a stream of FieldMetrics that this OrcRowWriter keeps track of.
void	write(org.apache.flink.table.data.RowData row, 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<org.apache.flink.table.data.RowData> buildWriter(org.apache.flink.table.types.logical.RowType rowType,
                                                                            Schema iSchema)

write

public void write(org.apache.flink.table.data.RowData row,
                  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<org.apache.flink.table.data.RowData>

Parameters:

row - 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<org.apache.flink.table.data.RowData>

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<org.apache.flink.table.data.RowData>