Package 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	Description
IncomingDataBatch(BitData.FragmentRecordBatch header, DrillBuf body, AckSender sender)	Create a new batch.

Method Summary

Modifier and Type	Method	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 Details

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 Details

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()