Package org.apache.calcite.adapter.druid
Query provider based on a Druid database.
-
Interface Summary Interface Description DimensionSpec Interface for Druid DimensionSpec.DruidConnection Connection to Druid.DruidConnectionImpl.RunnableQueueSink ASink
that is alsoRunnable
.DruidJson Object that knows how to write itself to aJsonGenerator
.DruidSqlOperatorConverter Defines how to convert RexNode with a given calcite SQL operator to Druid expressionsExtractionFunction Interface for Druid extraction functions.Granularity A strategy by which Druid rolls up rows into sub-totals based on their timestamp values. -
Class Summary Class Description BinaryOperatorConversion Binary operator conversion utility class used to convert expression like exp1 Operator exp2CeilOperatorConversion DruidSqlOperatorConverter implementation that handles Ceil operations conversionsComplexMetric Used to store information about available complex metrics in the Druid AdapterDefaultDimensionSpec Default implementation of DimensionSpec.DirectOperatorConversion Direct operator conversion for expression like Function(exp_1,...exp_n)DruidConnectionImpl Implementation ofDruidConnection
.DruidConnectionImpl.BlockingQueueEnumerator<E> AnEnumerator
that gets its rows from aBlockingQueue
.DruidConnectionImpl.JsonAggregator Element of the "aggregators" collection in the result of a "segmentMetadata" call, populated by Jackson.DruidConnectionImpl.JsonColumn Element of the "columns" collection in the result of a "segmentMetadata" call, populated by Jackson.DruidConnectionImpl.JsonSegmentMetadata Result of a "segmentMetadata" call, populated by Jackson.DruidConnectionImpl.Page Progress through a large fetch.DruidDateTimeUtils Utilities for generating intervals from RexNode.DruidExpressions Expression utility class to transform Calcite expressions to Druid expressions when possible.DruidJsonFilter Filter element of a Druid "groupBy" or "topN" query.DruidJsonFilter.JsonBound Bound filter.DruidJsonFilter.JsonCompositeFilter Filter that combines other filters using a boolean operator.DruidJsonFilter.JsonDimHavingFilter Druid Having Filter specDruidJsonFilter.JsonExpressionFilter Druid Expression filter.DruidJsonFilter.JsonInFilter IN filter.DruidJsonFilter.JsonSelector Equality filter.DruidQuery Relational expression representing a scan of a Druid data set.DruidQuery.DruidQueryNode Interpreter node that executes a Druid query and sends the results to aSink
.DruidQuery.JsonAggregation Aggregation element of a Druid "groupBy" or "topN" query.DruidQuery.JsonCardinalityAggregation Aggregation element that calls the "cardinality" function.DruidQuery.JsonCollation Collation element of a Druid "groupBy" query.DruidQuery.JsonExpressionPostAgg Druid Json Expression post aggregate.DruidQuery.JsonFilteredAggregation Aggregation element that contains a filterDruidQuery.JsonLimit Collation element of a Druid "groupBy" query.DruidQuery.JsonPostAggregation Post-Aggregator Post aggregator abstract writerDruidQuery.QuerySpec Druid query specification.DruidQuery.ScanQuery Druid Scan Query BodyDruidRules Rules and relational operators forDruidQuery
.DruidRules.DruidAggregateExtractProjectRule Rule to extract aProject
fromAggregate
on top ofDruidQuery
based on the fields used in the aggregate.DruidRules.DruidAggregateFilterTransposeRule DruidRules.DruidAggregateProjectRule DruidRules.DruidAggregateRule Rule to push anAggregate
into aDruidQuery
.DruidRules.DruidFilterAggregateTransposeRule DruidRules.DruidFilterProjectTransposeRule DruidRules.DruidFilterRule Rule to push aFilter
into aDruidQuery
.DruidRules.DruidHavingFilterRule Rule to Push a HavingFilter
into aDruidQuery
DruidRules.DruidPostAggregationProjectRule Rule to push aProject
into aDruidQuery
as a Post aggregator.DruidRules.DruidProjectFilterTransposeRule DruidRules.DruidProjectRule Rule to push aProject
into aDruidQuery
.DruidRules.DruidProjectSortTransposeRule DruidRules.DruidSortProjectTransposeRule DruidRules.DruidSortRule Rule to push aSort
into aDruidQuery
.DruidSchema Schema mapped onto a Druid instance.DruidSchemaFactory Schema factory that creates Druid schemas.DruidSqlCastConverter Druid cast converter operator used to translates calcite casts to Druid expression castDruidTable Table mapped onto a Druid table.DruidTable.MapRelProtoDataType Creates aRelDataType
from a map of field names and types.DruidTableFactory Implementation ofTableFactory
for Druid.ExtractionDimensionSpec Implementation of extraction function DimensionSpec.ExtractOperatorConversion Time extract operator conversion for expressions like EXTRACT(timeUnit FROM arg) Unit can be SECOND, MINUTE, HOUR, DAY (day of month), DOW (day of week), DOY (day of year), WEEK (week of week year), MONTH (1 through 12), QUARTER (1 through 4), or YEARFloorOperatorConversion DruidSqlOperatorConverter implementation that handles Floor operations conversionsGranularities Factory methods and helpers forGranularity
.Granularities.PeriodGranularity Implementation ofGranularity
based on a time unit.NaryOperatorConverter Converts Calcite n-ary operators to druid expression eg (arg1 Op arg2 Op arg3)SubstringOperatorConversion Converts Calcite SUBSTRING call to Druid Expression when possibleTimeExtractionFunction Implementation of Druid time format extraction function.UnaryPrefixOperatorConversion Unary prefix Operator conversion class used to convert expression like Unary NOT and MinusUnarySuffixOperatorConversion Unary suffix operator conversion, used to convert function like: expression Unary_OperatorVirtualColumn Druid Json Expression based Virtual Column.VirtualColumn.Builder Virtual Column Builder -
Enum Summary Enum Description DruidJsonFilter.Type Supported filter typesDruidType Druid type.Granularities.AllGranularity Implementation ofGranularity
forGranularity.Type.ALL
.Granularity.Type Type of supported periods for granularity.QueryType Type of Druid query.