Uses of Class
org.apache.drill.exec.physical.config.HashPartitionSender
Package
Description
-
Uses of HashPartitionSender in org.apache.drill.exec.physical.base
Modifier and TypeMethodDescriptionAbstractPhysicalVisitor.visitHashPartitionSender
(HashPartitionSender op, X value) PhysicalVisitor.visitHashPartitionSender
(HashPartitionSender op, EXTRA value) -
Uses of HashPartitionSender in org.apache.drill.exec.physical.impl.partitionsender
Modifier and TypeMethodDescriptionPartitionSenderCreator.getRoot
(ExecutorFragmentContext context, HashPartitionSender config, List<RecordBatch> children) protected PartitionerTemplate.OutgoingRecordBatch
PartitionerTemplate.newOutgoingRecordBatch
(OperatorStats stats, HashPartitionSender operator, AccountingDataTunnel tunnel, FragmentContext context, BufferAllocator allocator, int oppositeMinorFragmentId) Shim method to be overridden in plain-old Java mode by the subclass to instantiate the generated inner class.void
Partitioner.setup
(ExchangeFragmentContext context, RecordBatch incoming, HashPartitionSender popConfig, OperatorStats stats, OperatorContext oContext, ClassGenerator<?> cg, int start, int count) final void
PartitionerTemplate.setup
(ExchangeFragmentContext context, RecordBatch incoming, HashPartitionSender popConfig, OperatorStats stats, OperatorContext oContext, ClassGenerator<?> cg, int start, int end) ModifierConstructorDescriptionOutgoingRecordBatch
(OperatorStats stats, HashPartitionSender operator, AccountingDataTunnel tunnel, FragmentContext context, BufferAllocator allocator, int oppositeMinorFragmentId) PartitionSenderRootExec
(RootFragmentContext context, RecordBatch incoming, HashPartitionSender operator) PartitionSenderRootExec
(RootFragmentContext context, RecordBatch incoming, HashPartitionSender operator, boolean closeIncoming)