Modifier and Type | Method and Description |
---|---|
Aggregation |
QuantileSqlAggregator.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) |
Modifier and Type | Method and Description |
---|---|
Aggregation |
SqlAggregator.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 . |
Aggregation |
ApproxCountDistinctSqlAggregator.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) |
Modifier and Type | Method and Description |
---|---|
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.
|
boolean |
RowExtraction.isFilterable(RowSignature rowSignature)
Check if this extraction can be used to build a filter on a Druid dataSource.
|
DimensionSpec |
RowExtraction.toDimensionSpec(RowSignature rowSignature,
String outputName,
ValueType outputType) |
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 |
---|---|
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 |
DruidRel.getOutputRowSignature() |
RowSignature |
DruidQueryBuilder.getOutputRowSignature()
Returns the output row signature for this DruidQueryBuilder.
|
RowSignature |
DruidSemiJoin.getSourceRowSignature() |
abstract RowSignature |
DruidRel.getSourceRowSignature() |
RowSignature |
DruidQueryRel.getSourceRowSignature() |
RowSignature |
DruidNestedGroupBy.getSourceRowSignature() |
Modifier and Type | Method and Description |
---|---|
static DruidQueryBuilder |
DruidQueryBuilder.fullScan(RowSignature rowSignature,
org.apache.calcite.rel.type.RelDataTypeFactory relDataTypeFactory) |
Sequence<Object[]> |
QueryMaker.runQuery(DataSource dataSource,
RowSignature sourceRowSignature,
DruidQueryBuilder queryBuilder) |
GroupByQuery |
DruidQueryBuilder.toGroupByQuery(DataSource dataSource,
RowSignature sourceRowSignature,
Map<String,Object> context)
Return this query as a GroupBy query, or null if this query is not compatible with GroupBy.
|
SelectQuery |
DruidQueryBuilder.toSelectQuery(DataSource dataSource,
RowSignature sourceRowSignature,
Map<String,Object> context)
Return this query as a Select query, or null if this query is not compatible with Select.
|
TimeseriesQuery |
DruidQueryBuilder.toTimeseriesQuery(DataSource dataSource,
RowSignature sourceRowSignature,
Map<String,Object> context)
Return this query as a Timeseries query, or null if this query is not compatible with Timeseries.
|
TopNQuery |
DruidQueryBuilder.toTopNQuery(DataSource dataSource,
RowSignature sourceRowSignature,
Map<String,Object> context,
int maxTopNLimit,
boolean useApproximateTopN)
Return this query as a TopN query, or null if this query is not compatible with TopN.
|
Modifier and Type | Method and Description |
---|---|
RowSignature |
RowSignature.Builder.build() |
RowSignature |
DruidTable.getRowSignature() |
Constructor and Description |
---|
DruidTable(DataSource dataSource,
RowSignature rowSignature) |
Copyright © 2011–2017. All rights reserved.