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.