Package org.apache.druid.query.union

Class UnionQuery

java.lang.Object

org.apache.druid.query.union.UnionQuery

All Implemented Interfaces:

Query<Object>

public class UnionQuery
extends Object
implements Query<Object>

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,Object>	context
protected final List<Query<?>>	queries

Fields inherited from interface org.apache.druid.query.Query

DATASOURCE_METADATA, GROUP_BY, SCAN, SEARCH, SEGMENT_METADATA, SELECT, TIME_BOUNDARY, TIMESERIES, TOPN, UNION_QUERY, WINDOW_OPERATOR

Constructor Summary

Constructors

Constructor	Description
UnionQuery(List<Query<?>> queries)
UnionQuery(List<Query<?>> queries, Map<String,Object> context)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	getContext()	Returns the context as an (immutable) map.
DataSource	getDataSource()
List<DataSource>	getDataSources()
org.joda.time.Duration	getDuration()
DimFilter	getFilter()
Granularity	getGranularity()
String	getId()
List<org.joda.time.Interval>	getIntervals()
com.google.common.collect.Ordering<Object>	getResultOrdering()	Comparator that represents the order in which results are generated from the QueryRunnerFactory.createRunner(Segment) and QueryRunnerFactory.mergeRunners(QueryProcessingPool, Iterable) calls.
RowSignature	getResultRowSignature(RowSignature.Finalization finalization)
QueryRunner<Object>	getRunner(QuerySegmentWalker walker)
String	getSubQueryId()	Returns the subQueryId of this query.
org.joda.time.DateTimeZone	getTimezone()
String	getType()
boolean	hasFilters()
static DruidException	methodNotSupported()
String	toString()
Query<Object>	withDataSource(DataSource dataSource)
Query<Object>	withDataSources(List<DataSource> children)
Query<Object>	withId(String id)
Query<Object>	withOverriddenContext(Map<String,Object> contextOverrides)
Query<Object>	withQuerySegmentSpec(QuerySegmentSpec spec)	Returns a new query, identical to this one, but with a different associated QuerySegmentSpec.
Query<Object>	withSubQueryId(String subQueryId)	Returns a copy of this query with a new subQueryId (see Query.getSubQueryId().

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.druid.query.Query

context, getContextBoolean, getContextHumanReadableBytes, getContextValue, getMostSpecificId, getRequiredColumns, getResultRowSignature, getSingleInterval, getSqlQueryId, getVirtualColumns, mayCollapseQueryDataSource, optimizeForSegment, withDefaultSubQueryId, withLane, withPriority, withSqlQueryId

Field Details

context

protected final Map<String,Object> context

queries

protected final List<Query<?>> queries

Constructor Details

UnionQuery

public UnionQuery(List<Query<?>> queries)

UnionQuery

public UnionQuery(List<Query<?>> queries,
 Map<String,Object> context)

Method Details

getDataSource

public DataSource getDataSource()

Specified by:

getDataSource in interface Query<Object>

getDataSources

public List<DataSource> getDataSources()

hasFilters

public boolean hasFilters()

Specified by:

hasFilters in interface Query<Object>

getFilter

public DimFilter getFilter()

Specified by:

getFilter in interface Query<Object>

getType

public String getType()

Specified by:

getType in interface Query<Object>

getRunner

public QueryRunner<Object> getRunner(QuerySegmentWalker walker)

Specified by:

getRunner in interface Query<Object>

getIntervals

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

Specified by:

getIntervals in interface Query<Object>

getDuration

public org.joda.time.Duration getDuration()

Specified by:

getDuration in interface Query<Object>

getGranularity

public Granularity getGranularity()

Specified by:

getGranularity in interface Query<Object>

getTimezone

public org.joda.time.DateTimeZone getTimezone()

Specified by:

getTimezone in interface Query<Object>

getContext

public Map<String,Object> getContext()

Description copied from interface: Query

Returns the context as an (immutable) map.

Specified by:

getContext in interface Query<Object>

getResultOrdering

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

Description copied from interface: Query

Comparator that represents the order in which results are generated from the QueryRunnerFactory.createRunner(Segment) and QueryRunnerFactory.mergeRunners(QueryProcessingPool, Iterable) calls. This is used to combine streams of results from different sources; for example, it's used by historicals to combine streams from different segments, and it's used by the broker to combine streams from different historicals.

Important note: sometimes, this ordering is used in a type-unsafe way to order @{code Result} objects. Because of this, implementations should fall back to Ordering.natural() when they are given an object that is not of type T.

Specified by:

getResultOrdering in interface Query<Object>

withOverriddenContext

public Query<Object> withOverriddenContext(Map<String,Object> contextOverrides)

Specified by:

withOverriddenContext in interface Query<Object>

withQuerySegmentSpec

public Query<Object> withQuerySegmentSpec(QuerySegmentSpec spec)

Description copied from interface: Query

Returns a new query, identical to this one, but with a different associated QuerySegmentSpec.

This often changes the behavior of Query.getRunner(QuerySegmentWalker), since most queries inherit that method from BaseQuery, which implements it by calling QuerySegmentSpec.lookup(org.apache.druid.query.Query<T>, org.apache.druid.query.QuerySegmentWalker).

Specified by:

withQuerySegmentSpec in interface Query<Object>

withId

public Query<Object> withId(String id)

Specified by:

withId in interface Query<Object>

getId

public String getId()

Specified by:

getId in interface Query<Object>

withSubQueryId

public Query<Object> withSubQueryId(String subQueryId)

Description copied from interface: Query

Returns a copy of this query with a new subQueryId (see Query.getSubQueryId().

Specified by:

withSubQueryId in interface Query<Object>

getSubQueryId

public String getSubQueryId()

Description copied from interface: Query

Returns the subQueryId of this query. This is set by ClientQuerySegmentWalker (the entry point for the Broker's query stack) on any subqueries that it issues. It is null for the main query.

Specified by:

getSubQueryId in interface Query<Object>

withDataSource

public Query<Object> withDataSource(DataSource dataSource)

Specified by:

withDataSource in interface Query<Object>

withDataSources

public Query<Object> withDataSources(List<DataSource> children)

toString

public String toString()

Overrides:

toString in class Object

methodNotSupported

public static DruidException methodNotSupported()

getResultRowSignature

public RowSignature getResultRowSignature(RowSignature.Finalization finalization)

Specified by:

getResultRowSignature in interface Query<Object>