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 and 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 and 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 Detail

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 Detail

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