io.druid.query

Class BaseQuery<T>

java.lang.Object

io.druid.query.BaseQuery<T>

All Implemented Interfaces:

Query<T>

Direct Known Subclasses:

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

public abstract class BaseQuery<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, Map<String,Object> context)

Method Summary

Methods

Modifier and Type	Method and Description
protected Map<String,Object>	computeOverridenContext(Map<String,Object> overrides)
boolean	equals(Object o)
Map<String,Object>	getContext()
boolean	getContextBySegment(boolean defaultValue)
boolean	getContextFinalize(boolean defaultValue)
boolean	getContextPopulateCache(boolean defaultValue)
int	getContextPriority(int defaultValue)
boolean	getContextUseCache(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()
int	hashCode()
com.metamx.common.guava.Sequence<T>	run(QueryRunner<T> runner, Map<String,Object> context)
com.metamx.common.guava.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

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,
         Map<String,Object> context)

Method Detail

getDataSource

public DataSource getDataSource()

Specified by:

getDataSource in interface Query<T>

getQuerySegmentSpec

public QuerySegmentSpec getQuerySegmentSpec()

run

public com.metamx.common.guava.Sequence<T> run(QuerySegmentWalker walker,
                                      Map<String,Object> context)

Specified by:

run in interface Query<T>

run

public com.metamx.common.guava.Sequence<T> run(QueryRunner<T> runner,
                                      Map<String,Object> context)

Specified by:

run in interface Query<T>

getIntervals

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

Specified by:

getIntervals in interface Query<T>

getDuration

public org.joda.time.Duration getDuration()

Specified by:

getDuration in interface Query<T>

getContext

public Map<String,Object> getContext()

Specified by:

getContext in interface Query<T>

getContextValue

public <ContextType> ContextType getContextValue(String key)

Specified by:

getContextValue in interface Query<T>

getContextValue

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

Specified by:

getContextValue in interface Query<T>

getContextPriority

public int getContextPriority(int defaultValue)

Specified by:

getContextPriority in interface Query<T>

getContextBySegment

public boolean getContextBySegment(boolean defaultValue)

Specified by:

getContextBySegment in interface Query<T>

getContextPopulateCache

public boolean getContextPopulateCache(boolean defaultValue)

Specified by:

getContextPopulateCache in interface Query<T>

getContextUseCache

public boolean getContextUseCache(boolean defaultValue)

Specified by:

getContextUseCache in interface Query<T>

getContextFinalize

public boolean getContextFinalize(boolean defaultValue)

Specified by:

getContextFinalize in interface Query<T>

computeOverridenContext

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

getId

public String getId()

Specified by:

getId in interface Query<T>

withId

public Query withId(String id)

Specified by:

withId in interface Query<T>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object