Modifier and Type | Class and Description |
---|---|
class |
AbstractPhysicalVisitor<T,X,E extends Throwable> |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
AbstractExchange.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
AbstractJoinPop.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
AbstractReceiver.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
AbstractSender.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
AbstractStore.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
AbstractSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
AbstractWriter.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
AbstractGroupScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
PhysicalOperator.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value)
Provides capability to build a set of output based on traversing a query graph tree.
|
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
BroadcastSender.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
ComplexToJson.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
Filter.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
FlattenPOP.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
HashPartitionSender.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
IteratorValidator.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
LateralJoinPOP.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
Limit.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
MergingReceiverPOP.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
MetadataControllerPOP.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
MetadataHandlerPOP.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
OrderedPartitionSender.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
PartitionLimit.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
ProducerConsumer.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
Project.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
RangePartitionSender.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
RowKeyJoinPOP.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
RuntimeFilterPOP.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
Screen.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
SelectionVectorRemover.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
SingleSender.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
Sort.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
StatisticsAggregate.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
StatisticsMerge.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
StreamingAggregate.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
TopN.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
Trace.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
UnionAll.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
UnnestPOP.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
UnorderedReceiver.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
UnpivotMaps.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
WindowPOP.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
HashAggregate.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
<T,X,E extends Throwable> |
Values.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Class and Description |
---|---|
class |
TraceInjector |
Modifier and Type | Class and Description |
---|---|
class |
IteratorValidatorInjector |
Modifier and Type | Class and Description |
---|---|
class |
AbstractOpWrapperVisitor<RET,EXCEP extends Throwable> |
Modifier and Type | Class and Description |
---|---|
protected static class |
Fragment.BufferedOpFinder |
class |
MakeFragmentsVisitor
Responsible for breaking a plan into its constituent Fragments.
|
class |
Materializer |
class |
MemoryCalculator
A visitor to compute memory requirements for each operator in a minor fragment.
|
protected static class |
SimpleParallelizer.CountRequiredFragments
Designed to setup initial values for arriving fragment accounting.
|
class |
StatsCollector
Visitor to collect stats such as cost and parallelization info of operators within a fragment.
|
Modifier and Type | Class and Description |
---|---|
class |
ExchangeRemoverMaterializer
Materializer visitor to remove exchange(s)
NOTE: this Visitor does NOT set OperatorId, as after Exchange removal all operators need renumbering
Use OperatorIdVisitor on top to set correct OperatorId
|
class |
OperatorIdVisitor
Visitor to renumber operators - needed after materialization is done as some operators may be removed
using @ExtendedMaterializerVisitor
|
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
DruidSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
HBaseSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
HiveSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
HttpSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
IcebergSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
KafkaSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
KuduSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
MapRDBSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
MockSubScanPOP.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
MongoSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
OpenTSDBSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
AbstractParquetRowGroupScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
PhoenixSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Method and Description |
---|---|
<T,X,E extends Throwable> |
SplunkSubScan.accept(PhysicalVisitor<T,X,E> physicalVisitor,
X value) |
Modifier and Type | Class and Description |
---|---|
protected class |
RuntimeFilterRouter.RuntimeFilterParallelismCollector
Collect the runtime filter parallelism related information such as join node major/minor fragment id , probe side scan node's
major/minor fragment id, probe side node's endpoints.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
ThrottledResourceManager.QueuedResourceAllocator.BufferedOpFinder
Searches a fragment operator tree to find buffered within that fragment.
|
Copyright © 1970 The Apache Software Foundation. All rights reserved.