FlinkOrcWriter

java.lang.Object

org.apache.iceberg.flink.data.FlinkOrcWriter

All Implemented Interfaces:: OrcRowWriter<org.apache.flink.table.data.RowData>

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

Method Summary

Modifier and Type

Method

Description

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

buildWriter(org.apache.flink.table.types.logical.RowType rowType, Schema iSchema)

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.

List<OrcValueWriter<?>>

writers()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- 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 List<OrcValueWriter<?>> writers()
  
  Specified by:
  
  writers in interface OrcRowWriter<org.apache.flink.table.data.RowData>
- metrics
  
  public 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>