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)
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.

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.