public class QuantileSqlAggregator extends Object implements SqlAggregator
Constructor and Description |
---|
QuantileSqlAggregator() |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.sql.SqlAggFunction |
calciteFunction()
Returns the SQL operator corresponding to this aggregation function.
|
Aggregation |
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 . |
public org.apache.calcite.sql.SqlAggFunction calciteFunction()
SqlAggregator
calciteFunction
in interface SqlAggregator
public Aggregation 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)
SqlAggregator
AggregateCall
. This method should ignore filters;
they will be applied to your aggregator in a later step.toDruidAggregation
in interface SqlAggregator
plannerContext
- SQL planner contextrowSignature
- signature of the rows being aggregatedrexBuilder
- a rexBuilder, in case you need onename
- desired output name of the aggregationaggregateCall
- aggregate call objectproject
- project that should be applied before aggregation; may be nullexistingAggregations
- existing aggregations for this query; useful for re-using aggregations. May be safely
ignored if you do not want to re-use existing aggregations.Copyright © 2011–2018. All rights reserved.