org.apache.drill.exec.store.parquet.columnreaders.batchsizing

Class RecordBatchOverflow

java.lang.Object

org.apache.drill.exec.store.parquet.columnreaders.batchsizing.RecordBatchOverflow

public final class RecordBatchOverflow
extends Object

Logic for handling batch record overflow; this class essentially serializes overflow vector data in a compact manner so that it is reused for building the next record batch.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RecordBatchOverflow.Builder Builder class to construct a RecordBatchOverflow object
static class	RecordBatchOverflow.FieldOverflowDefinition Field overflow definition
static class	RecordBatchOverflow.RecordOverflowDefinition Record batch definition

Method Summary

Modifier and Type	Method and Description
RecordBatchOverflow.RecordOverflowDefinition	getRecordOverflowDefinition()
static RecordBatchOverflow.Builder	newBuilder(BufferAllocator allocator, RecordBatchStats.RecordBatchStatsContext batchStatsContext)

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static RecordBatchOverflow.Builder newBuilder(BufferAllocator allocator,
                                                     RecordBatchStats.RecordBatchStatsContext batchStatsContext)

Parameters:

allocator - buffer allocator

batchStatsContext - batch statistics context

Returns:

new builder object

getRecordOverflowDefinition

public RecordBatchOverflow.RecordOverflowDefinition getRecordOverflowDefinition()

Returns:

the record overflow definition