org.apache.paimon.format.orc.writer

Class Vectorizer<T>

java.lang.Object

org.apache.paimon.format.orc.writer.Vectorizer<T>

Type Parameters:

T - The type of the element

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

RowDataVectorizer

public abstract class Vectorizer<T>
extends Object
implements Serializable

This class provides an abstracted set of methods to handle the lifecycle of VectorizedRowBatch.

Users have to extend this class and override the vectorize() method with the logic to transform the element to a VectorizedRowBatch.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Vectorizer(String schema)

Method Summary

Modifier and Type	Method and Description
org.apache.orc.TypeDescription	getSchema() Provides the ORC schema.
abstract void	vectorize(T element, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch) Transforms the provided element to ColumnVectors and sets them in the exposed VectorizedRowBatch.

Methods inherited from class java.lang.Object

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

Constructor Detail

Vectorizer

public Vectorizer(String schema)

Method Detail

getSchema

public org.apache.orc.TypeDescription getSchema()

Provides the ORC schema.

Returns:

the ORC schema

vectorize

public abstract void vectorize(T element,
                               org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)
                        throws IOException

Transforms the provided element to ColumnVectors and sets them in the exposed VectorizedRowBatch.

Parameters:

element - The input element

batch - The batch to write the ColumnVectors

Throws:

IOException - if there is an error while transforming the input.