Package 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 Description SparkOrcWriter(org.apache.orc.TypeDescription schema)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidwrite(org.apache.spark.sql.catalyst.InternalRow value, org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch output)Writes the data.
-
-
-
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:OrcValueWriterWrites the data.- Specified by:
writein interfaceOrcValueWriter<org.apache.spark.sql.catalyst.InternalRow>- Parameters:
value- the data value to write.output- the VectorizedRowBatch to which the output will be written.
-
-