| Package | Description |
|---|---|
| org.apache.drill.exec.ops | |
| org.apache.drill.exec.physical.impl.partitionsender | |
| org.apache.drill.test |
Provides a variety of test framework tools to simplify Drill unit
tests and ad-hoc tests created while developing features.
|
| Modifier and Type | Method and Description |
|---|---|
AccountingDataTunnel |
ExchangeFragmentContext.getDataTunnel(CoordinationProtos.DrillbitEndpoint endpoint) |
AccountingDataTunnel |
FragmentContextImpl.getDataTunnel(CoordinationProtos.DrillbitEndpoint endpoint) |
| Modifier and Type | Method and Description |
|---|---|
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.
|
| Constructor and Description |
|---|
OutgoingRecordBatch(OperatorStats stats,
HashPartitionSender operator,
AccountingDataTunnel tunnel,
FragmentContext context,
BufferAllocator allocator,
int oppositeMinorFragmentId) |
| Modifier and Type | Method and Description |
|---|---|
AccountingDataTunnel |
PhysicalOpUnitTestBase.MockExecutorFragmentContext.getDataTunnel(CoordinationProtos.DrillbitEndpoint endpoint) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.