| Modifier and Type | Method and Description |
|---|---|
boolean |
AnalyzeParquetInfoProvider.supportsGroupScan(GroupScan groupScan) |
boolean |
AnalyzeFileInfoProviderImpl.supportsGroupScan(GroupScan groupScan) |
boolean |
AnalyzeInfoProvider.supportsGroupScan(GroupScan groupScan)
Checks whether this
AnalyzeInfoProvider supports specified GroupScan type. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
DbGroupScan
A DbGroupScan operator represents the scan associated with a database.
|
interface |
FileGroupScan
FileGroupScan operator represents all data which will be scanned from FileSystem by a given physical plan.
|
interface |
IndexGroupScan
An IndexGroupScan operator represents the scan associated with an Index.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractDbGroupScan |
class |
AbstractFileGroupScan |
class |
AbstractGroupScan |
class |
AbstractGroupScanWithMetadata<P extends TableMetadataProvider>
Represents table group scan with metadata usage.
|
class |
SchemalessScan
The type of scan operator, which allows to scan schemaless tables (
DynamicDrillTable with null selection) |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
AbstractGroupScan.applyFilter(LogicalExpression filterExpr,
UdfUtilities udfUtilities,
FunctionImplementationRegistry functionImplementationRegistry,
OptionManager optionManager) |
GroupScan |
GroupScan.applyFilter(LogicalExpression filterExpr,
UdfUtilities udfUtilities,
FunctionImplementationRegistry functionImplementationRegistry,
OptionManager optionManager) |
GroupScan |
AbstractGroupScan.applyLimit(int maxRecords)
By default, return null to indicate row count based prune is not supported.
|
GroupScan |
AbstractGroupScanWithMetadata.applyLimit(int maxRecords) |
GroupScan |
GroupScan.applyLimit(int maxRecords)
Apply rowcount based prune for "LIMIT n" query.
|
GroupScan |
SchemalessScan.clone(List<SchemaPath> columns) |
GroupScan |
AbstractGroupScan.clone(List<SchemaPath> columns) |
GroupScan |
GroupScan.clone(List<SchemaPath> columns)
Returns a clone of GroupScan instance, except that the new GroupScan will use the provided list of columns .
|
| Modifier and Type | Method and Description |
|---|---|
RETURN |
PhysicalVisitor.visitGroupScan(GroupScan groupScan,
EXTRA value) |
T |
AbstractPhysicalVisitor.visitGroupScan(GroupScan groupScan,
X value) |
| Modifier and Type | Field and Description |
|---|---|
protected GroupScan |
DrillScanRelBase.groupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
DrillScanRelBase.getGroupScan() |
| Modifier and Type | Method and Description |
|---|---|
abstract DrillScanRelBase |
DrillScanRelBase.copy(org.apache.calcite.plan.RelTraitSet traitSet,
GroupScan scan) |
| Constructor and Description |
|---|
DrillScanRelBase(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traits,
GroupScan grpScan,
org.apache.calcite.plan.RelOptTable table) |
| Modifier and Type | Method and Description |
|---|---|
int |
PluginCost.getAverageColumnSize(GroupScan scan) |
int |
PluginCost.getBlockSize(GroupScan scan) |
int |
PluginCost.getRandomBlockReadCost(GroupScan scan) |
int |
PluginCost.getSequentialBlockReadCost(GroupScan scan) |
| Modifier and Type | Method and Description |
|---|---|
PhysicalOperator |
Materializer.visitGroupScan(GroupScan groupScan,
Materializer.IndexedFragmentNode iNode) |
Void |
StatsCollector.visitGroupScan(GroupScan groupScan,
Wrapper wrapper) |
| Modifier and Type | Method and Description |
|---|---|
PhysicalOperator |
ExchangeRemoverMaterializer.visitGroupScan(GroupScan groupScan,
Materializer.IndexedFragmentNode iNode) |
| Modifier and Type | Method and Description |
|---|---|
static GroupScan |
IndexPlanUtils.getGroupScan(DrillScanRelBase relNode) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.calcite.plan.RelOptCost |
MapRDBIndexDescriptor.getCost(IndexProperties indexProps,
org.apache.calcite.plan.RelOptPlanner planner,
int numProjectedFields,
GroupScan primaryTableGroupScan) |
org.apache.calcite.plan.RelOptCost |
AbstractIndexDescriptor.getCost(IndexProperties indexProps,
org.apache.calcite.plan.RelOptPlanner planner,
int numProjectedFields,
GroupScan primaryGroupScan) |
org.apache.calcite.plan.RelOptCost |
IndexDescriptor.getCost(IndexProperties indexProps,
org.apache.calcite.plan.RelOptPlanner planner,
int numProjectedFields,
GroupScan primaryGroupScan)
Get the total cost of index access (I/O, CPU) in the context of the current query
|
static IndexDiscover |
IndexDiscoverFactory.getIndexDiscover(StoragePluginConfig config,
GroupScan inScan,
org.apache.calcite.rel.RelNode scanRel,
Class<? extends IndexDiscover> targetIndexDiscoverClass) |
static boolean |
IndexPlanUtils.scanIsPartition(GroupScan scan) |
| Constructor and Description |
|---|
MapRDBIndexDiscover(GroupScan inScan,
DrillScanRelBase scanRel) |
MapRDBIndexDiscover(GroupScan inScan,
ScanPrel scanRel) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
AbstractMatchFunction.checkScan(GroupScan groupScan) |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
DrillTable.getGroupScan() |
| Modifier and Type | Method and Description |
|---|---|
DrillScanRel |
DrillScanRel.copy(org.apache.calcite.plan.RelTraitSet traitSet,
GroupScan scan) |
void |
DrillTable.setGroupScan(GroupScan scan) |
| Constructor and Description |
|---|
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traits,
org.apache.calcite.plan.RelOptTable table,
GroupScan groupScan,
org.apache.calcite.rel.type.RelDataType rowType,
List<SchemaPath> columns)
Creates a DrillScanRel for a particular GroupScan
|
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traits,
org.apache.calcite.plan.RelOptTable table,
GroupScan groupScan,
org.apache.calcite.rel.type.RelDataType rowType,
List<SchemaPath> columns,
boolean partitionFilterPushdown)
Creates a DrillScanRel for a particular GroupScan
|
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
DrillScanPrel.getGroupScan() |
GroupScan |
DirectScanPrel.getGroupScan() |
| Modifier and Type | Method and Description |
|---|---|
ScanPrel |
ScanPrel.copy(org.apache.calcite.plan.RelTraitSet traitSet,
GroupScan scan) |
static DirectScanPrel |
DirectScanPrel.create(org.apache.calcite.rel.RelNode old,
org.apache.calcite.plan.RelTraitSet traitSets,
GroupScan scan,
org.apache.calcite.rel.type.RelDataType rowType) |
| Constructor and Description |
|---|
ScanPrel(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traits,
GroupScan groupScan,
org.apache.calcite.rel.type.RelDataType rowType,
org.apache.calcite.plan.RelOptTable table) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.calcite.util.Pair<GroupScan,List<org.apache.calcite.rex.RexNode>> |
FilterPushDownListener.ScanPushDownListener.transform(ExprNode.AndNode expr)
Transform a normalized DNF term into a new scan.
|
| Modifier and Type | Method and Description |
|---|---|
FilterPushDownListener.ScanPushDownListener |
FilterPushDownListener.builderFor(GroupScan groupScan)
Check if the filter rule should be applied to the target group scan,
and if so, return the builder to use.
|
boolean |
FilterPushDownListener.isTargetScan(GroupScan groupScan)
Broad check to see if the scan is of the correct type for this
listener.
|
| Modifier and Type | Class and Description |
|---|---|
class |
EasyGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
EasyGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
DirectGroupScan |
class |
MetadataDirectGroupScan
Represents direct scan based on metadata information.
|
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
MetadataDirectGroupScan.clone(List<SchemaPath> columns) |
GroupScan |
DirectGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
DruidGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
DruidGroupScan.applyLimit(int maxRecords) |
GroupScan |
DruidGroupScan.clone(int maxRecordsToRead) |
GroupScan |
DruidGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
EnumerableGroupScan |
| Modifier and Type | Class and Description |
|---|---|
class |
HBaseGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
HBaseGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
HiveDrillNativeParquetScan |
class |
HiveScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
HiveDrillNativeParquetScan.clone(List<SchemaPath> columns) |
GroupScan |
HiveScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
HttpGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
HttpGroupScan.applyLimit(int maxRecords) |
GroupScan |
HttpGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Method and Description |
|---|---|
FilterPushDownListener.ScanPushDownListener |
HttpPushDownListener.builderFor(GroupScan groupScan) |
boolean |
HttpPushDownListener.isTargetScan(GroupScan groupScan) |
| Modifier and Type | Class and Description |
|---|---|
class |
InfoSchemaGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
InfoSchemaGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
JdbcGroupScan |
| Modifier and Type | Class and Description |
|---|---|
class |
KafkaGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
KafkaGroupScan.clone(List<SchemaPath> columns) |
GroupScan |
KafkaGroupScan.cloneWithNewSpec(List<KafkaPartitionScanSpec> partitionScanSpecList) |
| Modifier and Type | Class and Description |
|---|---|
class |
KuduGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
KuduGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
MapRDBGroupScan |
| Modifier and Type | Method and Description |
|---|---|
protected void |
MapRDBPushLimitIntoScan.doPushLimitIntoGroupScan(org.apache.calcite.plan.RelOptRuleCall call,
LimitPrel limit,
ProjectPrel project,
ScanPrel scan,
GroupScan groupScan) |
int |
MapRDBCost.getAverageColumnSize(GroupScan scan) |
int |
MapRDBCost.getBlockSize(GroupScan scan) |
int |
MapRDBCost.getRandomBlockReadCost(GroupScan scan) |
int |
MapRDBCost.getSequentialBlockReadCost(GroupScan scan) |
| Modifier and Type | Class and Description |
|---|---|
class |
BinaryTableGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
BinaryTableGroupScan.clone(List<SchemaPath> columns) |
| 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 | Method and Description |
|---|---|
GroupScan |
JsonTableGroupScan.applyLimit(int maxRecords) |
GroupScan |
RestrictedJsonTableGroupScan.clone(JsonScanSpec scanSpec) |
GroupScan |
JsonTableGroupScan.clone(JsonScanSpec scanSpec) |
GroupScan |
RestrictedJsonTableGroupScan.clone(List<SchemaPath> columns) |
GroupScan |
JsonTableGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
MockGroupScanPOP
Describes a "group" scan of a (logical) mock table.
|
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
MockGroupScanPOP.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
MongoGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
MongoGroupScan.applyLimit(int maxRecords) |
GroupScan |
MongoGroupScan.clone(int maxRecords) |
GroupScan |
MongoGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
OpenTSDBGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
OpenTSDBGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractParquetGroupScan |
class |
ParquetGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
AbstractParquetGroupScan.applyLimit(int maxRecords) |
GroupScan |
ParquetGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Class and Description |
|---|---|
class |
SplunkGroupScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
SplunkGroupScan.applyLimit(int maxRecords) |
GroupScan |
SplunkGroupScan.clone(List<SchemaPath> columns) |
| Modifier and Type | Method and Description |
|---|---|
FilterPushDownListener.ScanPushDownListener |
SplunkPushDownListener.builderFor(GroupScan groupScan) |
boolean |
SplunkPushDownListener.isTargetScan(GroupScan groupScan) |
| Modifier and Type | Class and Description |
|---|---|
class |
SystemTableScan |
| Modifier and Type | Method and Description |
|---|---|
GroupScan |
SystemTableScan.applyLimit(int maxRecords) |
GroupScan |
SystemTableScan.clone(List<SchemaPath> columns) |
GroupScan |
SystemTableScan.clone(SystemTableScan systemTableScan,
int maxRecordsToRead) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.