| 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 | 
Aggregation.filter(RowSignature sourceRowSignature,
      DimFilter filter)  | 
static List<DruidExpression> | 
Aggregations.getArgumentsForSimpleAggregator(PlannerContext plannerContext,
                               RowSignature rowSignature,
                               org.apache.calcite.rel.core.AggregateCall call,
                               org.apache.calcite.rel.core.Project project)  | 
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 | 
|---|---|
static DruidExpression | 
OperatorConversions.convertCall(PlannerContext plannerContext,
           RowSignature rowSignature,
           org.apache.calcite.rex.RexNode rexNode,
           Function<List<DruidExpression>,DruidExpression> expressionFunction)  | 
static DruidExpression | 
OperatorConversions.convertCall(PlannerContext plannerContext,
           RowSignature rowSignature,
           org.apache.calcite.rex.RexNode rexNode,
           String functionName)  | 
static DruidExpression | 
OperatorConversions.convertCall(PlannerContext plannerContext,
           RowSignature rowSignature,
           org.apache.calcite.rex.RexNode rexNode,
           String functionName,
           Function<List<DruidExpression>,SimpleExtraction> simpleExtractionFunction)  | 
static org.apache.calcite.rex.RexNode | 
Expressions.fromFieldAccess(RowSignature rowSignature,
               org.apache.calcite.rel.core.Project project,
               int fieldNumber)
Translate a field access, possibly through a projection, to an underlying Druid dataSource. 
 | 
DruidExpression | 
UnarySuffixOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
UnaryPrefixOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
SqlOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)
Translate a Calcite  
RexNode to a Druid expression. | 
static DruidExpression | 
Expressions.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)
Translate a Calcite  
RexNode to a Druid expressions. | 
DruidExpression | 
DirectOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
BinaryOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
AliasedOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
static List<DruidExpression> | 
Expressions.toDruidExpressions(PlannerContext plannerContext,
                  RowSignature rowSignature,
                  List<org.apache.calcite.rex.RexNode> rexNodes)
Translate a list of Calcite  
RexNode to Druid expressions. | 
static DimFilter | 
Expressions.toFilter(PlannerContext plannerContext,
        RowSignature rowSignature,
        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 | 
|---|---|
DruidExpression | 
TruncateOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
TrimOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
TimestampToMillisOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
TimeShiftOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
TimeParseOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
TimeFormatOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
TimeFloorOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
TimeExtractOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
TimeArithmeticOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
SubstringOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
StrposOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
RegexpExtractOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
RTrimOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
MillisToTimestampOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
LookupOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
LTrimOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
FloorOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
ExtractOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
DateTruncOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
CeilOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
CastOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
DruidExpression | 
BTrimOperatorConversion.toDruidExpression(PlannerContext plannerContext,
                 RowSignature rowSignature,
                 org.apache.calcite.rex.RexNode rexNode)  | 
| Modifier and Type | Method and Description | 
|---|---|
static ConvertSelectorsToIns | 
ConvertSelectorsToIns.create(RowSignature sourceRowSignature)  | 
static ConvertBoundsToSelectors | 
ConvertBoundsToSelectors.create(RowSignature sourceRowSignature)  | 
Filtration | 
Filtration.optimize(RowSignature sourceRowSignature)
Optimize a Filtration for querying, possibly pulling out intervals and simplifying the dimFilter in the process. 
 | 
Filtration | 
Filtration.optimizeFilterOnly(RowSignature sourceRowSignature)
Optimize a Filtration containing only a DimFilter, avoiding pulling out intervals. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
RowSignature | 
SelectProjection.getOutputRowSignature()  | 
RowSignature | 
Grouping.getOutputRowSignature()  | 
RowSignature | 
DruidQuery.getOutputRowSignature()  | 
RowSignature | 
DruidQuery.getSourceRowSignature()  | 
| Modifier and Type | Method and Description | 
|---|---|
DruidQuery | 
PartialDruidQuery.build(DataSource dataSource,
     RowSignature sourceRowSignature,
     PlannerContext plannerContext,
     org.apache.calcite.rex.RexBuilder rexBuilder)  | 
static Grouping | 
Grouping.create(List<DimensionExpression> dimensions,
      List<Aggregation> aggregations,
      DimFilter havingFilter,
      RowSignature outputRowSignature)  | 
| Constructor and Description | 
|---|
DruidQuery(PartialDruidQuery partialQuery,
          DataSource dataSource,
          RowSignature sourceRowSignature,
          PlannerContext plannerContext,
          org.apache.calcite.rex.RexBuilder rexBuilder)  | 
SelectProjection(List<String> directColumns,
                List<VirtualColumn> virtualColumns,
                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 | 
|---|---|
RowSignature | 
RowSignature.Builder.build()  | 
static RowSignature | 
RowSignature.from(List<String> rowOrder,
    org.apache.calcite.rel.type.RelDataType rowType)  | 
RowSignature | 
DruidTable.getRowSignature()  | 
| Constructor and Description | 
|---|
DruidTable(DataSource dataSource,
          RowSignature rowSignature)  | 
Copyright © 2011–2018. All rights reserved.