org.apache.drill.exec.rpc.data

Class IncomingDataBatch

java.lang.Object

org.apache.drill.exec.rpc.data.IncomingDataBatch

public class IncomingDataBatch
extends Object

An incoming batch of data. The data is held by the original allocator. Any use of the associated data must be leveraged through the use of newRawFragmentBatch().

Constructor Summary

Constructors

Constructor and Description
IncomingDataBatch(BitData.FragmentRecordBatch header, DrillBuf body, AckSender sender) Create a new batch.

Method Summary

Modifier and Type	Method and Description
BitData.FragmentRecordBatch	getHeader()
RawFragmentBatch	newRawFragmentBatch(BufferAllocator allocator) Create a new RawFragmentBatch based on this incoming data batch that is transferred into the provided allocator.

Methods inherited from class java.lang.Object

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

Constructor Detail

IncomingDataBatch

public IncomingDataBatch(BitData.FragmentRecordBatch header,
                         DrillBuf body,
                         AckSender sender)

Create a new batch. Does not impact reference counts of body.

Parameters:

header - Batch header

body - Data body. Could be null.

sender - AckSender to use for underlying RawFragmentBatches.

Method Detail

newRawFragmentBatch

public RawFragmentBatch newRawFragmentBatch(BufferAllocator allocator)

Create a new RawFragmentBatch based on this incoming data batch that is transferred into the provided allocator. Also increments the AckSender to expect one additional return message.

Parameters:

allocator - Target allocator that should be associated with data underlying this batch.

Returns:

The newly created RawFragmentBatch

getHeader

public BitData.FragmentRecordBatch getHeader()