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.OutgoingRecordBatchPartitionerTemplate.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.voidPartitioner.setup(ExchangeFragmentContext context, RecordBatch incoming, HashPartitionSender popConfig, OperatorStats stats, OperatorContext oContext, ClassGenerator<?> cg, int start, int count) final voidPartitionerTemplate.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)