io.druid.query

Class BaseQuery<T extends Comparable<T>>

java.lang.Object

io.druid.query.BaseQuery<T>

All Implemented Interfaces:

Query<T>

Direct Known Subclasses:

DataSourceMetadataQuery, GroupByQuery, ScanQuery, SearchQuery, SegmentMetadataQuery, SelectQuery, TimeBoundaryQuery, TimeseriesQuery, TopNQuery

public abstract class BaseQuery<T extends Comparable<T>>
extends Object
implements Query<T>

Field Summary

Fields

Modifier and Type	Field and Description
static String	QUERYID

Fields inherited from interface io.druid.query.Query

DATASOURCE_METADATA, GROUP_BY, SEARCH, SEGMENT_METADATA, SELECT, TIME_BOUNDARY, TIMESERIES, TOPN

Constructor Summary

Constructors

Constructor and Description
BaseQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, boolean descending, Map<String,Object> context)

Method Summary

Modifier and Type	Method and Description
protected Map<String,Object>	computeOverridenContext(Map<String,Object> overrides)
boolean	equals(Object o)
Map<String,Object>	getContext()
boolean	getContextBoolean(String key, boolean defaultValue)
static <T> boolean	getContextBySegment(Query<T> query, boolean defaultValue)
static <T> boolean	getContextFinalize(Query<T> query, boolean defaultValue)
static <T> boolean	getContextPopulateCache(Query<T> query, boolean defaultValue)
static <T> int	getContextPriority(Query<T> query, int defaultValue)
static <T> int	getContextUncoveredIntervalsLimit(Query<T> query, int defaultValue)
static <T> boolean	getContextUseCache(Query<T> query, boolean defaultValue)
<ContextType> ContextType	getContextValue(String key)
<ContextType> ContextType	getContextValue(String key, ContextType defaultValue)
DataSource	getDataSource()
org.joda.time.Duration	getDuration()
String	getId()
List<org.joda.time.Interval>	getIntervals()
QuerySegmentSpec	getQuerySegmentSpec()
com.google.common.collect.Ordering<T>	getResultOrdering()
int	hashCode()
boolean	isDescending()
Sequence<T>	run(QueryRunner<T> runner, Map<String,Object> context)
Sequence<T>	run(QuerySegmentWalker walker, Map<String,Object> context)
Query	withId(String id)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.druid.query.Query

getFilter, getType, hasFilters, withDataSource, withOverriddenContext, withQuerySegmentSpec

Field Detail

QUERYID

public static final String QUERYID

See Also:

Constant Field Values

Constructor Detail

BaseQuery

public BaseQuery(DataSource dataSource,
                 QuerySegmentSpec querySegmentSpec,
                 boolean descending,
                 Map<String,Object> context)

Method Detail

getContextPriority

public static <T> int getContextPriority(Query<T> query,
                                         int defaultValue)

getContextBySegment

public static <T> boolean getContextBySegment(Query<T> query,
                                              boolean defaultValue)

getContextPopulateCache

public static <T> boolean getContextPopulateCache(Query<T> query,
                                                  boolean defaultValue)

getContextUseCache

public static <T> boolean getContextUseCache(Query<T> query,
                                             boolean defaultValue)

getContextFinalize

public static <T> boolean getContextFinalize(Query<T> query,
                                             boolean defaultValue)

getContextUncoveredIntervalsLimit

public static <T> int getContextUncoveredIntervalsLimit(Query<T> query,
                                                        int defaultValue)

getDataSource

public DataSource getDataSource()

Specified by:

getDataSource in interface Query<T extends Comparable<T>>

isDescending

public boolean isDescending()

Specified by:

isDescending in interface Query<T extends Comparable<T>>

getQuerySegmentSpec

public QuerySegmentSpec getQuerySegmentSpec()

run

public Sequence<T> run(QuerySegmentWalker walker,
                       Map<String,Object> context)

Specified by:

run in interface Query<T extends Comparable<T>>

run

public Sequence<T> run(QueryRunner<T> runner,
                       Map<String,Object> context)

Specified by:

run in interface Query<T extends Comparable<T>>

getIntervals

public List<org.joda.time.Interval> getIntervals()

Specified by:

getIntervals in interface Query<T extends Comparable<T>>

getDuration

public org.joda.time.Duration getDuration()

Specified by:

getDuration in interface Query<T extends Comparable<T>>

getContext

public Map<String,Object> getContext()

Specified by:

getContext in interface Query<T extends Comparable<T>>

getContextValue

public <ContextType> ContextType getContextValue(String key)

Specified by:

getContextValue in interface Query<T extends Comparable<T>>

getContextValue

public <ContextType> ContextType getContextValue(String key,
                                                 ContextType defaultValue)

Specified by:

getContextValue in interface Query<T extends Comparable<T>>

getContextBoolean

public boolean getContextBoolean(String key,
                                 boolean defaultValue)

Specified by:

getContextBoolean in interface Query<T extends Comparable<T>>

computeOverridenContext

protected Map<String,Object> computeOverridenContext(Map<String,Object> overrides)

getResultOrdering

public com.google.common.collect.Ordering<T> getResultOrdering()

Specified by:

getResultOrdering in interface Query<T extends Comparable<T>>

getId

public String getId()

Specified by:

getId in interface Query<T extends Comparable<T>>

withId

public Query withId(String id)

Specified by:

withId in interface Query<T extends Comparable<T>>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object