Modifier and Type | Method and Description |
---|---|
DimFilter |
DatasourceIngestionSpec.getFilter() |
Constructor and Description |
---|
DatasourceIngestionSpec(String dataSource,
org.joda.time.Interval interval,
List<org.joda.time.Interval> intervals,
List<DataSegment> segments,
DimFilter filter,
Granularity granularity,
List<String> dimensions,
List<String> metrics,
boolean ignoreWhenNoSegments) |
Modifier and Type | Method and Description |
---|---|
DimFilter |
IngestSegmentFirehoseFactory.getDimensionsFilter() |
Constructor and Description |
---|
IngestSegmentFirehoseFactory(String dataSource,
org.joda.time.Interval interval,
DimFilter dimFilter,
List<String> dimensions,
List<String> metrics,
com.google.inject.Injector injector,
IndexIO indexIO) |
Modifier and Type | Method and Description |
---|---|
DimFilter |
Druids.TimeseriesQueryBuilder.getDimFilter() |
DimFilter |
Query.getFilter() |
Modifier and Type | Method and Description |
---|---|
Druids.NotDimFilterBuilder |
Druids.NotDimFilterBuilder.field(DimFilter f) |
Druids.TimeseriesQueryBuilder |
Druids.TimeseriesQueryBuilder.filters(DimFilter f) |
Druids.SearchQueryBuilder |
Druids.SearchQueryBuilder.filters(DimFilter f) |
Druids.TimeBoundaryQueryBuilder |
Druids.TimeBoundaryQueryBuilder.filters(DimFilter f) |
Druids.SelectQueryBuilder |
Druids.SelectQueryBuilder.filters(DimFilter f) |
Modifier and Type | Method and Description |
---|---|
Druids.AndDimFilterBuilder |
Druids.AndDimFilterBuilder.fields(List<DimFilter> f) |
Druids.OrDimFilterBuilder |
Druids.OrDimFilterBuilder.fields(List<DimFilter> f) |
Modifier and Type | Method and Description |
---|---|
DimFilter |
FilteredAggregatorFactory.getFilter() |
Constructor and Description |
---|
FilteredAggregatorFactory(AggregatorFactory delegate,
DimFilter filter) |
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 |
---|---|
DimFilter |
DataSourceMetadataQuery.getFilter() |
Modifier and Type | Class and Description |
---|---|
class |
AndDimFilter |
class |
BoundDimFilter |
class |
ExtractionDimFilter
Deprecated.
|
class |
InDimFilter |
class |
IntervalDimFilter |
class |
JavaScriptDimFilter |
class |
LikeDimFilter |
class |
NoopDimFilter |
class |
NotDimFilter |
class |
OrDimFilter |
class |
RegexDimFilter |
class |
SearchQueryDimFilter |
class |
SelectorDimFilter |
class |
SpatialDimFilter |
Modifier and Type | Method and Description |
---|---|
static DimFilter |
DimFilters.dimEquals(String dimension,
String... values) |
DimFilter |
NotDimFilter.getField() |
DimFilter |
SpatialDimFilter.optimize() |
DimFilter |
SelectorDimFilter.optimize() |
DimFilter |
SearchQueryDimFilter.optimize() |
DimFilter |
RegexDimFilter.optimize() |
DimFilter |
OrDimFilter.optimize() |
DimFilter |
NotDimFilter.optimize() |
DimFilter |
NoopDimFilter.optimize() |
DimFilter |
LikeDimFilter.optimize() |
DimFilter |
JavaScriptDimFilter.optimize() |
DimFilter |
IntervalDimFilter.optimize() |
DimFilter |
InDimFilter.optimize() |
DimFilter |
ExtractionDimFilter.optimize()
Deprecated.
|
DimFilter |
DimFilter.optimize() |
DimFilter |
BoundDimFilter.optimize() |
DimFilter |
AndDimFilter.optimize() |
Modifier and Type | Method and Description |
---|---|
static List<DimFilter> |
DimFilters.filterNulls(List<DimFilter> optimized) |
List<DimFilter> |
OrDimFilter.getFields() |
List<DimFilter> |
AndDimFilter.getFields() |
static List<DimFilter> |
DimFilters.optimize(List<DimFilter> filters) |
Modifier and Type | Method and Description |
---|---|
static AndDimFilter |
DimFilters.and(DimFilter... filters) |
static <T> Set<T> |
DimFilterUtils.filterShards(DimFilter dimFilter,
Iterable<T> input,
com.google.common.base.Function<T,ShardSpec> converter)
Filter the given iterable of objects by removing any object whose ShardSpec, obtained from the converter function,
does not fit in the RangeSet of the dimFilter
getDimensionRangeSet(String) . |
static <T> Set<T> |
DimFilterUtils.filterShards(DimFilter dimFilter,
Iterable<T> input,
com.google.common.base.Function<T,ShardSpec> converter,
Map<String,com.google.common.base.Optional<com.google.common.collect.RangeSet<String>>> dimensionRangeCache)
Filter the given iterable of objects by removing any object whose ShardSpec, obtained from the converter function,
does not fit in the RangeSet of the dimFilter
getDimensionRangeSet(String) . |
static NotDimFilter |
DimFilters.not(DimFilter filter) |
static OrDimFilter |
DimFilters.or(DimFilter... filters) |
Modifier and Type | Method and Description |
---|---|
static AndDimFilter |
DimFilters.and(List<DimFilter> filters) |
static List<DimFilter> |
DimFilters.filterNulls(List<DimFilter> optimized) |
static List<DimFilter> |
DimFilters.optimize(List<DimFilter> filters) |
static OrDimFilter |
DimFilters.or(List<DimFilter> filters) |
Constructor and Description |
---|
NotDimFilter(DimFilter field) |
Constructor and Description |
---|
AndDimFilter(List<DimFilter> fields) |
OrDimFilter(List<DimFilter> fields) |
Modifier and Type | Method and Description |
---|---|
DimFilter |
GroupByQuery.getDimFilter() |
DimFilter |
GroupByQuery.getFilter() |
Modifier and Type | Method and Description |
---|---|
GroupByQuery.Builder |
GroupByQuery.Builder.setDimFilter(DimFilter dimFilter) |
GroupByQuery |
GroupByQuery.withDimFilter(DimFilter dimFilter) |
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 |
---|---|
DimFilter |
DimFilterHavingSpec.getDimFilter() |
Constructor and Description |
---|
DimFilterHavingSpec(DimFilter dimFilter) |
Modifier and Type | Method and Description |
---|---|
DimFilter |
SegmentMetadataQuery.getFilter() |
Modifier and Type | Method and Description |
---|---|
DimFilter |
ScanQuery.getDimensionsFilter() |
DimFilter |
ScanQuery.getFilter() |
Modifier and Type | Method and Description |
---|---|
ScanQuery.ScanQueryBuilder |
ScanQuery.ScanQueryBuilder.filters(DimFilter f) |
ScanQuery |
ScanQuery.withDimFilter(DimFilter dimFilter) |
Constructor and Description |
---|
ScanQuery(DataSource dataSource,
QuerySegmentSpec querySegmentSpec,
String resultFormat,
int batchSize,
int limit,
DimFilter dimFilter,
List<String> columns,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
DimFilter |
SearchQuery.getDimensionsFilter() |
DimFilter |
SearchQuery.getFilter() |
Modifier and Type | Method and Description |
---|---|
SearchQuery |
SearchQuery.withDimFilter(DimFilter dimFilter) |
Constructor and Description |
---|
SearchQuery(DataSource dataSource,
DimFilter dimFilter,
Granularity granularity,
int limit,
QuerySegmentSpec querySegmentSpec,
List<DimensionSpec> dimensions,
SearchQuerySpec querySpec,
SearchSortSpec sortSpec,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
DimFilter |
SelectQuery.getDimensionsFilter() |
DimFilter |
SelectQuery.getFilter() |
Modifier and Type | Method and Description |
---|---|
SelectQuery |
SelectQuery.withDimFilter(DimFilter dimFilter) |
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 |
---|---|
DimFilter |
TimeBoundaryQuery.getDimensionsFilter() |
DimFilter |
TimeBoundaryQuery.getFilter() |
Constructor and Description |
---|
TimeBoundaryQuery(DataSource dataSource,
QuerySegmentSpec querySegmentSpec,
String bound,
DimFilter dimFilter,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
DimFilter |
TimeseriesQuery.getDimensionsFilter() |
DimFilter |
TimeseriesQuery.getFilter() |
Modifier and Type | Method and Description |
---|---|
TimeseriesQuery |
TimeseriesQuery.withDimFilter(DimFilter dimFilter) |
Constructor and Description |
---|
TimeseriesQuery(DataSource dataSource,
QuerySegmentSpec querySegmentSpec,
boolean descending,
VirtualColumns virtualColumns,
DimFilter dimFilter,
Granularity granularity,
List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
DimFilter |
TopNQuery.getDimensionsFilter() |
DimFilter |
TopNQueryBuilder.getDimFilter() |
DimFilter |
TopNQuery.getFilter() |
Modifier and Type | Method and Description |
---|---|
TopNQueryBuilder |
TopNQueryBuilder.filters(DimFilter f) |
TopNQuery |
TopNQuery.withDimFilter(DimFilter dimFilter) |
Constructor and Description |
---|
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 Filter |
Filters.toFilter(DimFilter dimFilter)
Convert a DimFilter to a Filter.
|
Modifier and Type | Method and Description |
---|---|
static List<Filter> |
Filters.toFilters(List<DimFilter> dimFilters)
Convert a list of DimFilters to a list of Filters.
|
Constructor and Description |
---|
IngestSegmentFirehose(List<WindowedStorageAdapter> adapters,
List<String> dims,
List<String> metrics,
DimFilter dimFilter,
Granularity granularity) |
Modifier and Type | Method and Description |
---|---|
static <T extends AggregatorFactory> |
Aggregations.aggregatorMatches(AggregatorFactory factory,
DimFilter filter,
Class<T> clazz,
com.google.common.base.Predicate<T> predicate)
Returns true if "factory" is an aggregator factory that either matches "predicate" (if filter is null) or is
a filtered aggregator factory whose filter is equal to "filter" and underlying aggregator matches "predicate".
|
Aggregation |
Aggregation.filter(DimFilter filter) |
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 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 |
---|---|
DimFilter |
Filtration.getDimFilter() |
static DimFilter |
Filtration.matchEverything() |
static DimFilter |
Filtration.matchNothing() |
protected DimFilter |
ValidateNoMarkerFiltersRemain.process(DimFilter filter) |
DimFilter |
ConvertSelectorsToIns.process(DimFilter filter) |
DimFilter |
ConvertBoundsToSelectors.process(DimFilter filter) |
DimFilter |
CombineAndSimplifyBounds.process(DimFilter filter) |
protected abstract DimFilter |
BottomUpTransform.process(DimFilter filter) |
Modifier and Type | Method and Description |
---|---|
static Filtration |
Filtration.create(DimFilter dimFilter) |
static Filtration |
Filtration.create(DimFilter dimFilter,
List<org.joda.time.Interval> intervals) |
protected DimFilter |
ValidateNoMarkerFiltersRemain.process(DimFilter filter) |
DimFilter |
ConvertSelectorsToIns.process(DimFilter filter) |
DimFilter |
ConvertBoundsToSelectors.process(DimFilter filter) |
DimFilter |
CombineAndSimplifyBounds.process(DimFilter filter) |
protected abstract DimFilter |
BottomUpTransform.process(DimFilter filter) |
Modifier and Type | Method and Description |
---|---|
DimFilter |
DruidQueryBuilder.getFilter() |
DimFilter |
DruidQueryBuilder.getHaving() |
Modifier and Type | Method and Description |
---|---|
static DruidNestedGroupBy |
DruidNestedGroupBy.from(DruidRel sourceRel,
DimFilter filter,
Grouping grouping,
org.apache.calcite.rel.type.RelDataType rowType,
List<String> rowOrder) |
DruidQueryBuilder |
DruidQueryBuilder.withFilter(DimFilter newFilter) |
DruidQueryBuilder |
DruidQueryBuilder.withHaving(DimFilter newHaving) |
Copyright © 2011–2017. All rights reserved.