| Modifier and Type | Method and Description |
|---|---|
Aggregation |
Aggregation.filter(RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
DimFilter filter) |
Aggregation |
SqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations)
Returns a Druid Aggregation corresponding to a SQL
AggregateCall. |
Aggregation |
ApproxCountDistinctSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
| Modifier and Type | Method and Description |
|---|---|
Aggregation |
ArrayConcatSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
BuiltinApproxCountDistinctSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
EarliestLatestBySqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
MultiColumnSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
AvgSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
SimpleSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
ArraySqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
CountSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
GroupingSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
StringSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
EarliestLatestAnySqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
BitwiseSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
| Modifier and Type | Method and Description |
|---|---|
DimFilter |
AliasedOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
default DimFilter |
SqlOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode)
Returns a Druid filter corresponding to a Calcite
RexNode used as a filter condition. |
static DimFilter |
Expressions.toFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode expression)
Translates "condition" to a Druid filter, or returns null if we cannot translate the condition.
|
| Modifier and Type | Method and Description |
|---|---|
DimFilter |
LikeOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
DimFilter |
ContainsOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
DimFilter |
RegexpLikeOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
DimFilter |
ArrayContainsOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
DimFilter |
ArrayOverlapOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
| Modifier and Type | Method and Description |
|---|---|
VirtualColumnRegistry |
PlannerContext.getJoinExpressionVirtualColumnRegistry() |
| Modifier and Type | Method and Description |
|---|---|
void |
PlannerContext.setJoinExpressionVirtualColumnRegistry(VirtualColumnRegistry joinExpressionVirtualColumnRegistry) |
| Modifier and Type | Method and Description |
|---|---|
static VirtualColumnRegistry |
VirtualColumnRegistry.create(RowSignature rowSignature,
ExprMacroTable macroTable,
boolean forceExpressionVirtualColumns) |
| Modifier and Type | Method and Description |
|---|---|
DruidQuery |
PartialDruidQuery.build(DataSource dataSource,
RowSignature sourceRowSignature,
PlannerContext plannerContext,
org.apache.calcite.rex.RexBuilder rexBuilder,
boolean finalizeAggregations,
VirtualColumnRegistry virtualColumnRegistry) |
static DruidQuery |
DruidQuery.fromPartialQuery(PartialDruidQuery partialQuery,
DataSource dataSource,
RowSignature sourceRowSignature,
PlannerContext plannerContext,
org.apache.calcite.rex.RexBuilder rexBuilder,
boolean finalizeAggregations,
VirtualColumnRegistry virtualColumnRegistry) |
static Projection |
Projection.preAggregation(org.apache.calcite.rel.core.Project project,
PlannerContext plannerContext,
RowSignature inputRowSignature,
VirtualColumnRegistry virtualColumnRegistry) |
| Modifier and Type | Method and Description |
|---|---|
static Aggregation |
GroupByRules.translateAggregateCall(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
String name,
org.apache.calcite.rel.core.AggregateCall call,
boolean finalizeAggregations)
Translate an AggregateCall to Druid equivalents.
|
Copyright © 2011–2022 The Apache Software Foundation. All rights reserved.