| Modifier and Type | Class and Description |
|---|---|
class |
StatisticsWriterRecordBatch |
class |
WriterRecordBatch
Write the RecordBatch to the given RecordWriter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HashAggBatch |
class |
StreamingAggBatch |
| Modifier and Type | Class and Description |
|---|---|
class |
FilterRecordBatch |
class |
RuntimeFilterRecordBatch
A RuntimeFilterRecordBatch steps over the ScanBatch.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FlattenRecordBatch |
| Modifier and Type | Class and Description |
|---|---|
class |
HashJoinBatch
Implements the runtime execution for the Hash-Join operator supporting INNER,
LEFT OUTER, RIGHT OUTER, and FULL OUTER joins
|
class |
LateralJoinBatch
RecordBatch implementation for the lateral join operator.
|
class |
MergeJoinBatch
A join operator that merges two sorted streams using a record iterator.
|
class |
NestedLoopJoinBatch |
class |
RowKeyJoinBatch |
| Modifier and Type | Class and Description |
|---|---|
class |
LimitRecordBatch |
class |
PartitionLimitRecordBatch
Helps to perform limit in a partition within a record batch.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MergingRecordBatch
Merges pre-sorted record batches from remote senders.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MetadataControllerBatch
Terminal operator for producing ANALYZE statement.
|
class |
MetadataHandlerBatch
Responsible for handling metadata returned by incoming aggregate operators
and fetching required metadata form the Metastore.
|
class |
MetadataHashAggBatch |
class |
MetadataStreamAggBatch
Operator which adds aggregate calls for all incoming columns to calculate
required metadata and produces aggregations.
|
| Modifier and Type | Class and Description |
|---|---|
class |
OrderedPartitionRecordBatch
Generates an ordered partition, rather than a random hash partition.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ProducerConsumerBatch |
| Modifier and Type | Class and Description |
|---|---|
class |
ProjectRecordBatch |
| Modifier and Type | Class and Description |
|---|---|
class |
RangePartitionRecordBatch
Provides the ability to divide up the input rows into a fixed number of
separate ranges or 'buckets' based on the values of a set of columns (the
range partitioning columns).
|
| Modifier and Type | Class and Description |
|---|---|
class |
SortBatch |
| Modifier and Type | Class and Description |
|---|---|
class |
StatisticsAggBatch |
class |
StatisticsMergeBatch
Example input and output:
Schema of incoming batch:
|
| Modifier and Type | Class and Description |
|---|---|
class |
RemovingRecordBatch |
| Modifier and Type | Class and Description |
|---|---|
class |
TopNBatch
Operator Batch which implements the TopN functionality.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TraceRecordBatch
Contains value vectors which are exactly the same
as the incoming record batch's value vectors.
|
| Modifier and Type | Class and Description |
|---|---|
class |
UnionAllRecordBatch |
| Modifier and Type | Class and Description |
|---|---|
class |
UnnestRecordBatch |
| Modifier and Type | Class and Description |
|---|---|
class |
UnpivotMapsRecordBatch
Unpivot maps.
|
| Modifier and Type | Class and Description |
|---|---|
class |
WindowFrameRecordBatch
support for OVER(PARTITION BY expression1,expression2,...
|
| Modifier and Type | Class and Description |
|---|---|
class |
ExternalSortBatch
External sort batch: a sort batch which can spill to disk in
order to operate within a defined memory footprint.
|
| Modifier and Type | Method and Description |
|---|---|
AbstractRecordBatch<ExternalSort> |
ExternalSortBatchCreator.getBatch(ExecutorFragmentContext context,
ExternalSort config,
List<RecordBatch> children) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractBinaryRecordBatch<T extends PhysicalOperator> |
class |
AbstractSingleRecordBatch<T extends PhysicalOperator>
Implements an AbstractUnaryRecordBatch where the incoming record batch is
known at the time of creation
|
class |
AbstractTableFunctionRecordBatch<T extends PhysicalOperator>
Implements AbstractUnaryRecodBatch for operators that do not have an incoming
record batch available at creation time; the input is typically set up a few
steps after creation.
|
class |
AbstractUnaryRecordBatch<T extends PhysicalOperator>
Base class for operators that have a single input.
|
| Constructor and Description |
|---|
RecordIterator(RecordBatch incoming,
AbstractRecordBatch<?> outgoing,
OperatorContext oContext,
int inputIndex,
boolean enableMarkAndReset,
RecordBatchMemoryManager callBack) |
RecordIterator(RecordBatch incoming,
AbstractRecordBatch<?> outgoing,
OperatorContext oContext,
int inputIndex,
RecordBatchMemoryManager callBack) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.