org.apache.paimon.format.orc

Class OrcWriterFactory

java.lang.Object

org.apache.paimon.format.orc.OrcWriterFactory

All Implemented Interfaces:

FormatWriterFactory

public class OrcWriterFactory
extends Object
implements FormatWriterFactory

A factory that creates an ORC FormatWriter. The factory takes a user supplied Vectorizer implementation to convert the element into an VectorizedRowBatch.

Constructor Summary

Constructors

Constructor and Description
OrcWriterFactory(Vectorizer<InternalRow> vectorizer, Properties writerProperties, org.apache.hadoop.conf.Configuration configuration, int writeBatchSize) Creates a new OrcBulkWriterFactory using the provided Vectorizer, Hadoop Configuration, ORC writer properties.

Method Summary

Modifier and Type	Method and Description
FormatWriter	create(PositionOutputStream out, String compression) Creates a writer that writes to the given stream.
protected OrcFile.WriterOptions	getWriterOptions()

Methods inherited from class java.lang.Object

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

Constructor Detail

OrcWriterFactory

public OrcWriterFactory(Vectorizer<InternalRow> vectorizer,
                        Properties writerProperties,
                        org.apache.hadoop.conf.Configuration configuration,
                        int writeBatchSize)

Creates a new OrcBulkWriterFactory using the provided Vectorizer, Hadoop Configuration, ORC writer properties.

Parameters:

vectorizer - The vectorizer implementation to convert input record to a VectorizerRowBatch.

writerProperties - Properties that can be used in ORC WriterOptions.

Method Detail

create

public FormatWriter create(PositionOutputStream out,
                           String compression)
                    throws IOException

Description copied from interface: FormatWriterFactory

Creates a writer that writes to the given stream.

Specified by:

create in interface FormatWriterFactory

Parameters:

out - The output stream to write the encoded data to.

compression - the compression value.

Throws:

IOException - Thrown if the writer cannot be opened, or if the output stream throws an exception.

getWriterOptions

@VisibleForTesting
protected OrcFile.WriterOptions getWriterOptions()