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 TypeMethodDescriptionvoidAccountingDataTunnel.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 TypeMethodDescriptionvoidSingleSenderCreator.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 TypeMethodDescriptionvoidBroadcastSenderRootExec.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 TypeMethodDescriptionvoidPartitionerTemplate.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 FragmentWritableBatchFragmentWritableBatch.getEmptyBatchWithSchema(boolean isLast, UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId, BatchSchema schema) static FragmentWritableBatchFragmentWritableBatch.getEmptyLast(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int receiveMinorFragmentId) static FragmentWritableBatchFragmentWritableBatch.getEmptyLast(UserBitShared.QueryId queryId, int sendMajorFragmentId, int sendMinorFragmentId, int receiveMajorFragmentId, int[] receiveMinorFragmentIds) static FragmentWritableBatchFragmentWritableBatch.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 TypeMethodDescriptionvoidDataTunnel.sendRecordBatch(RpcOutcomeListener<BitData.AckWithCredit> outcomeListener, FragmentWritableBatch batch)