Modifier and Type | Method and Description |
---|---|
protected GroupByQuery |
DruidQueryBuilder.buildGroupByQuery(TemplateDruidQuery template,
ConstrainedTable table,
Granularity granularity,
org.joda.time.DateTimeZone timeZone,
Set<Dimension> groupByDimensions,
Filter filter,
Having having,
Set<org.joda.time.Interval> intervals,
LimitSpec druidOrderBy)
Builds a druid groupBy query recursively nesting dataSource based on the TemplateDruidQuery.
|
protected TimeSeriesQuery |
DruidQueryBuilder.buildTimeSeriesQuery(TemplateDruidQuery template,
ConstrainedTable table,
Granularity granularity,
org.joda.time.DateTimeZone timeZone,
Filter filter,
Set<org.joda.time.Interval> intervals)
Builds a druid TimeSeries query.
|
protected TopNQuery |
DruidQueryBuilder.buildTopNQuery(TemplateDruidQuery template,
ConstrainedTable table,
Granularity granularity,
org.joda.time.DateTimeZone timeZone,
Set<Dimension> groupByDimension,
Filter filter,
Set<org.joda.time.Interval> intervals,
TopNMetric metricSpec,
int topN)
Builds a druid topN query.
|
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 |
---|
ResultSetSchema(Granularity granularity,
Iterable<Column> columns)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
default boolean |
ApiMetricName.isValidFor(Granularity granularity)
Determine if this API Metric Name is valid for the given time grain.
|
default boolean |
ApiMetricName.isValidFor(Granularity granularity,
LogicalMetric logicalMetric)
Determine if this API Metric Name is valid for the given time grain.
|
Modifier and Type | Method and Description |
---|---|
LogicalTable |
BaseTableLoader.buildLogicalTable(String name,
Granularity granularity,
String category,
String longName,
org.joda.time.ReadablePeriod retention,
String description,
TableGroup group,
MetricDictionary metrics)
Deprecated.
The LogicalTable constructor is being mirrored here, can be referenced directly
|
LogicalTable |
BaseTableLoader.buildLogicalTable(String name,
Granularity granularity,
TableGroup group,
MetricDictionary metrics)
Deprecated.
use new LogicalTable(...) by preferences
|
Modifier and Type | Method and Description |
---|---|
void |
BaseTableLoader.loadLogicalTablesWithGranularities(Map<String,TableGroup> nameGroupMap,
Set<? extends Granularity> validGrains,
LogicalTableDictionary tableDictionary,
Map<String,MetricDictionary> scopedMetrics)
Load several logical tables into the logicalDictionary, each with their own scoped metric dictionary.
|
void |
BaseTableLoader.loadLogicalTablesWithGranularities(Map<String,TableGroup> nameGroupMap,
Set<? extends Granularity> validGrains,
ResourceDictionaries dictionaries)
Load several logical tables into the logicalDictionary, all with the globally-scoped metric dictionary.
|
void |
BaseTableLoader.loadLogicalTableWithGranularities(String logicalTableName,
TableGroup nameGroup,
Set<? extends Granularity> validGrains,
LogicalTableDictionary tableDictionary,
MetricDictionary metricDictionary)
Load a logical table into the logicalDictionary.
|
void |
BaseTableLoader.loadLogicalTableWithGranularities(String logicalTableName,
TableGroup nameGroup,
Set<? extends Granularity> validGrains,
ResourceDictionaries dictionaries)
Load a logical table into the logicalDictionary.
|
Modifier and Type | Method and Description |
---|---|
Granularity |
TemplateDruidQuery.getGranularity() |
Modifier and Type | Method and Description |
---|---|
TemplateDruidQuery |
TemplateDruidQuery.withGranularity(Granularity granularity)
With granularity is partially implemented because TemplateDruidQuery supports only ZonelessTimeGrains.
|
Modifier and Type | Interface and Description |
---|---|
interface |
TimeGrain
TimeGrain represents a strategy for Granularities to map time into monotonic increasing time buckets.
|
interface |
ZonelessTimeGrain
An interface to support classes which implement a Time Grain without Zone information.
|
Modifier and Type | Class and Description |
---|---|
class |
AllGranularity
All granularity buckets any number and length of intervals into a single bucket.
|
class |
DefaultTimeGrain
DefaultTimeGrain are a set of concrete TimeGrain implementations which support 'natural', simple to describe time
blocks corresponding to standard rounding rules.
|
class |
ZonedTimeGrain
TimeGrain with a time zone and a Zoneless Time Grain.
|
Modifier and Type | Method and Description |
---|---|
Granularity |
GranularityParser.parseGranularity(String granularityName)
Parse a granularity from a string.
|
Granularity |
StandardGranularityParser.parseGranularity(String granularityName) |
Granularity |
GranularityParser.parseGranularity(String granularityName,
org.joda.time.DateTimeZone dateTimeZone)
Parse a granularity from a string and time zone.
|
Granularity |
StandardGranularityParser.parseGranularity(String granularityName,
org.joda.time.DateTimeZone dateTimeZone) |
Modifier and Type | Method and Description |
---|---|
default boolean |
TimeGrain.satisfiedBy(Granularity that) |
boolean |
AllGranularity.satisfiedBy(Granularity that)
Any granularity can be rolled up into all.
|
boolean |
Granularity.satisfiedBy(Granularity that)
Determine if this granularity can be fulfilled by an aggregate of another granularity.
|
default boolean |
Granularity.satisfies(Granularity that)
Determine the reciprocal relationship to satisfiedBy, that this granularity fulfils an aggregate of another
granularity.
|
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
Granularity |
TimeFormatExtractionFunction.getGranularity()
Returns
granularity of this
TimeFormatExtractionFunction . |
Modifier and Type | Method and Description |
---|---|
TimeFormatExtractionFunction |
TimeFormatExtractionFunction.withGranularity(Granularity granularity)
Returns a new
TimeFormatExtractionFunction with a specified
granularity . |
Constructor and Description |
---|
TimeFormatExtractionFunction(String format,
Locale locale,
org.joda.time.DateTimeZone timeZone,
Granularity granularity,
Boolean asMillis)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected Granularity |
AbstractDruidFactQuery.granularity |
Modifier and Type | Method and Description |
---|---|
Granularity |
AbstractDruidFactQuery.getGranularity() |
Granularity |
LookbackQuery.getGranularity() |
Granularity |
WeightEvaluationQuery.getGranularity() |
Granularity |
DruidFactQuery.getGranularity()
Returns the time grain (granularity) of the query.
|
Modifier and Type | Method and Description |
---|---|
DruidSearchQuery |
DruidSearchQuery.withGranularity(Granularity granularity) |
TopNQuery |
TopNQuery.withGranularity(Granularity granularity) |
LookbackQuery |
LookbackQuery.withGranularity(Granularity granularity) |
TimeSeriesQuery |
TimeSeriesQuery.withGranularity(Granularity granularity) |
GroupByQuery |
GroupByQuery.withGranularity(Granularity granularity) |
Q |
DruidFactQuery.withGranularity(Granularity granularity)
Returns a copy of this query with the specified time grain.
|
Constructor and Description |
---|
AbstractDruidAggregationQuery(QueryType queryType,
DataSource dataSource,
Granularity granularity,
Collection<Dimension> dimensions,
Filter filter,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
QueryContext context,
boolean doFork)
Constructor.
|
AbstractDruidFactQuery(QueryType queryType,
DataSource dataSource,
Granularity granularity,
Filter filter,
Collection<org.joda.time.Interval> intervals,
QueryContext context,
boolean doFork)
Constructor.
|
DruidSearchQuery(DataSource dataSource,
Granularity granularity,
Filter filter,
Collection<org.joda.time.Interval> intervals,
Collection<Dimension> searchDimensions,
SearchQuerySpec query,
SearchSortDirection sort,
Integer limit)
Constructor.
|
DruidSearchQuery(DataSource dataSource,
Granularity granularity,
Filter filter,
Collection<org.joda.time.Interval> intervals,
Collection<Dimension> searchDimensions,
SearchQuerySpec query,
SearchSortDirection sort,
Integer limit,
QueryContext context,
boolean doFork)
Constructor.
|
GroupByQuery(DataSource dataSource,
Granularity granularity,
Collection<Dimension> dimensions,
Filter filter,
Having having,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
LimitSpec limitSpec)
Constructor.
|
GroupByQuery(DataSource dataSource,
Granularity granularity,
Collection<Dimension> dimensions,
Filter filter,
Having having,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
LimitSpec limitSpec,
QueryContext context,
boolean doFork)
Constructor.
|
TimeSeriesQuery(DataSource dataSource,
Granularity granularity,
Filter filter,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals)
Constructor.
|
TimeSeriesQuery(DataSource dataSource,
Granularity granularity,
Filter filter,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
QueryContext context,
boolean doFork)
Constructor.
|
TopNQuery(DataSource dataSource,
Granularity granularity,
Dimension dimension,
Filter filter,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
long threshold,
TopNMetric metric)
Constructor.
|
TopNQuery(DataSource dataSource,
Granularity granularity,
Dimension dimension,
Filter filter,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
long threshold,
TopNMetric metric,
QueryContext context,
boolean doFork)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
SqlAggregationQuery |
SqlAggregationQuery.withGranularity(Granularity granularity) |
Modifier and Type | Method and Description |
---|---|
static Map<Granularity,List<org.apache.calcite.sql.fun.SqlDatePartFunction>> |
SqlTimeConverter.buildDefaultGranularityToDateFunctionsMap()
Builds the default mapping between
Granularity and the SqlDatePartFunction s needed to group on
and read into a DateTime. |
Modifier and Type | Method and Description |
---|---|
List<org.apache.calcite.rex.RexNode> |
SqlTimeConverter.buildGroupBy(org.apache.calcite.tools.RelBuilder builder,
Granularity granularity,
String timeColumn)
Builds a list of
RexNode which will effectively groupBy the given Granularity . |
List<org.apache.calcite.sql.fun.SqlDatePartFunction> |
SqlTimeConverter.timeGrainToDatePartFunctions(Granularity granularity)
Gets a list of
SqlDatePartFunction to be performed on a timestamp
which can be used to group by the given Granularity . |
Constructor and Description |
---|
SqlTimeConverter(Map<Granularity,List<org.apache.calcite.sql.fun.SqlDatePartFunction>> granularityToDateFunctionMap)
Builds a sql time converter which can group by, filter, and reparse dateTimes from a row in a ResultSet.
|
Modifier and Type | Method and Description |
---|---|
Granularity |
BaseSchema.getGranularity() |
Granularity |
Schema.getGranularity()
Get the time granularity for this Schema.
|
Granularity |
LogicalTable.getGranularity() |
Constructor and Description |
---|
BaseSchema(Granularity granularity,
Iterable<Column> columns)
Constructor.
|
LogicalTable(String name,
Granularity granularity,
TableGroup tableGroup,
MetricDictionary metricDictionary)
Constructor
|
LogicalTable(String name,
String category,
String longName,
Granularity granularity,
org.joda.time.ReadablePeriod retention,
String description,
TableGroup tableGroup,
MetricDictionary metricDictionary)
Constructor.
|
LogicalTableSchema(TableGroup tableGroup,
Granularity granularity,
MetricDictionary metricDictionary)
Constructor.
|
TableIdentifier(String logicalTableName,
Granularity granularity)
Constructor.
|
ZonedSchema(Granularity granularity,
org.joda.time.DateTimeZone dateTimeZone,
Iterable<Column> columns)
Deprecated.
Constructor.
|
Modifier and Type | Method and Description |
---|---|
Granularity |
RequestQueryGranularityResolver.apply(DataApiRequest request,
TemplateDruidQuery templateDruidQuery) |
Granularity |
QueryPlanningConstraint.getMinimumGranularity() |
Granularity |
QueryPlanningConstraint.getRequestGranularity() |
Granularity |
RequestQueryGranularityResolver.resolveAcceptingGrain(DataApiRequest apiRequest,
TemplateDruidQuery query)
Get the a granularity which must be satisfied by any answering table granularity for this request.
|
Constructor and Description |
---|
QueryPlanningConstraint(Set<Dimension> requestDimensions,
Set<Dimension> filterDimensions,
Set<Dimension> metricDimensions,
Set<String> metricNames,
ApiFilters apiFilters,
LogicalTable logicalTable,
Set<org.joda.time.Interval> intervals,
Set<LogicalMetric> logicalMetrics,
Granularity minimumGranularity,
Granularity requestGranularity)
Constructor.
|
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 long |
IntervalUtils.countSlicedIntervals(Collection<org.joda.time.Interval> rawIntervals,
Granularity grain)
Count the intervals after simplifying raw intervals and splitting by grain.
|
static Map<org.joda.time.Interval,AtomicInteger> |
IntervalUtils.getSlicedIntervals(Collection<org.joda.time.Interval> rawIntervals,
Granularity grain)
Simplify raw intervals and return a map of intervals (dividing them by the grain) to the ordinal of the interval.
|
static org.joda.time.DateTimeZone |
DateTimeUtils.getTimeZone(Granularity granularity)
Given a granularity, produce a time zone.
|
Modifier and Type | Method and Description |
---|---|
protected Granularity |
ApiRequestImpl.generateGranularity(String granularity,
org.joda.time.DateTimeZone dateTimeZone,
GranularityParser granularityParser)
Generate a Granularity instance based on a path element.
|
protected Granularity |
ApiRequestImpl.generateGranularity(String granularity,
GranularityParser granularityParser)
Generate a Granularity instance based on a path element.
|
Granularity |
DataApiRequest.getGranularity()
The grain to group the results of this request.
|
Granularity |
TablesApiRequest.getGranularity()
Returns the grain to group the results of this request.
|
Granularity |
DataApiRequestImpl.getGranularity() |
Granularity |
TablesApiRequestImpl.getGranularity() |
Modifier and Type | Method and Description |
---|---|
protected static Set<org.joda.time.Interval> |
ApiRequestImpl.generateIntervals(org.joda.time.DateTime now,
String apiIntervalQuery,
Granularity granularity,
org.joda.time.format.DateTimeFormatter dateTimeFormatter)
Extracts the set of intervals from the api request.
|
protected static Set<org.joda.time.Interval> |
ApiRequestImpl.generateIntervals(String apiIntervalQuery,
Granularity granularity,
org.joda.time.format.DateTimeFormatter dateTimeFormatter)
Extracts the set of intervals from the api request.
|
protected LogicalTable |
ApiRequestImpl.generateTable(String tableName,
Granularity granularity,
LogicalTableDictionary logicalTableDictionary)
Extracts a specific logical table object given a valid table name and a valid granularity.
|
static org.joda.time.DateTime |
ApiRequestImpl.getAsDateTime(org.joda.time.DateTime now,
Granularity granularity,
String dateText,
org.joda.time.format.DateTimeFormatter timeFormatter)
Get datetime from the given input text based on granularity.
|
protected static void |
ApiRequestImpl.validateTimeAlignment(Granularity granularity,
Set<org.joda.time.Interval> intervals)
Throw an exception if any of the intervals are not accepted by this granularity.
|
DataApiRequestImpl |
DataApiRequest.withGranularity(Granularity granularity) |
DataApiRequestImpl |
DataApiRequestImpl.withGranularity(Granularity granularity) |
TablesApiRequest |
TablesApiRequest.withTables(Granularity granularity) |
TablesApiRequest |
TablesApiRequestImpl.withTables(Granularity granularity) |
Constructor and Description |
---|
DataApiRequestImpl(ResponseFormatType format,
Optional<PaginationParameters> paginationParameters,
javax.ws.rs.core.UriInfo uriInfo,
javax.ws.rs.core.Response.ResponseBuilder builder,
LogicalTable table,
Granularity granularity,
Set<Dimension> dimensions,
LinkedHashMap<Dimension,LinkedHashSet<DimensionField>> perDimensionFields,
Set<LogicalMetric> logicalMetrics,
Set<org.joda.time.Interval> intervals,
ApiFilters apiFilters,
Map<LogicalMetric,Set<ApiHaving>> havings,
Having having,
LinkedHashSet<OrderByColumn> sorts,
int count,
int topN,
long asyncAfter,
org.joda.time.DateTimeZone timeZone,
DruidFilterBuilder filterBuilder,
HavingGenerator havingApiGenerator,
Optional<OrderByColumn> dateTimeSort)
All argument constructor, meant to be used for rewriting apiRequest.
|
Modifier and Type | Field and Description |
---|---|
protected Granularity |
ResultSetResponseProcessor.granularity |
Modifier and Type | Method and Description |
---|---|
long |
QueryWeightUtil.getQueryWeightThreshold(Granularity granularity)
Get the weight threshold for the granularity.
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.