Package 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
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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 ofFieldMetricsthat this OrcRowWriter keeps track of.voidwrite(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() 
 - 
 
- 
- 
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:OrcRowWriterWrites or appends a row to ORC's VectorizedRowBatch.- Specified by:
 writein interfaceOrcRowWriter<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:
 writersin interfaceOrcRowWriter<org.apache.flink.table.data.RowData>
 
- 
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<org.apache.flink.table.data.RowData>
 
 - 
 
 -