Uses of Class
org.apache.drill.exec.record.FragmentWritableBatch
Package
Description
-
Uses of FragmentWritableBatch in org.apache.drill.exec.ops
Modifier and TypeMethodDescriptionvoid
AccountingDataTunnel.sendRecordBatch
(FragmentWritableBatch batch) -
Uses of FragmentWritableBatch in org.apache.drill.exec.physical.impl
Modifier and TypeMethodDescriptionvoid
SingleSenderCreator.SingleSenderRootExec.updateStats
(FragmentWritableBatch writableBatch) -
Uses of FragmentWritableBatch in org.apache.drill.exec.physical.impl.broadcastsender
Modifier and TypeMethodDescriptionvoid
BroadcastSenderRootExec.updateStats
(FragmentWritableBatch writableBatch) -
Uses of FragmentWritableBatch in org.apache.drill.exec.physical.impl.partitionsender
Modifier and TypeMethodDescriptionvoid
PartitionerTemplate.OutgoingRecordBatch.updateStats
(FragmentWritableBatch writableBatch) -
Uses of FragmentWritableBatch in org.apache.drill.exec.record
Modifier and TypeMethodDescriptionstatic FragmentWritableBatch
FragmentWritableBatch.getEmptyBatchWithSchema
(boolean isLast, UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, BatchSchema schema) static FragmentWritableBatch
FragmentWritableBatch.getEmptyLast
(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId) static FragmentWritableBatch
FragmentWritableBatch.getEmptyLast
(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int[] receiveMinorFragmentIds) static FragmentWritableBatch
FragmentWritableBatch.getEmptyLastWithSchema
(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, BatchSchema schema) -
Uses of FragmentWritableBatch in org.apache.drill.exec.rpc.data
Modifier and TypeMethodDescriptionvoid
DataTunnel.sendRecordBatch
(RpcOutcomeListener<BitData.AckWithCredit> outcomeListener, FragmentWritableBatch batch)