Package | Description |
---|---|
io.druid.query.aggregation.histogram.sql | |
io.druid.sql.calcite.aggregation | |
io.druid.sql.calcite.aggregation.builtin | |
io.druid.sql.calcite.rel | |
io.druid.sql.calcite.rule |
Modifier and Type | Method and Description |
---|---|
Aggregation |
QuantileSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Modifier and Type | Method and Description |
---|---|
Aggregation |
QuantileSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Modifier and Type | Method and Description |
---|---|
static Aggregation |
Aggregation.create(AggregatorFactory aggregatorFactory) |
static Aggregation |
Aggregation.create(List<AggregatorFactory> aggregatorFactories,
PostAggregator postAggregator) |
static Aggregation |
Aggregation.create(List<VirtualColumn> virtualColumns,
AggregatorFactory aggregatorFactory) |
static Aggregation |
Aggregation.create(List<VirtualColumn> virtualColumns,
List<AggregatorFactory> aggregatorFactories,
PostAggregator postAggregator) |
static Aggregation |
Aggregation.create(PostAggregator postAggregator) |
Aggregation |
Aggregation.filter(RowSignature sourceRowSignature,
DimFilter filter) |
Aggregation |
SqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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)
Returns a Druid Aggregation corresponding to a SQL
AggregateCall . |
Modifier and Type | Method and Description |
---|---|
Aggregation |
SqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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)
Returns a Druid Aggregation corresponding to a SQL
AggregateCall . |
Modifier and Type | Method and Description |
---|---|
Aggregation |
SumSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Aggregation |
MinSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Aggregation |
MaxSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Aggregation |
CountSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Aggregation |
AvgSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Aggregation |
ApproxCountDistinctSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Modifier and Type | Method and Description |
---|---|
Aggregation |
SumSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Aggregation |
MinSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Aggregation |
MaxSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Aggregation |
CountSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Aggregation |
AvgSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Aggregation |
ApproxCountDistinctSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
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) |
Modifier and Type | Method and Description |
---|---|
List<Aggregation> |
Grouping.getAggregations() |
Modifier and Type | Method and Description |
---|---|
static Grouping |
Grouping.create(List<DimensionExpression> dimensions,
List<Aggregation> aggregations,
DimFilter havingFilter,
RowSignature outputRowSignature) |
Modifier and Type | Method and Description |
---|---|
static Aggregation |
GroupByRules.translateAggregateCall(PlannerContext plannerContext,
RowSignature sourceRowSignature,
org.apache.calcite.rex.RexBuilder rexBuilder,
org.apache.calcite.rel.core.Project project,
org.apache.calcite.rel.core.AggregateCall call,
List<Aggregation> existingAggregations,
String name)
Translate an AggregateCall to Druid equivalents.
|
Modifier and Type | Method and Description |
---|---|
static Aggregation |
GroupByRules.translateAggregateCall(PlannerContext plannerContext,
RowSignature sourceRowSignature,
org.apache.calcite.rex.RexBuilder rexBuilder,
org.apache.calcite.rel.core.Project project,
org.apache.calcite.rel.core.AggregateCall call,
List<Aggregation> existingAggregations,
String name)
Translate an AggregateCall to Druid equivalents.
|
Copyright © 2011–2018. All rights reserved.