Modifier and Type | Method and Description |
---|---|
protected static SimplifiedIntervalList |
PartialDataHandler.collectBucketedIntervalsNotInIntervalList(SimplifiedIntervalList supplyIntervals,
SimplifiedIntervalList bucketedIntervals,
Granularity granularity)
Collect all subintervals from a bucketed collection that are not subintervals of a supply.
|
SimplifiedIntervalList |
PartialDataHandler.findMissingTimeGrainIntervals(SimplifiedIntervalList availableIntervals,
SimplifiedIntervalList requestedIntervals,
Granularity granularity)
Find the holes in the passed in intervals at a given granularity.
|
Modifier and Type | Method and Description |
---|---|
protected ResponseData |
HttpResponseMaker.buildResponseData(ResultSet resultSet,
LinkedHashSet<String> apiMetricColumnNames,
LinkedHashMap<Dimension,LinkedHashSet<DimensionField>> requestedApiDimensionFields,
SimplifiedIntervalList partialIntervals,
SimplifiedIntervalList volatileIntervals,
Pagination pagination,
Map<String,URI> paginationLinks)
Builds a ResponseData object.
|
protected static SimplifiedIntervalList |
PartialDataHandler.collectBucketedIntervalsNotInIntervalList(SimplifiedIntervalList supplyIntervals,
SimplifiedIntervalList bucketedIntervals,
Granularity granularity)
Collect all subintervals from a bucketed collection that are not subintervals of a supply.
|
SimplifiedIntervalList |
PartialDataHandler.findMissingTimeGrainIntervals(SimplifiedIntervalList availableIntervals,
SimplifiedIntervalList requestedIntervals,
Granularity granularity)
Find the holes in the passed in intervals at a given granularity.
|
Constructor and Description |
---|
PartialDataResultSetMapper(SimplifiedIntervalList missingIntervals,
Supplier<SimplifiedIntervalList> volatileIntervalSupply)
Build a mapper to filter results over missing intervals from a result set, retaining any that are also volatile.
|
Constructor and Description |
---|
PartialDataResultSetMapper(SimplifiedIntervalList missingIntervals,
Supplier<SimplifiedIntervalList> volatileIntervalSupply)
Build a mapper to filter results over missing intervals from a result set, retaining any that are also volatile.
|
Modifier and Type | Method and Description |
---|---|
default Iterator<org.joda.time.Interval> |
TimeGrain.intervalsIterator(SimplifiedIntervalList intervals) |
Iterator<org.joda.time.Interval> |
AllGranularity.intervalsIterator(SimplifiedIntervalList intervals) |
Iterator<org.joda.time.Interval> |
Granularity.intervalsIterator(SimplifiedIntervalList intervals)
Build an iterator from a pre-simplified list of intervals.
|
Modifier and Type | Method and Description |
---|---|
SimplifiedIntervalList |
NoVolatileIntervalsFunction.getVolatileIntervals() |
SimplifiedIntervalList |
VolatileIntervalsFunction.getVolatileIntervals()
Retrieve a list of which intervals are volatile.
|
SimplifiedIntervalList |
TimeOffsetVolatileIntervalsFunction.getVolatileIntervals() |
default SimplifiedIntervalList |
VolatileIntervalsService.getVolatileIntervals(DruidAggregationQuery<?> query,
PhysicalTable factSource)
Deprecated.
Exists solely for backwards compatibility.
VolatileIntervalsService.getVolatileIntervals(Granularity, List, PhysicalTable) should be used instead |
SimplifiedIntervalList |
VolatileIntervalsService.getVolatileIntervals(Granularity granularity,
List<org.joda.time.Interval> intervals,
PhysicalTable factSource)
Retrieve a simplified sublist of the given intervals aligned to the specified time buckets and that are
partially or fully volatile.
|
SimplifiedIntervalList |
DefaultingVolatileIntervalsService.getVolatileIntervals(Granularity granularity,
List<org.joda.time.Interval> intervals,
PhysicalTable factSource) |
Modifier and Type | Method and Description |
---|---|
SimplifiedIntervalList |
LookbackQuery.LookbackQueryRequestedIntervalsFunction.apply(DruidAggregationQuery<?> druidAggregationQuery) |
Modifier and Type | Method and Description |
---|---|
Map<String,SimplifiedIntervalList> |
DataSourceMetadataService.getAvailableIntervalsByDataSource(DataSourceName dataSourceName)
Get a set of intervals available for each column in the data source.
|
static Map<Columns,Map<String,SimplifiedIntervalList>> |
DataSourceMetadata.getIntervalLists(DataSourceMetadata metadata)
Return a pair of maps containing the simplified intervals for dimensions and metrics respectively.
|
protected static Map<String,SimplifiedIntervalList> |
DataSourceMetadataService.groupIntervalByColumn(DataSourceMetadata metadata)
Group interval in segment metadata by column.
|
Modifier and Type | Method and Description |
---|---|
default SimplifiedIntervalList |
PhysicalTable.getAvailableIntervals()
Return a view of the available intervals.
|
SimplifiedIntervalList |
ConstrainedTable.getAvailableIntervals() |
SimplifiedIntervalList |
BasePhysicalTable.getAvailableIntervals(DataSourceConstraint constraint) |
default SimplifiedIntervalList |
PhysicalTable.getAvailableIntervals(DataSourceConstraint constraint)
Return a view of the available intervals for this table given a constraint.
|
SimplifiedIntervalList |
ConstrainedTable.getAvailableIntervals(DataSourceConstraint constraint)
Return a view of the available intervals for the original source table given a constraint.
|
Modifier and Type | Method and Description |
---|---|
Map<Column,SimplifiedIntervalList> |
BasePhysicalTable.getAllAvailableIntervals() |
Map<Column,SimplifiedIntervalList> |
PhysicalTable.getAllAvailableIntervals()
Getter for all the available intervals for the corresponding columns configured on the table.
|
Map<Column,SimplifiedIntervalList> |
ConstrainedTable.getAllAvailableIntervals() |
default Map<Column,SimplifiedIntervalList> |
PhysicalTable.mapToSchemaAvailability(Map<String,SimplifiedIntervalList> rawIntervals,
PhysicalTableSchema schema)
Map availabilities in schema-less columns to a
Column keyed availability map for a given table. |
Modifier and Type | Method and Description |
---|---|
default Map<Column,SimplifiedIntervalList> |
PhysicalTable.mapToSchemaAvailability(Map<String,SimplifiedIntervalList> rawIntervals,
PhysicalTableSchema schema)
Map availabilities in schema-less columns to a
Column keyed availability map for a given table. |
Modifier and Type | Method and Description |
---|---|
Map<String,SimplifiedIntervalList> |
BaseMetadataAvailability.getAllAvailableIntervals() |
Map<String,SimplifiedIntervalList> |
BaseCompositeAvailability.getAllAvailableIntervals()
Retrieve all available intervals for all data source fields across all the underlying datasources.
|
Map<String,SimplifiedIntervalList> |
Availability.getAllAvailableIntervals()
The availability of all columns.
|
Modifier and Type | Method and Description |
---|---|
static SimplifiedIntervalList |
IntervalUtils.collectBucketedIntervalsIntersectingIntervalList(SimplifiedIntervalList supplyIntervals,
SimplifiedIntervalList bucketedIntervals,
Granularity granularity)
Collect all subintervals of an interval list of a grain bucketed size which are subintervals of another supply
list of intervals.
|
static SimplifiedIntervalList |
TableUtils.getConstrainedLogicalTableAvailability(LogicalTable logicalTable,
QueryPlanningConstraint queryPlanningConstraint)
Returns union of constrained availabilities of constrained logical table.
|
SimplifiedIntervalList |
SimplifiedIntervalList.intersect(SimplifiedIntervalList that)
Return the intersection of all subintervals in two interval lists.
|
static SimplifiedIntervalList |
TableUtils.logicalTableAvailability(LogicalTable logicalTable)
Returns union of availabilities of the logical table.
|
static SimplifiedIntervalList |
SimplifiedIntervalList.simplifyIntervals(Collection<org.joda.time.Interval>... intervals)
Takes one or more lists of intervals, and combines them into a single, sorted list with the minimum number of
intervals needed to capture exactly the same instants as the original intervals.
|
SimplifiedIntervalList |
SimplifiedIntervalList.subtract(SimplifiedIntervalList that)
Return the subtracted list of all intervals in this that are not in that.
|
SimplifiedIntervalList |
SimplifiedIntervalList.union(SimplifiedIntervalList that)
Return the union of this simplified interval list and the intervals of another.
|
Modifier and Type | Method and Description |
---|---|
static Collector<org.joda.time.Interval,SimplifiedIntervalList,SimplifiedIntervalList> |
SimplifiedIntervalList.getCollector()
Build a collector which appends overlapping intervals, merging and simplifying as it goes.
|
static Collector<org.joda.time.Interval,SimplifiedIntervalList,SimplifiedIntervalList> |
SimplifiedIntervalList.getCollector()
Build a collector which appends overlapping intervals, merging and simplifying as it goes.
|
Modifier and Type | Method and Description |
---|---|
static SimplifiedIntervalList |
IntervalUtils.collectBucketedIntervalsIntersectingIntervalList(SimplifiedIntervalList supplyIntervals,
SimplifiedIntervalList bucketedIntervals,
Granularity granularity)
Collect all subintervals of an interval list of a grain bucketed size which are subintervals of another supply
list of intervals.
|
SimplifiedIntervalList |
SimplifiedIntervalList.intersect(SimplifiedIntervalList that)
Return the intersection of all subintervals in two interval lists.
|
SimplifiedIntervalList |
SimplifiedIntervalList.subtract(SimplifiedIntervalList that)
Return the subtracted list of all intervals in this that are not in that.
|
SimplifiedIntervalList |
SimplifiedIntervalList.union(SimplifiedIntervalList that)
Return the union of this simplified interval list and the intervals of another.
|
Constructor and Description |
---|
IsSubinterval(SimplifiedIntervalList supplyList)
Construct a subinterval predicate that closes over a supply of intervals.
|
SimplifiedIntervalList(SimplifiedIntervalList intervals)
If the intervals are already simplified, simply copy the list.
|
SkippingIntervalPredicate(SimplifiedIntervalList supplyList,
BiPredicate<org.joda.time.Interval,org.joda.time.Interval> testPredicate,
boolean defaultValue)
Constructor to build a predicate that applies an arbitrary predicate to not-before intervals from the
iterator.
|
Modifier and Type | Field and Description |
---|---|
protected SimplifiedIntervalList |
ResponseData.missingIntervals |
protected SimplifiedIntervalList |
ResponseData.volatileIntervals |
Modifier and Type | Method and Description |
---|---|
SimplifiedIntervalList |
ResponseData.getMissingIntervals() |
SimplifiedIntervalList |
ResponseData.getVolatileIntervals() |
Modifier and Type | Method and Description |
---|---|
void |
JsonAndJsonApiResponseWriter.writeMetaObject(com.fasterxml.jackson.core.JsonGenerator generator,
Collection<org.joda.time.Interval> missingIntervals,
SimplifiedIntervalList volatileIntervals,
ResponseData responseData)
Builds the meta object for the JSON response.
|
Constructor and Description |
---|
ResponseData(ResultSet resultSet,
DataApiRequest apiRequest,
SimplifiedIntervalList missingIntervals,
SimplifiedIntervalList volatileIntervals,
Pagination pagination,
Map<String,URI> paginationLinks)
Deprecated.
All the values needed to build a Response should be passed explicitly instead of relying on the
DataApiRequest
|
ResponseData(ResultSet resultSet,
LinkedHashSet<String> apiMetricColumnNames,
LinkedHashMap<Dimension,LinkedHashSet<DimensionField>> requestedApiDimensionFields,
SimplifiedIntervalList missingIntervals,
SimplifiedIntervalList volatileIntervals,
Pagination pagination,
Map<String,URI> paginationLinks)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
static SimplifiedIntervalList |
PartialDataRequestHandler.getPartialIntervalsWithDefault(Map<String,Serializable> context)
Return the missing intervals from the context.
|
static SimplifiedIntervalList |
VolatileDataRequestHandler.getVolatileIntervalsWithDefault(Map<String,Serializable> context)
Return the volatile intervals from the context.
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.