public class FlinkOrcWriter extends java.lang.Object implements OrcRowWriter<org.apache.flink.table.data.RowData>
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() |
public static OrcRowWriter<org.apache.flink.table.data.RowData> buildWriter(org.apache.flink.table.types.logical.RowType rowType, Schema iSchema)
public void write(org.apache.flink.table.data.RowData row, org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch output)
OrcRowWriter
write
in interface OrcRowWriter<org.apache.flink.table.data.RowData>
row
- the row data value to write.output
- the VectorizedRowBatch to which the output will be written.public java.util.List<OrcValueWriter<?>> writers()
writers
in interface OrcRowWriter<org.apache.flink.table.data.RowData>
public java.util.stream.Stream<FieldMetrics<?>> metrics()
OrcRowWriter
FieldMetrics
that this OrcRowWriter keeps track of.metrics
in interface OrcRowWriter<org.apache.flink.table.data.RowData>