Package org.apache.flink.orc.vector
Class RowDataVectorizer
- java.lang.Object
-
- org.apache.flink.orc.vector.Vectorizer<org.apache.flink.table.data.RowData>
-
- org.apache.flink.orc.vector.RowDataVectorizer
-
- All Implemented Interfaces:
Serializable
public class RowDataVectorizer extends Vectorizer<org.apache.flink.table.data.RowData>
AVectorizerofRowDatatype element.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description RowDataVectorizer(String schema, org.apache.flink.table.types.logical.LogicalType[] fieldTypes)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidvectorize(org.apache.flink.table.data.RowData row, 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 org.apache.flink.orc.vector.Vectorizer
addUserMetadata, getSchema, setWriter
-
-
-
-
Constructor Detail
-
RowDataVectorizer
public RowDataVectorizer(String schema, org.apache.flink.table.types.logical.LogicalType[] fieldTypes)
-
-
Method Detail
-
vectorize
public void vectorize(org.apache.flink.table.data.RowData row, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)Description copied from class:VectorizerTransforms the provided element to ColumnVectors and sets them in the exposed VectorizedRowBatch.- Specified by:
vectorizein classVectorizer<org.apache.flink.table.data.RowData>- Parameters:
row- The input elementbatch- The batch to write the ColumnVectors
-
-