Uses of Class
org.apache.drill.exec.record.FragmentWritableBatch
Packages that use FragmentWritableBatch
Package
Description
-
Uses of FragmentWritableBatch in org.apache.drill.exec.ops
Methods in org.apache.drill.exec.ops with parameters of type FragmentWritableBatchModifier and TypeMethodDescriptionvoid
AccountingDataTunnel.sendRecordBatch
(FragmentWritableBatch batch) -
Uses of FragmentWritableBatch in org.apache.drill.exec.physical.impl
Methods in org.apache.drill.exec.physical.impl with parameters of type FragmentWritableBatchModifier and TypeMethodDescriptionvoid
SingleSenderCreator.SingleSenderRootExec.updateStats
(FragmentWritableBatch writableBatch) -
Uses of FragmentWritableBatch in org.apache.drill.exec.physical.impl.broadcastsender
Methods in org.apache.drill.exec.physical.impl.broadcastsender with parameters of type FragmentWritableBatchModifier and TypeMethodDescriptionvoid
BroadcastSenderRootExec.updateStats
(FragmentWritableBatch writableBatch) -
Uses of FragmentWritableBatch in org.apache.drill.exec.physical.impl.partitionsender
Methods in org.apache.drill.exec.physical.impl.partitionsender with parameters of type FragmentWritableBatchModifier and TypeMethodDescriptionvoid
PartitionerTemplate.OutgoingRecordBatch.updateStats
(FragmentWritableBatch writableBatch) -
Uses of FragmentWritableBatch in org.apache.drill.exec.record
Methods in org.apache.drill.exec.record that return FragmentWritableBatchModifier 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
Methods in org.apache.drill.exec.rpc.data with parameters of type FragmentWritableBatchModifier and TypeMethodDescriptionvoid
DataTunnel.sendRecordBatch
(RpcOutcomeListener<BitData.AckWithCredit> outcomeListener, FragmentWritableBatch batch)