Package org.apache.drill.exec.record

Class FragmentWritableBatch

java.lang.Object

org.apache.drill.exec.record.FragmentWritableBatch

public class FragmentWritableBatch
extends Object

Constructor Summary

Constructors

Constructor	Description
FragmentWritableBatch(boolean isLast, UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int[] receiveMinorFragmentIds, WritableBatch batch)
FragmentWritableBatch(boolean isLast, UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, WritableBatch batch)

Method Summary

Modifier and Type	Method	Description
io.netty.buffer.ByteBuf[]	getBuffers()
long	getByteCount()
static FragmentWritableBatch	getEmptyBatchWithSchema(boolean isLast, UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, BatchSchema schema)
static FragmentWritableBatch	getEmptyLast(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId)
static FragmentWritableBatch	getEmptyLast(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int[] receiveMinorFragmentIds)
static FragmentWritableBatch	getEmptyLastWithSchema(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, BatchSchema schema)
BitData.FragmentRecordBatch	getHeader()

Methods inherited from class java.lang.Object

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

Constructor Details

FragmentWritableBatch

public FragmentWritableBatch(boolean isLast,
 UserBitShared.QueryId queryId,
 int sendMajorFragmentId,
 int sendMinorFragmentId,
 int receiveMajorFragmentId,
 int receiveMinorFragmentId,
 WritableBatch batch)

FragmentWritableBatch

public FragmentWritableBatch(boolean isLast,
 UserBitShared.QueryId queryId,
 int sendMajorFragmentId,
 int sendMinorFragmentId,
 int receiveMajorFragmentId,
 int[] receiveMinorFragmentIds,
 WritableBatch batch)

Method Details

getEmptyLast

public static FragmentWritableBatch getEmptyLast(UserBitShared.QueryId queryId,
 int sendMajorFragmentId,
 int sendMinorFragmentId,
 int receiveMajorFragmentId,
 int receiveMinorFragmentId)

getEmptyLast

public static FragmentWritableBatch getEmptyLast(UserBitShared.QueryId queryId,
 int sendMajorFragmentId,
 int sendMinorFragmentId,
 int receiveMajorFragmentId,
 int[] receiveMinorFragmentIds)

getEmptyLastWithSchema

public static FragmentWritableBatch getEmptyLastWithSchema(UserBitShared.QueryId queryId,
 int sendMajorFragmentId,
 int sendMinorFragmentId,
 int receiveMajorFragmentId,
 int receiveMinorFragmentId,
 BatchSchema schema)

getEmptyBatchWithSchema

public static FragmentWritableBatch getEmptyBatchWithSchema(boolean isLast,
 UserBitShared.QueryId queryId,
 int sendMajorFragmentId,
 int sendMinorFragmentId,
 int receiveMajorFragmentId,
 int receiveMinorFragmentId,
 BatchSchema schema)

getBuffers

public io.netty.buffer.ByteBuf[] getBuffers()

getByteCount

public long getByteCount()

getHeader

public BitData.FragmentRecordBatch getHeader()