org.apache.iceberg.spark.data

Class SparkOrcWriter

java.lang.Object

org.apache.iceberg.spark.data.SparkOrcWriter

All Implemented Interfaces:

OrcValueWriter<org.apache.spark.sql.catalyst.InternalRow>

public class SparkOrcWriter
extends java.lang.Object
implements OrcValueWriter<org.apache.spark.sql.catalyst.InternalRow>

This class acts as an adaptor from an OrcFileAppender to a FileAppender<InternalRow>.

Constructor Summary

Constructors

Constructor and Description
SparkOrcWriter(org.apache.orc.TypeDescription schema)

Method Summary

Modifier and Type	Method and Description
void	write(org.apache.spark.sql.catalyst.InternalRow value, org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch output) Writes the data.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkOrcWriter

public SparkOrcWriter(org.apache.orc.TypeDescription schema)

Method Detail

write

public void write(org.apache.spark.sql.catalyst.InternalRow value,
                  org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch output)

Description copied from interface: OrcValueWriter

Writes the data.

Specified by:

write in interface OrcValueWriter<org.apache.spark.sql.catalyst.InternalRow>

Parameters:

value - the data value to write.

output - the VectorizedRowBatch to which the output will be written.