io.druid.query.aggregation.histogram.sql

Class QuantileSqlAggregator

java.lang.Object

io.druid.query.aggregation.histogram.sql.QuantileSqlAggregator

All Implemented Interfaces:

SqlAggregator

public class QuantileSqlAggregator
extends Object
implements SqlAggregator

Constructor Summary

Constructors

Constructor and Description
QuantileSqlAggregator()

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.sql.SqlAggFunction	calciteFunction() Returns the SQL operator corresponding to this aggregation function.
Aggregation	toDruidAggregation(String name, RowSignature rowSignature, PlannerContext plannerContext, List<Aggregation> existingAggregations, org.apache.calcite.rel.core.Project project, org.apache.calcite.rel.core.AggregateCall aggregateCall, DimFilter filter) Returns Druid Aggregation corresponding to a SQL AggregateCall.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QuantileSqlAggregator

public QuantileSqlAggregator()

Method Detail

calciteFunction

public org.apache.calcite.sql.SqlAggFunction calciteFunction()

Description copied from interface: SqlAggregator

Returns the SQL operator corresponding to this aggregation function. Should be a singleton.

Specified by:

calciteFunction in interface SqlAggregator

Returns:

operator

toDruidAggregation

public Aggregation toDruidAggregation(String name,
                                      RowSignature rowSignature,
                                      PlannerContext plannerContext,
                                      List<Aggregation> existingAggregations,
                                      org.apache.calcite.rel.core.Project project,
                                      org.apache.calcite.rel.core.AggregateCall aggregateCall,
                                      DimFilter filter)

Description copied from interface: SqlAggregator

Returns Druid Aggregation corresponding to a SQL AggregateCall.

Specified by:

toDruidAggregation in interface SqlAggregator

Parameters:

name - desired output name of the aggregation

rowSignature - signature of the rows being aggregated

plannerContext - SQL planner context

existingAggregations - existing aggregations for this query; useful for re-using aggregations. May be safely ignored if you do not want to re-use existing aggregations.

project - SQL projection to apply before the aggregate call, may be null

aggregateCall - SQL aggregate call

filter - filter that should be applied to the aggregation, may be null

Returns:

aggregation, or null if the call cannot be translated