Modifier and Type | Field and Description |
---|---|
static com.google.common.base.Function<String,DimensionSpec> |
Druids.DIMENSION_IDENTITY |
Modifier and Type | Method and Description |
---|---|
Druids.SearchQueryBuilder |
Druids.SearchQueryBuilder.dimensions(DimensionSpec d) |
Modifier and Type | Method and Description |
---|---|
Druids.SearchQueryBuilder |
Druids.SearchQueryBuilder.dimensions(List<DimensionSpec> d) |
Druids.SelectQueryBuilder |
Druids.SelectQueryBuilder.dimensionSpecs(List<DimensionSpec> d) |
Modifier and Type | Method and Description |
---|---|
List<DimensionSpec> |
CardinalityAggregatorFactory.getFields() |
Constructor and Description |
---|
CardinalityAggregatorFactory(String name,
List<DimensionSpec> fields,
boolean byRow) |
CardinalityAggregatorFactory(String name,
List<String> fieldNames,
List<DimensionSpec> fields,
boolean byRow) |
Modifier and Type | Class and Description |
---|---|
class |
BaseFilteredDimensionSpec |
class |
DefaultDimensionSpec |
class |
ExtractionDimensionSpec |
class |
LegacyDimensionSpec |
class |
ListFilteredDimensionSpec |
class |
LookupDimensionSpec |
class |
RegexFilteredDimensionSpec |
Modifier and Type | Field and Description |
---|---|
protected DimensionSpec |
BaseFilteredDimensionSpec.delegate |
Modifier and Type | Method and Description |
---|---|
DimensionSpec |
BaseFilteredDimensionSpec.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static List<DimensionSpec> |
DefaultDimensionSpec.toSpec(Iterable<String> dimensionNames) |
static List<DimensionSpec> |
DefaultDimensionSpec.toSpec(String... dimensionNames) |
Constructor and Description |
---|
BaseFilteredDimensionSpec(DimensionSpec delegate) |
ListFilteredDimensionSpec(DimensionSpec delegate,
Set<String> values,
Boolean isWhitelist) |
RegexFilteredDimensionSpec(DimensionSpec delegate,
String pattern) |
Modifier and Type | Method and Description |
---|---|
static Collection<DimensionSpec> |
GroupByQueryQueryToolChest.extractionsToRewrite(GroupByQuery query)
This function checks the query for dimensions which can be optimized by applying the dimension extraction
as the final step of the query instead of on every event.
|
List<DimensionSpec> |
GroupByQuery.getDimensions() |
Modifier and Type | Method and Description |
---|---|
GroupByQuery.Builder |
GroupByQuery.Builder.addDimension(DimensionSpec dimension) |
DimensionSelector |
RowBasedColumnSelectorFactory.makeDimensionSelector(DimensionSpec dimensionSpec) |
Modifier and Type | Method and Description |
---|---|
GroupByQuery.Builder |
GroupByQuery.Builder.setDimensions(List<DimensionSpec> dimensions) |
GroupByQuery |
GroupByQuery.withDimensionSpecs(List<DimensionSpec> dimensionSpecs) |
Constructor and Description |
---|
GroupByQuery(DataSource dataSource,
QuerySegmentSpec querySegmentSpec,
VirtualColumns virtualColumns,
DimFilter dimFilter,
Granularity granularity,
List<DimensionSpec> dimensions,
List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs,
HavingSpec havingSpec,
LimitSpec limitSpec,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
NoopLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs) |
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
LimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs)
Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
|
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
DefaultLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs) |
Modifier and Type | Field and Description |
---|---|
protected List<DimensionSpec> |
SearchQueryExecutor.dimsToSearch |
Modifier and Type | Method and Description |
---|---|
List<DimensionSpec> |
SearchQuery.getDimensions() |
Constructor and Description |
---|
CursorBasedExecutor(SearchQuery query,
Segment segment,
Filter filter,
org.joda.time.Interval interval,
List<DimensionSpec> dimensionSpecs) |
IndexOnlyExecutor(SearchQuery query,
Segment segment,
ImmutableBitmap timeFilteredBitmap,
List<DimensionSpec> dimensionSpecs) |
SearchQuery(DataSource dataSource,
DimFilter dimFilter,
Granularity granularity,
int limit,
QuerySegmentSpec querySegmentSpec,
List<DimensionSpec> dimensions,
SearchQuerySpec querySpec,
SearchSortSpec sortSpec,
Map<String,Object> context) |
SearchQueryExecutor(SearchQuery query,
Segment segment,
List<DimensionSpec> dimensionSpecs) |
Modifier and Type | Method and Description |
---|---|
List<DimensionSpec> |
SelectQuery.getDimensions() |
Constructor and Description |
---|
SelectQuery(DataSource dataSource,
QuerySegmentSpec querySegmentSpec,
boolean descending,
DimFilter dimFilter,
Granularity granularity,
List<DimensionSpec> dimensions,
List<String> metrics,
VirtualColumns virtualColumns,
PagingSpec pagingSpec,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
DimensionSpec |
TopNQueryBuilder.getDimensionSpec() |
DimensionSpec |
TopNQuery.getDimensionSpec() |
Modifier and Type | Method and Description |
---|---|
TopNQueryBuilder |
TopNQueryBuilder.dimension(DimensionSpec d) |
String |
TopNMetricSpec.getMetricName(DimensionSpec dimSpec) |
String |
NumericTopNMetricSpec.getMetricName(DimensionSpec dimSpec) |
String |
LexicographicTopNMetricSpec.getMetricName(DimensionSpec dimSpec) |
String |
InvertedTopNMetricSpec.getMetricName(DimensionSpec dimSpec) |
String |
DimensionTopNMetricSpec.getMetricName(DimensionSpec dimSpec) |
TopNResultBuilder |
TopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
TopNResultBuilder |
NumericTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
TopNResultBuilder |
LexicographicTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
TopNResultBuilder |
InvertedTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
TopNResultBuilder |
DimensionTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
TopNQuery |
TopNQuery.withDimensionSpec(DimensionSpec spec) |
Constructor and Description |
---|
TopNBinaryFn(TopNResultMerger merger,
Granularity granularity,
DimensionSpec dimSpec,
TopNMetricSpec topNMetricSpec,
int threshold,
List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
TopNLexicographicResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
String previousStop,
Comparator comparator,
List<AggregatorFactory> aggFactories) |
TopNNumericResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
String metricName,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
TopNQuery(DataSource dataSource,
VirtualColumns virtualColumns,
DimensionSpec dimensionSpec,
TopNMetricSpec topNMetricSpec,
int threshold,
QuerySegmentSpec querySegmentSpec,
DimFilter dimFilter,
Granularity granularity,
List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
static <ColumnSelectorStrategyClass extends ColumnSelectorStrategy> |
DimensionHandlerUtils.createColumnSelectorPluses(ColumnSelectorStrategyFactory<ColumnSelectorStrategyClass> strategyFactory,
List<DimensionSpec> dimensionSpecs,
ColumnSelectorFactory cursor)
Creates an array of ColumnSelectorPlus objects, selectors that handle type-specific operations within
query processing engines, using a strategy factory provided by the query engine.
|
static List<ValueType> |
DimensionHandlerUtils.getValueTypesFromDimensionSpecs(List<DimensionSpec> dimSpecs) |
Modifier and Type | Method and Description |
---|---|
DimensionSelector |
VirtualizedColumnSelectorFactory.makeDimensionSelector(DimensionSpec dimensionSpec) |
DimensionSelector |
ExpressionVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec,
ColumnSelectorFactory columnSelectorFactory) |
Modifier and Type | Method and Description |
---|---|
DimensionSpec |
RowExtraction.toDimensionSpec(RowSignature rowSignature,
String outputName,
ValueType outputType) |
Modifier and Type | Method and Description |
---|---|
static RowExtraction |
RowExtraction.fromDimensionSpec(DimensionSpec dimensionSpec) |
Modifier and Type | Method and Description |
---|---|
List<DimensionSpec> |
SelectProjection.getDimensions() |
List<DimensionSpec> |
Grouping.getDimensions() |
Modifier and Type | Method and Description |
---|---|
static Grouping |
Grouping.create(List<DimensionSpec> dimensions,
List<Aggregation> aggregations) |
Constructor and Description |
---|
SelectProjection(org.apache.calcite.rel.core.Project project,
List<DimensionSpec> dimensions,
List<String> metrics) |
Copyright © 2011–2017. All rights reserved.