Uses of Class
org.apache.drill.exec.physical.config.HashPartitionSender
Packages that use HashPartitionSender
Package
Description
-
Uses of HashPartitionSender in org.apache.drill.exec.physical.base
Methods in org.apache.drill.exec.physical.base with parameters of type HashPartitionSenderModifier and TypeMethodDescriptionAbstractPhysicalVisitor.visitHashPartitionSender
(HashPartitionSender op, X value) PhysicalVisitor.visitHashPartitionSender
(HashPartitionSender op, EXTRA value) -
Uses of HashPartitionSender in org.apache.drill.exec.physical.impl.partitionsender
Methods in org.apache.drill.exec.physical.impl.partitionsender with parameters of type HashPartitionSenderModifier 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) Constructors in org.apache.drill.exec.physical.impl.partitionsender with parameters of type HashPartitionSenderModifierConstructorDescriptionOutgoingRecordBatch
(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)