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.