Modifier and Type | Class and Description |
---|---|
class |
Graph<G extends GraphValue<G>,R extends G,T extends G> |
static class |
GraphAlgos.Tarjan<V extends GraphValue<V>> |
static class |
GraphAlgos.TopoSorter<V extends GraphValue<V>> |
Modifier and Type | Method and Description |
---|---|
static <V extends GraphValue<V>> |
GraphAlgos.checkDirected(Graph<V,?,?> graph) |
static <G extends GraphValue<G>,R extends G,T extends G> |
Graph.newGraph(List<G> operators,
Class<R> root,
Class<T> leaf) |
static <V extends GraphValue<V>> |
GraphAlgos.TopoSorter.sort(Graph<V,?,?> graph) |
static <V extends GraphValue<V>> |
GraphAlgos.TopoSorter.sortLogical(Graph<V,?,?> graph) |
Modifier and Type | Interface and Description |
---|---|
interface |
LogicalOperator |
Modifier and Type | Class and Description |
---|---|
class |
Analyze |
class |
Filter |
class |
Flatten |
class |
GroupingAggregate |
class |
Join |
class |
LateralJoin |
class |
Limit |
class |
LogicalOperatorBase |
class |
LogicalSemiJoin |
class |
MetadataAggregate
Implementation of
LogicalOperator for MetadataAggRel rel node. |
class |
MetadataController
Implementation of
LogicalOperator for MetadataControllerRel rel node. |
class |
MetadataHandler
Implementation of
LogicalOperator for MetadataHandlerRel rel node. |
class |
Order |
class |
Project |
class |
RunningAggregate |
class |
Scan |
class |
SingleInputOperator
SimpleOperator is an operator that has one inputs at most.
|
class |
SinkOperator
An operator that cannot be subscribed to.
|
class |
SourceOperator
An operator that produces data without any parents.
|
class |
Store |
class |
Transform |
class |
Union |
class |
Unnest |
class |
Values |
class |
Window |
class |
Writer |
Modifier and Type | Interface and Description |
---|---|
interface |
DbGroupScan
A DbGroupScan operator represents the scan associated with a database.
|
interface |
DbSubScan |
interface |
Exchange |
interface |
FileGroupScan
FileGroupScan operator represents all data which will be scanned from FileSystem by a given physical plan.
|
interface |
FragmentLeaf
A Physical Operator that can be the leaf node of one particular execution
fragment.
|
interface |
FragmentRoot
Describes the root operation within a particular Fragment.
|
interface |
GroupScan
A GroupScan operator represents all data which will be scanned by a given physical
plan.
|
interface |
HasAffinity
Describes a physical operator that has affinity to particular nodes.
|
interface |
IndexGroupScan
An IndexGroupScan operator represents the scan associated with an Index.
|
interface |
Leaf
Operator which specifically is a lowest level leaf node of a query plan
across all possible fragments.
|
interface |
PhysicalOperator |
interface |
Receiver
A receiver is one half of an exchange operator.
|
interface |
Root
Marker interface describe the root of a query plan.
|
interface |
Scan |
interface |
Sender
A sender is one half of an exchange node operations.
|
interface |
Store
An interface which supports storing a record stream.
|
interface |
SubScan
A SubScan operator represents the data scanned by a particular major/minor
fragment.
|
interface |
Writer
Writer physical operator
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractBase |
class |
AbstractDbGroupScan |
class |
AbstractDbSubScan |
class |
AbstractExchange |
class |
AbstractFileGroupScan |
class |
AbstractGroupScan |
class |
AbstractGroupScanWithMetadata<P extends TableMetadataProvider>
Represents table group scan with metadata usage.
|
class |
AbstractJoinPop |
class |
AbstractMultiple
Describes an operator that expects more than one children operators as its input.
|
class |
AbstractReceiver |
class |
AbstractSender |
class |
AbstractSingle
Describes an operator that expects a single child operator as its input.
|
class |
AbstractStore |
class |
AbstractSubScan |
class |
AbstractWriter |
class |
SchemalessScan
The type of scan operator, which allows to scan schemaless tables (
DynamicDrillTable with null selection) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDeMuxExchange
DeMuxExchange is opposite of MuxExchange.
|
class |
AbstractMuxExchange
Multiplexing Exchange (MuxExchange) is used when results from multiple minor fragments belonging to the same
major fragment running on a node need to be collected at one fragment on the same node before distributing the
results further.
|
class |
BroadcastExchange |
class |
BroadcastSender |
class |
ComplexToJson |
class |
ExternalSort |
class |
FlattenPOP |
class |
HashAggregate |
class |
HashJoinPOP |
class |
HashPartitionSender |
class |
HashToMergeExchange |
class |
HashToRandomExchange |
class |
IteratorValidator |
class |
LateralJoinPOP |
class |
MergeJoinPOP |
class |
MergingReceiverPOP |
class |
MetadataControllerPOP |
class |
MetadataHandlerPOP |
class |
MetadataHashAggPOP |
class |
MetadataStreamAggPOP |
class |
NestedLoopJoinPOP |
class |
OrderedMuxExchange
OrderedMuxExchange is a version of MuxExchange where the incoming batches are sorted
merge operation is performed to produced a sorted stream as output.
|
class |
OrderedPartitionExchange |
class |
OrderedPartitionSender |
class |
PartitionLimit |
class |
ProducerConsumer |
class |
RangePartitionExchange |
class |
RangePartitionSender |
class |
RowKeyJoinPOP |
class |
RuntimeFilterPOP |
class |
Screen |
class |
SelectionVectorRemover |
class |
SingleMergeExchange |
class |
SingleSender
Sender that pushes all data to a single destination node.
|
class |
Sort |
class |
StatisticsAggregate |
class |
StatisticsMerge |
class |
StreamingAggregate |
class |
TopN |
class |
Trace |
class |
UnionAll |
class |
UnionExchange |
class |
UnnestPOP |
class |
UnorderedDeMuxExchange
UnorderedDeMuxExchange is a version of DeMuxExchange where the incoming batches are not sorted.
|
class |
UnorderedMuxExchange
UnorderedMuxExchange is a version of MuxExchange where the incoming batches are not sorted.
|
class |
UnorderedReceiver |
class |
UnpivotMaps |
class |
WindowPOP |
Modifier and Type | Class and Description |
---|---|
class |
EasyGroupScan |
class |
EasySubScan |
class |
EasyWriter |
Modifier and Type | Class and Description |
---|---|
class |
DirectGroupScan |
class |
DirectSubScan |
class |
MetadataDirectGroupScan
Represents direct scan based on metadata information.
|
Modifier and Type | Class and Description |
---|---|
class |
DruidGroupScan |
class |
DruidSubScan
A Class containing information to read a single druid data source.
|
Modifier and Type | Class and Description |
---|---|
class |
EnumerableGroupScan |
class |
EnumerableSubScan |
Modifier and Type | Class and Description |
---|---|
class |
HBaseGroupScan |
class |
HBaseSubScan
Information for reading a single HBase region
|
Modifier and Type | Class and Description |
---|---|
class |
HiveDrillNativeParquetRowGroupScan |
class |
HiveDrillNativeParquetScan |
class |
HiveScan |
class |
HiveSubScan |
Modifier and Type | Class and Description |
---|---|
class |
HttpGroupScan |
class |
HttpSubScan |
Modifier and Type | Class and Description |
---|---|
class |
IcebergGroupScan |
class |
IcebergSubScan |
Modifier and Type | Class and Description |
---|---|
class |
InfoSchemaGroupScan |
class |
InfoSchemaSubScan |
Modifier and Type | Class and Description |
---|---|
class |
JdbcGroupScan |
class |
JdbcSubScan |
class |
JdbcWriter |
Modifier and Type | Class and Description |
---|---|
class |
KafkaGroupScan |
class |
KafkaSubScan |
Modifier and Type | Class and Description |
---|---|
class |
KuduGroupScan |
class |
KuduSubScan
Information for reading a single Kudu tablet
|
class |
KuduWriter |
Modifier and Type | Class and Description |
---|---|
class |
MapRDBGroupScan |
class |
MapRDBSubScan |
class |
RestrictedMapRDBSubScan
A RestrictedMapRDBSubScan is intended for skip-scan (as opposed to sequential scan) operations
where the set of rowkeys is obtained from a corresponding RowKeyJoin instance
|
Modifier and Type | Class and Description |
---|---|
class |
BinaryTableGroupScan |
Modifier and Type | Class and Description |
---|---|
class |
JsonTableGroupScan |
class |
RestrictedJsonTableGroupScan
A RestrictedJsonTableGroupScan encapsulates (along with a subscan) the functionality
for doing restricted (i.e skip) scan rather than sequential scan.
|
Modifier and Type | Class and Description |
---|---|
class |
MockGroupScanPOP
Describes a "group" scan of a (logical) mock table.
|
class |
MockStorePOP |
class |
MockSubScanPOP
Describes a physical scan operation for the mock data source.
|
Modifier and Type | Class and Description |
---|---|
class |
MongoGroupScan |
class |
MongoSubScan |
Modifier and Type | Class and Description |
---|---|
class |
OpenTSDBGroupScan |
class |
OpenTSDBSubScan |
Modifier and Type | Class and Description |
---|---|
class |
AbstractParquetGroupScan |
class |
AbstractParquetRowGroupScan |
class |
ParquetGroupScan |
class |
ParquetRowGroupScan |
class |
ParquetWriter |
Modifier and Type | Class and Description |
---|---|
class |
PhoenixGroupScan |
class |
PhoenixSubScan |
Modifier and Type | Class and Description |
---|---|
class |
SplunkGroupScan |
class |
SplunkSubScan |
Modifier and Type | Class and Description |
---|---|
class |
SystemTableScan |
Copyright © 1970 The Apache Software Foundation. All rights reserved.