public class IncomingDataBatch extends Object
|Constructor and Description|
Create a new batch.
|Modifier and Type||Method and Description|
Create a new RawFragmentBatch based on this incoming data batch that is transferred into the provided allocator.
public IncomingDataBatch(BitData.FragmentRecordBatch header, DrillBuf body, AckSender sender)
header- Batch header
body- Data body. Could be null.
sender- AckSender to use for underlying RawFragmentBatches.
public RawFragmentBatch newRawFragmentBatch(BufferAllocator allocator)
allocator- Target allocator that should be associated with data underlying this batch.
public BitData.FragmentRecordBatch getHeader()
Copyright © 1970 The Apache Software Foundation. All rights reserved.