Modifier and Type | Method and Description |
---|---|
Granularity |
DatasourceIngestionSpec.getGranularity() |
Modifier and Type | Method and Description |
---|---|
DatasourceIngestionSpec |
DatasourceIngestionSpec.withQueryGranularity(Granularity granularity) |
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 |
---|---|
Granularity |
GranularityPathSpec.getDataGranularity() |
Modifier and Type | Method and Description |
---|---|
void |
GranularityPathSpec.setDataGranularity(Granularity dataGranularity) |
Modifier and Type | Method and Description |
---|---|
Granularity |
SegmentAllocateAction.getPreferredSegmentGranularity() |
Granularity |
SegmentAllocateAction.getQueryGranularity() |
Constructor and Description |
---|
SegmentAllocateAction(String dataSource,
org.joda.time.DateTime timestamp,
Granularity queryGranularity,
Granularity preferredSegmentGranularity,
String sequenceName,
String previousSegmentId) |
Modifier and Type | Class and Description |
---|---|
class |
AllGranularity
AllGranularty buckets everything into a single bucket
|
class |
DurationGranularity
DurationGranularity buckets data based on the length of a duration
|
class |
NoneGranularity
NoneGranularity does not bucket data
|
class |
PeriodGranularity
PeriodGranularity buckets data based on any custom time period
|
Modifier and Type | Field and Description |
---|---|
static Granularity |
Granularities.ALL |
static Granularity |
Granularities.DAY |
static Granularity |
Granularities.FIFTEEN_MINUTE |
static Granularity |
Granularities.FIVE_MINUTE |
static Granularity |
Granularities.HOUR |
static Granularity |
Granularities.MINUTE |
static Granularity |
Granularities.MONTH |
static Granularity |
Granularities.NONE |
static Granularity |
Granularities.QUARTER |
static Granularity |
Granularities.SECOND |
static Granularity |
Granularities.SIX_HOUR |
static Granularity |
Granularities.TEN_MINUTE |
static Granularity |
Granularities.THIRTY_MINUTE |
static Granularity |
Granularities.WEEK |
static Granularity |
Granularities.YEAR |
Modifier and Type | Method and Description |
---|---|
static Granularity |
Granularity.fromString(String str) |
Granularity |
GranularityType.getDefaultGranularity() |
static Granularity |
Granularity.mergeGranularities(List<Granularity> toMerge)
simple merge strategy on query granularity that checks if all are equal or else
returns null.
|
Modifier and Type | Method and Description |
---|---|
static List<Granularity> |
Granularity.granularitiesFinerThan(Granularity gran0) |
Modifier and Type | Method and Description |
---|---|
static List<Granularity> |
Granularity.granularitiesFinerThan(Granularity gran0) |
static boolean |
GranularityType.isStandard(Granularity granularity)
For a select subset of granularites, users can specify them directly as string.
|
Modifier and Type | Method and Description |
---|---|
static Granularity |
Granularity.mergeGranularities(List<Granularity> toMerge)
simple merge strategy on query granularity that checks if all are equal or else
returns null.
|
Modifier and Type | Method and Description |
---|---|
Granularity |
Druids.TimeseriesQueryBuilder.getGranularity() |
Modifier and Type | Method and Description |
---|---|
static <T> com.google.common.collect.Ordering<Result<T>> |
ResultGranularTimestampComparator.create(Granularity granularity,
boolean descending) |
Druids.TimeseriesQueryBuilder |
Druids.TimeseriesQueryBuilder.granularity(Granularity g) |
Druids.SearchQueryBuilder |
Druids.SearchQueryBuilder.granularity(Granularity g) |
Druids.SelectQueryBuilder |
Druids.SelectQueryBuilder.granularity(Granularity g) |
static <T> Sequence<Result<T>> |
QueryRunnerHelper.makeCursorBasedQuery(StorageAdapter adapter,
List<org.joda.time.Interval> queryIntervals,
Filter filter,
VirtualColumns virtualColumns,
boolean descending,
Granularity granularity,
com.google.common.base.Function<Cursor,Result<T>> mapFn) |
Constructor and Description |
---|
ResultGranularTimestampComparator(Granularity granularity) |
Modifier and Type | Method and Description |
---|---|
Granularity |
TimeFormatExtractionFn.getGranularity() |
Constructor and Description |
---|
TimeFormatExtractionFn(String format,
org.joda.time.DateTimeZone tz,
String localeString,
Granularity granularity,
boolean asMillis) |
Modifier and Type | Method and Description |
---|---|
Granularity |
GroupByQuery.getGranularity() |
Modifier and Type | Method and Description |
---|---|
GroupByQuery.Builder |
GroupByQuery.Builder.setGranularity(Granularity granularity) |
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 |
---|---|
Granularity |
SegmentAnalysis.getQueryGranularity() |
Constructor and Description |
---|
SegmentAnalysis(String id,
List<org.joda.time.Interval> interval,
Map<String,ColumnAnalysis> columns,
long size,
long numRows,
Map<String,AggregatorFactory> aggregators,
TimestampSpec timestampSpec,
Granularity queryGranularity,
Boolean rollup) |
Constructor and Description |
---|
SearchBinaryFn(SearchSortSpec searchSortSpec,
Granularity granularity,
int limit) |
Modifier and Type | Method and Description |
---|---|
Granularity |
SearchQuery.getGranularity() |
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 |
---|---|
Granularity |
SelectQuery.getGranularity() |
Constructor and Description |
---|
SelectBinaryFn(Granularity granularity,
PagingSpec pagingSpec,
boolean descending) |
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 |
---|---|
Granularity |
TimeseriesQuery.getGranularity() |
Constructor and Description |
---|
TimeseriesBinaryFn(Granularity granularity,
List<AggregatorFactory> aggregations) |
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 |
---|---|
Granularity |
TopNQueryBuilder.getGranularity() |
Granularity |
TopNQuery.getGranularity() |
Modifier and Type | Method and Description |
---|---|
TopNQueryBuilder |
TopNQueryBuilder.granularity(Granularity g) |
Constructor and Description |
---|
TopNBinaryFn(TopNResultMerger merger,
Granularity granularity,
DimensionSpec dimSpec,
TopNMetricSpec topNMetricSpec,
int threshold,
List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
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 |
---|---|
Granularity |
Metadata.getQueryGranularity() |
Modifier and Type | Method and Description |
---|---|
Sequence<Cursor> |
QueryableIndexStorageAdapter.makeCursors(Filter filter,
org.joda.time.Interval interval,
VirtualColumns virtualColumns,
Granularity gran,
boolean descending) |
Sequence<Cursor> |
CursorFactory.makeCursors(Filter filter,
org.joda.time.Interval interval,
VirtualColumns virtualColumns,
Granularity gran,
boolean descending) |
Metadata |
Metadata.setQueryGranularity(Granularity queryGranularity) |
Modifier and Type | Method and Description |
---|---|
Granularity |
IncrementalIndexSchema.getGran() |
Modifier and Type | Method and Description |
---|---|
Sequence<Cursor> |
IncrementalIndexStorageAdapter.makeCursors(Filter filter,
org.joda.time.Interval interval,
VirtualColumns virtualColumns,
Granularity gran,
boolean descending) |
IncrementalIndexSchema.Builder |
IncrementalIndexSchema.Builder.withQueryGranularity(Granularity gran) |
Constructor and Description |
---|
IncrementalIndexSchema(long minTimestamp,
TimestampSpec timestampSpec,
Granularity gran,
VirtualColumns virtualColumns,
DimensionsSpec dimensionsSpec,
AggregatorFactory[] metrics,
boolean rollup) |
OffheapIncrementalIndex(long minTimestamp,
Granularity gran,
AggregatorFactory[] metrics,
int maxRowCount,
StupidPool<ByteBuffer> bufferPool) |
OffheapIncrementalIndex(long minTimestamp,
Granularity gran,
boolean rollup,
AggregatorFactory[] metrics,
int maxRowCount,
StupidPool<ByteBuffer> bufferPool) |
OnheapIncrementalIndex(long minTimestamp,
Granularity gran,
AggregatorFactory[] metrics,
boolean deserializeComplexMetrics,
boolean reportParseExceptions,
boolean sortFacts,
int maxRowCount) |
OnheapIncrementalIndex(long minTimestamp,
Granularity gran,
AggregatorFactory[] metrics,
int maxRowCount) |
OnheapIncrementalIndex(long minTimestamp,
Granularity gran,
boolean rollup,
DimensionsSpec dimensionsSpec,
AggregatorFactory[] metrics,
int maxRowCount) |
Modifier and Type | Method and Description |
---|---|
Granularity |
UniformGranularitySpec.getQueryGranularity() |
Granularity |
GranularitySpec.getQueryGranularity() |
Granularity |
ArbitraryGranularitySpec.getQueryGranularity() |
Granularity |
UniformGranularitySpec.getSegmentGranularity() |
Granularity |
GranularitySpec.getSegmentGranularity() |
Granularity |
ArbitraryGranularitySpec.getSegmentGranularity() |
Constructor and Description |
---|
ArbitraryGranularitySpec(Granularity queryGranularity,
Boolean rollup,
List<org.joda.time.Interval> inputIntervals) |
ArbitraryGranularitySpec(Granularity queryGranularity,
List<org.joda.time.Interval> inputIntervals) |
UniformGranularitySpec(Granularity segmentGranularity,
Granularity queryGranularity,
Boolean rollup,
List<org.joda.time.Interval> inputIntervals) |
UniformGranularitySpec(Granularity segmentGranularity,
Granularity queryGranularity,
List<org.joda.time.Interval> inputIntervals) |
Constructor and Description |
---|
IngestSegmentFirehose(List<WindowedStorageAdapter> adapters,
List<String> dims,
List<String> metrics,
DimFilter dimFilter,
Granularity granularity) |
Modifier and Type | Method and Description |
---|---|
static Granularity |
ExtractionFns.toQueryGranularity(ExtractionFn extractionFn)
Converts extractionFn to a QueryGranularity, if possible.
|
static Granularity |
TimeUnits.toQueryGranularity(org.apache.calcite.avatica.util.TimeUnitRange timeUnitRange,
org.joda.time.DateTimeZone timeZone)
Returns the Druid QueryGranularity corresponding to a Calcite TimeUnitRange, or null if there is none.
|
Modifier and Type | Method and Description |
---|---|
static RowExtraction |
FloorExpressionConversion.applyTimestampFloor(RowExtraction rex,
Granularity queryGranularity) |
static ExtractionFn |
ExtractionFns.fromQueryGranularity(Granularity queryGranularity)
Converts a QueryGranularity to an extractionFn, if possible.
|
Copyright © 2011–2017. All rights reserved.