org.apache.flink.formats.parquet.vector

Interface ColumnBatchFactory<SplitT extends FileSourceSplit>

All Superinterfaces:

Serializable

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface ColumnBatchFactory<SplitT extends FileSourceSplit>
extends Serializable

Interface to create VectorizedColumnBatch.

Method Summary

Modifier and Type	Method and Description
VectorizedColumnBatch	create(SplitT split, ColumnVector[] vectors)
static <SplitT extends FileSourceSplit> ColumnBatchFactory<SplitT>	withoutExtraFields()

Method Detail

create

VectorizedColumnBatch create(SplitT split,
                             ColumnVector[] vectors)

withoutExtraFields

static <SplitT extends FileSourceSplit> ColumnBatchFactory<SplitT> withoutExtraFields()