| 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 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)  | 
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 PlannerContext | 
PlannerContext.create(DruidOperatorTable operatorTable,
      ExprMacroTable macroTable,
      PlannerConfig plannerConfig,
      AuthorizerMapper authorizerMapper,
      Map<String,Object> queryContext)  | 
PlannerContext | 
DruidPlanner.getPlannerContext()  | 
| Modifier and Type | Method and Description | 
|---|---|
static List<org.apache.calcite.tools.Program> | 
Rules.programs(PlannerContext plannerContext,
        QueryMaker queryMaker)  | 
| Constructor and Description | 
|---|
DruidConvertletTable(PlannerContext plannerContext)  | 
DruidPlanner(org.apache.calcite.tools.Planner planner,
            PlannerContext plannerContext,
            AuthorizerMapper authorizerMapper,
            Escalator escalator)  | 
DruidRexExecutor(PlannerContext plannerContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
PlannerContext | 
QueryMaker.getPlannerContext()  | 
PlannerContext | 
DruidRel.getPlannerContext()  | 
| Modifier and Type | Method and Description | 
|---|---|
DruidQuery | 
PartialDruidQuery.build(DataSource dataSource,
     RowSignature sourceRowSignature,
     PlannerContext plannerContext,
     org.apache.calcite.rex.RexBuilder rexBuilder)  | 
static DruidSemiJoin | 
DruidSemiJoin.create(DruidRel left,
      DruidRel right,
      List<Integer> leftKeys,
      List<Integer> rightKeys,
      PlannerContext plannerContext)  | 
| Constructor and Description | 
|---|
DruidQuery(PartialDruidQuery partialQuery,
          DataSource dataSource,
          RowSignature sourceRowSignature,
          PlannerContext plannerContext,
          org.apache.calcite.rex.RexBuilder rexBuilder)  | 
QueryMaker(QueryLifecycleFactory queryLifecycleFactory,
          PlannerContext plannerContext,
          com.fasterxml.jackson.databind.ObjectMapper jsonMapper)  | 
| 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.