Class RowDataVectorizer

    • 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: Vectorizer
        Transforms the provided element to ColumnVectors and sets them in the exposed VectorizedRowBatch.
        Specified by:
        vectorize in class Vectorizer<org.apache.flink.table.data.RowData>
        Parameters:
        row - The input element
        batch - The batch to write the ColumnVectors