| Package | Description |
|---|---|
| org.apache.drill.exec.cache |
Distributed cache for syncing state and data between Drillbits.
|
| org.apache.drill.exec.physical.impl | |
| org.apache.drill.exec.physical.impl.aggregate | |
| org.apache.drill.exec.physical.impl.partitionsender | |
| org.apache.drill.exec.physical.impl.protocol |
Defines a revised implementation of the Drill RecordBatch protocol.
|
| org.apache.drill.exec.physical.impl.sort | |
| org.apache.drill.exec.physical.impl.svremover | |
| org.apache.drill.exec.physical.impl.TopN | |
| org.apache.drill.exec.physical.impl.unnest | |
| org.apache.drill.exec.physical.impl.unorderedreceiver | |
| org.apache.drill.exec.physical.impl.validate | |
| org.apache.drill.exec.physical.impl.xsort | |
| org.apache.drill.exec.record |
| Modifier and Type | Method and Description |
|---|---|
int |
VectorSerializer.Writer.write(WritableBatch batch,
SelectionVector2 sv2) |
| Constructor and Description |
|---|
CachedVectorContainer(WritableBatch batch,
BufferAllocator allocator) |
VectorAccessibleSerializable(WritableBatch batch,
BufferAllocator allocator) |
VectorAccessibleSerializable(WritableBatch batch,
SelectionVector2 sv2,
BufferAllocator allocator)
Creates a wrapper around batch and sv2 for writing to a stream.
|
| Modifier and Type | Method and Description |
|---|---|
WritableBatch |
MockRecordBatch.getWritableBatch() |
WritableBatch |
ScanBatch.getWritableBatch() |
| Modifier and Type | Method and Description |
|---|---|
WritableBatch |
SpilledRecordBatch.getWritableBatch() |
| Modifier and Type | Method and Description |
|---|---|
WritableBatch |
PartitionerTemplate.OutgoingRecordBatch.getWritableBatch() |
| Modifier and Type | Method and Description |
|---|---|
WritableBatch |
OperatorRecordBatch.getWritableBatch() |
WritableBatch |
BatchAccessor.writableBatch() |
WritableBatch |
VectorContainerAccessor.writableBatch() |
| Modifier and Type | Method and Description |
|---|---|
WritableBatch |
SortBatch.getWritableBatch() |
| Modifier and Type | Method and Description |
|---|---|
WritableBatch |
RemovingRecordBatch.getWritableBatch() |
| Modifier and Type | Method and Description |
|---|---|
WritableBatch |
TopNBatch.getWritableBatch() |
| Modifier and Type | Method and Description |
|---|---|
WritableBatch |
MockLateralJoinBatch.getWritableBatch() |
| Modifier and Type | Method and Description |
|---|---|
WritableBatch |
UnorderedReceiverBatch.getWritableBatch() |
| Modifier and Type | Method and Description |
|---|---|
WritableBatch |
IteratorValidatorBatchIterator.getWritableBatch() |
| Modifier and Type | Method and Description |
|---|---|
WritableBatch |
ExternalSortBatch.getWritableBatch() |
| Modifier and Type | Method and Description |
|---|---|
static WritableBatch |
WritableBatch.get(VectorAccessible batch) |
static WritableBatch |
WritableBatch.getBatchNoHV(int recordCount,
Iterable<ValueVector> vectors,
boolean isSV2) |
static WritableBatch |
WritableBatch.getBatchNoHVWrap(int recordCount,
Iterable<VectorWrapper<?>> vws,
boolean isSV2) |
WritableBatch |
SchemalessBatch.getWritableBatch() |
WritableBatch |
RecordBatch.getWritableBatch()
Gets a writable version of this batch.
|
WritableBatch |
SimpleRecordBatch.getWritableBatch() |
WritableBatch |
RecordBatchLoader.getWritableBatch() |
WritableBatch |
AbstractRecordBatch.getWritableBatch() |
WritableBatch |
WritableBatch.transfer(BufferAllocator allocator) |
| Constructor and Description |
|---|
FragmentWritableBatch(boolean isLast,
UserBitShared.QueryId queryId,
int sendMajorFragmentId,
int sendMinorFragmentId,
int receiveMajorFragmentId,
int[] receiveMinorFragmentIds,
WritableBatch batch) |
FragmentWritableBatch(boolean isLast,
UserBitShared.QueryId queryId,
int sendMajorFragmentId,
int sendMinorFragmentId,
int receiveMajorFragmentId,
int receiveMinorFragmentId,
WritableBatch batch) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.