io.druid.segment.indexing.granularity

Interface GranularitySpec

All Known Implementing Classes:

ArbitraryGranularitySpec, UniformGranularitySpec

public interface GranularitySpec

Tells the indexer how to group events based on timestamp. The events may then be further partitioned based on anything, using a ShardSpec.

Method Summary

Modifier and Type	Method and Description
com.google.common.base.Optional<org.joda.time.Interval>	bucketInterval(org.joda.time.DateTime dt) Time-grouping interval corresponding to some instant, if any.
com.google.common.base.Optional<SortedSet<org.joda.time.Interval>>	bucketIntervals() Set of all time groups, broken up on segment boundaries.
Granularity	getQueryGranularity()
Granularity	getSegmentGranularity()
List<org.joda.time.Interval>	inputIntervals() Returns user provided intervals as-is state.
boolean	isRollup()
GranularitySpec	withIntervals(List<org.joda.time.Interval> inputIntervals)

Method Detail

bucketIntervals

com.google.common.base.Optional<SortedSet<org.joda.time.Interval>> bucketIntervals()

Set of all time groups, broken up on segment boundaries. Should be sorted by interval start and non-overlapping.

Returns:

set of all time groups

inputIntervals

List<org.joda.time.Interval> inputIntervals()

Returns user provided intervals as-is state. used for configuring granular path spec

Returns:

bucketInterval

com.google.common.base.Optional<org.joda.time.Interval> bucketInterval(org.joda.time.DateTime dt)

Time-grouping interval corresponding to some instant, if any.

Parameters:

dt - instant to return time interval for

Returns:

optional time interval

getSegmentGranularity

Granularity getSegmentGranularity()

isRollup

boolean isRollup()

getQueryGranularity

Granularity getQueryGranularity()

withIntervals

GranularitySpec withIntervals(List<org.joda.time.Interval> inputIntervals)