org.apache.drill.exec.record

Class WritableBatch

java.lang.Object

org.apache.drill.exec.record.WritableBatch

All Implemented Interfaces:

AutoCloseable

public class WritableBatch
extends Object
implements AutoCloseable

A specialized version of record batch that can moves out buffers and preps them for writing.

Method Summary

Modifier and Type	Method and Description
void	clear()
void	close()
static WritableBatch	get(VectorAccessible batch)
static WritableBatch	getBatchNoHV(int recordCount, Iterable<ValueVector> vectors, boolean isSV2)
static WritableBatch	getBatchNoHVWrap(int recordCount, Iterable<VectorWrapper<?>> vws, boolean isSV2)
DrillBuf[]	getBuffers()
UserBitShared.RecordBatchDef	getDef()
void	reconstructContainer(BufferAllocator allocator, VectorContainer container)
void	retainBuffers(int increment)
WritableBatch	transfer(BufferAllocator allocator)

Methods inherited from class java.lang.Object

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

Method Detail

transfer

public WritableBatch transfer(BufferAllocator allocator)

getDef

public UserBitShared.RecordBatchDef getDef()

getBuffers

public DrillBuf[] getBuffers()

reconstructContainer

public void reconstructContainer(BufferAllocator allocator,
                                 VectorContainer container)

clear

public void clear()

getBatchNoHVWrap

public static WritableBatch getBatchNoHVWrap(int recordCount,
                                             Iterable<VectorWrapper<?>> vws,
                                             boolean isSV2)

getBatchNoHV

public static WritableBatch getBatchNoHV(int recordCount,
                                         Iterable<ValueVector> vectors,
                                         boolean isSV2)

get

public static WritableBatch get(VectorAccessible batch)

retainBuffers

public void retainBuffers(int increment)

close

public void close()

Specified by:

close in interface AutoCloseable