Uses of Interface
org.apache.druid.query.DataSource

Packages that use DataSource

Package	Description
org.apache.druid.query
org.apache.druid.query.datasourcemetadata
org.apache.druid.query.groupby
org.apache.druid.query.metadata.metadata
org.apache.druid.query.operator
org.apache.druid.query.planning
org.apache.druid.query.scan
org.apache.druid.query.search
org.apache.druid.query.select
org.apache.druid.query.timeboundary
org.apache.druid.query.timeseries
org.apache.druid.query.topn
org.apache.druid.query.union
org.apache.druid.segment
org.apache.druid.segment.join

Uses of DataSource in org.apache.druid.query

Classes in org.apache.druid.query that implement DataSource

Modifier and Type	Class	Description
class	FilteredDataSource	This class models a data source to be unnested which is present along with a filter.
class	FrameBasedInlineDataSource	Represents an inline datasource where the rows are embedded within the DataSource object itself.
class	GlobalTableDataSource	TableDataSource variant for globally available 'broadcast' segments.
class	InlineDataSource	Represents an inline datasource, where the rows are embedded within the DataSource object itself.
class	JoinDataSource	Represents a join of two datasources.
class	LeafDataSource	Leaf DataSource-s have no inputs.
class	LookupDataSource	Represents a lookup.
class	QueryDataSource
class	RestrictedDataSource	Reperesents a TableDataSource with policy restriction.
class	TableDataSource
class	UnionDataSource	Reperesents a UNION ALL of two or more datasources.
class	UnnestDataSource	The data source for representing an unnest operation.

Methods in org.apache.druid.query that return DataSource

Modifier and Type	Method	Description
DataSource	FilteredDataSource.getBase()
DataSource	UnnestDataSource.getBase()
DataSource	BaseQuery.getDataSource()
DataSource	Query.getDataSource()
DataSource	JoinDataSource.getLeft()
DataSource	JoinDataSource.getRight()
DataSource	DataSource.withChildren(List<DataSource> children)	Return a new DataSource, identical to this one, with different children.
DataSource	FilteredDataSource.withChildren(List<DataSource> children)
DataSource	JoinDataSource.withChildren(List<DataSource> children)
final DataSource	LeafDataSource.withChildren(List<DataSource> children)
DataSource	QueryDataSource.withChildren(List<DataSource> children)
DataSource	RestrictedDataSource.withChildren(List<DataSource> children)
DataSource	UnionDataSource.withChildren(List<DataSource> children)
DataSource	UnnestDataSource.withChildren(List<DataSource> children)
default DataSource	DataSource.withPolicies(Map<String,Optional<Policy>> policyMap, PolicyEnforcer policyEnforcer)	Returns an updated datasource based on the policy restrictions on tables.
DataSource	RestrictedDataSource.withPolicies(Map<String,Optional<Policy>> policyMap, PolicyEnforcer policyEnforcer)
DataSource	TableDataSource.withPolicies(Map<String,Optional<Policy>> policyMap, PolicyEnforcer policyEnforcer)

Methods in org.apache.druid.query that return types with arguments of type DataSource

Modifier and Type	Method	Description
List<DataSource>	DataSource.getChildren()	Returns datasources that this datasource depends on.
List<DataSource>	FilteredDataSource.getChildren()
List<DataSource>	JoinDataSource.getChildren()
final List<DataSource>	LeafDataSource.getChildren()
List<DataSource>	QueryDataSource.getChildren()
List<DataSource>	RestrictedDataSource.getChildren()
List<DataSource>	UnionDataSource.getChildren()
List<DataSource>	UnnestDataSource.getChildren()

Methods in org.apache.druid.query with parameters of type DataSource

Modifier and Type	Method	Description
static FilteredDataSource	FilteredDataSource.create(DataSource base, DimFilter f)
static JoinDataSource	JoinDataSource.create(DataSource left, DataSource right, String rightPrefix, String condition, JoinType joinType, DimFilter leftFilter, ExprMacroTable macroTable, JoinableFactoryWrapper joinableFactoryWrapper, JoinAlgorithm joinAlgorithm)	Create a join dataSource from a string condition.
static JoinDataSource	JoinDataSource.create(DataSource left, DataSource right, String rightPrefix, JoinConditionAnalysis conditionAnalysis, JoinType joinType, DimFilter leftFilter, JoinableFactoryWrapper joinableFactoryWrapper, JoinAlgorithm joinAlgorithm)	Create a join dataSource from an existing JoinConditionAnalysis.
static RestrictedDataSource	RestrictedDataSource.create(DataSource base, Policy policy)
static UnnestDataSource	UnnestDataSource.create(DataSource base, VirtualColumn virtualColumn, DimFilter unnestFilter)
Druids.DataSourceMetadataQueryBuilder	Druids.DataSourceMetadataQueryBuilder.dataSource(DataSource ds)
Druids.ScanQueryBuilder	Druids.ScanQueryBuilder.dataSource(DataSource ds)
Druids.SearchQueryBuilder	Druids.SearchQueryBuilder.dataSource(DataSource d)
Druids.SegmentMetadataQueryBuilder	Druids.SegmentMetadataQueryBuilder.dataSource(DataSource ds)
Druids.TimeBoundaryQueryBuilder	Druids.TimeBoundaryQueryBuilder.dataSource(DataSource ds)
Druids.TimeseriesQueryBuilder	Druids.TimeseriesQueryBuilder.dataSource(DataSource ds)
static boolean	UnionDataSource.isCompatibleDataSource(DataSource dataSource)
static Query	Queries.withBaseDataSource(Query query, DataSource newBaseDataSource)	Rewrite "query" to refer to some specific base datasource, instead of the one it currently refers to.
Query<T>	Query.withDataSource(DataSource dataSource)

Method parameters in org.apache.druid.query with type arguments of type DataSource

Modifier and Type	Method	Description
DataSource	DataSource.withChildren(List<DataSource> children)	Return a new DataSource, identical to this one, with different children.
DataSource	FilteredDataSource.withChildren(List<DataSource> children)
DataSource	JoinDataSource.withChildren(List<DataSource> children)
final DataSource	LeafDataSource.withChildren(List<DataSource> children)
DataSource	QueryDataSource.withChildren(List<DataSource> children)
DataSource	RestrictedDataSource.withChildren(List<DataSource> children)
DataSource	UnionDataSource.withChildren(List<DataSource> children)
DataSource	UnnestDataSource.withChildren(List<DataSource> children)

Constructors in org.apache.druid.query with parameters of type DataSource

Modifier	Constructor	Description
	BaseQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, Map<String,Object> context)
	BaseQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, Map<String,Object> context, Granularity granularity)

Constructor parameters in org.apache.druid.query with type arguments of type DataSource

Modifier	Constructor	Description
	UnionDataSource(List<DataSource> dataSources)

Uses of DataSource in org.apache.druid.query.datasourcemetadata

Methods in org.apache.druid.query.datasourcemetadata with parameters of type DataSource

Modifier and Type	Method	Description
Query<Result<DataSourceMetadataResultValue>>	DataSourceMetadataQuery.withDataSource(DataSource dataSource)

Constructors in org.apache.druid.query.datasourcemetadata with parameters of type DataSource

Modifier	Constructor	Description
	DataSourceMetadataQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, Map<String,Object> context)

Uses of DataSource in org.apache.druid.query.groupby

Methods in org.apache.druid.query.groupby with parameters of type DataSource

Modifier and Type	Method	Description
GroupByQuery.Builder	GroupByQuery.Builder.setDataSource(DataSource dataSource)
Query<ResultRow>	GroupByQuery.withDataSource(DataSource dataSource)

Constructors in org.apache.druid.query.groupby with parameters of type DataSource

Modifier	Constructor	Description
	GroupByQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, VirtualColumns virtualColumns, DimFilter dimFilter, Granularity granularity, List<DimensionSpec> dimensions, List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs, HavingSpec havingSpec, LimitSpec limitSpec, List<List<String>> subtotalsSpec, Map<String,Object> context)

Uses of DataSource in org.apache.druid.query.metadata.metadata

Methods in org.apache.druid.query.metadata.metadata with parameters of type DataSource

Modifier and Type	Method	Description
Query<SegmentAnalysis>	SegmentMetadataQuery.withDataSource(DataSource dataSource)

Constructors in org.apache.druid.query.metadata.metadata with parameters of type DataSource

Modifier	Constructor	Description
	SegmentMetadataQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, ColumnIncluderator toInclude, Boolean merge, Map<String,Object> context, EnumSet<SegmentMetadataQuery.AnalysisType> analysisTypes, Boolean useDefaultInterval, Boolean lenientAggregatorMerge, AggregatorMergeStrategy aggregatorMergeStrategy)

Uses of DataSource in org.apache.druid.query.operator

Methods in org.apache.druid.query.operator with parameters of type DataSource

Modifier and Type	Method	Description
Query<RowsAndColumns>	WindowOperatorQuery.withDataSource(DataSource dataSource)

Constructors in org.apache.druid.query.operator with parameters of type DataSource

Modifier	Constructor	Description
	WindowOperatorQuery(DataSource dataSource, QuerySegmentSpec intervals, Map<String,Object> context, RowSignature rowSignature, List<OperatorFactory> operators, List<OperatorFactory> leafOperators)

Uses of DataSource in org.apache.druid.query.planning

Fields in org.apache.druid.query.planning declared as DataSource

Modifier and Type	Field	Description
protected final DataSource	ExecutionVertex.baseDataSource	The base datasource which will be read during the execution.

Methods in org.apache.druid.query.planning that return DataSource

Modifier and Type	Method	Description
DataSource	ExecutionVertex.getBaseDataSource()	The base datasource input of this vertex.
DataSource	JoinDataSourceAnalysis.getBaseDataSource()	Returns the base (bottom-leftmost) datasource.
DataSource	PreJoinableClause.getDataSource()
DataSource	PreJoinableClause.maybeUnwrapRestrictedDataSource()	If the data source is a RestrictedDataSource with a NoRestrictionPolicy, unwraps it to a table and return.

Methods in org.apache.druid.query.planning with parameters of type DataSource

Modifier and Type	Method	Description
Query	ExecutionVertex.buildQueryWithBaseDataSource(DataSource newBaseDataSource)
JoinDataSource	PreJoinableClause.makeUpdatedJoinDataSource(DataSource newSource, DimFilter joinBaseFilter, JoinableFactoryWrapper joinableFactoryWrapper)
static ExecutionVertex	ExecutionVertex.ofDataSource(DataSource dataSource)	Builds the ExecutionVertex around a DataSource.

Constructors in org.apache.druid.query.planning with parameters of type DataSource

Modifier	Constructor	Description
	JoinDataSourceAnalysis(DataSource baseDataSource, Query<?> baseQuery, DimFilter joinBaseTableFilter, List<PreJoinableClause> preJoinableClauses, QuerySegmentSpec querySegmentSpec)

Uses of DataSource in org.apache.druid.query.scan

Methods in org.apache.druid.query.scan with parameters of type DataSource

Modifier and Type	Method	Description
ScanQuery	ScanQuery.withDataSource(DataSource dataSource)

Constructors in org.apache.druid.query.scan with parameters of type DataSource

Modifier	Constructor	Description
	ScanQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, VirtualColumns virtualColumns, ScanQuery.ResultFormat resultFormat, int batchSize, long scanRowsOffset, long scanRowsLimit, Order orderFromUser, List<OrderBy> orderBysFromUser, DimFilter dimFilter, List<String> columns, Map<String,Object> context, List<ColumnType> columnTypes)

Uses of DataSource in org.apache.druid.query.search

Methods in org.apache.druid.query.search with parameters of type DataSource

Modifier and Type	Method	Description
Query<Result<SearchResultValue>>	SearchQuery.withDataSource(DataSource dataSource)

Constructors in org.apache.druid.query.search with parameters of type DataSource

Modifier	Constructor	Description
	SearchQuery(DataSource dataSource, DimFilter dimFilter, Granularity granularity, int limit, QuerySegmentSpec querySegmentSpec, List<DimensionSpec> dimensions, VirtualColumns virtualColumns, SearchQuerySpec querySpec, SearchSortSpec sortSpec, Map<String,Object> context)

Uses of DataSource in org.apache.druid.query.select

Methods in org.apache.druid.query.select that return DataSource

Modifier and Type	Method	Description
DataSource	SelectQuery.getDataSource()	Deprecated.

Methods in org.apache.druid.query.select with parameters of type DataSource

Modifier and Type	Method	Description
Query<Object>	SelectQuery.withDataSource(DataSource dataSource)	Deprecated.

Uses of DataSource in org.apache.druid.query.timeboundary

Methods in org.apache.druid.query.timeboundary with parameters of type DataSource

Modifier and Type	Method	Description
Query<Result<TimeBoundaryResultValue>>	TimeBoundaryQuery.withDataSource(DataSource dataSource)

Constructors in org.apache.druid.query.timeboundary with parameters of type DataSource

Modifier	Constructor	Description
	TimeBoundaryQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, String bound, DimFilter dimFilter, Map<String,Object> context)

Uses of DataSource in org.apache.druid.query.timeseries

Methods in org.apache.druid.query.timeseries with parameters of type DataSource

Modifier and Type	Method	Description
Query<Result<TimeseriesResultValue>>	TimeseriesQuery.withDataSource(DataSource dataSource)

Constructors in org.apache.druid.query.timeseries with parameters of type DataSource

Modifier	Constructor	Description
	TimeseriesQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, boolean descending, VirtualColumns virtualColumns, DimFilter dimFilter, Granularity granularity, List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs, int limit, Map<String,Object> context)

Uses of DataSource in org.apache.druid.query.topn

Methods in org.apache.druid.query.topn with parameters of type DataSource

Modifier and Type	Method	Description
TopNQueryBuilder	TopNQueryBuilder.dataSource(DataSource d)
Query<Result<TopNResultValue>>	TopNQuery.withDataSource(DataSource dataSource)

Constructors in org.apache.druid.query.topn with parameters of type DataSource

Modifier	Constructor	Description
	TopNQuery(DataSource dataSource, VirtualColumns virtualColumns, DimensionSpec dimensionSpec, TopNMetricSpec topNMetricSpec, int threshold, QuerySegmentSpec querySegmentSpec, DimFilter dimFilter, Granularity granularity, List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs, Map<String,Object> context)

Uses of DataSource in org.apache.druid.query.union

Methods in org.apache.druid.query.union that return DataSource

Modifier and Type	Method	Description
DataSource	UnionQuery.getDataSource()

Methods in org.apache.druid.query.union that return types with arguments of type DataSource

Modifier and Type	Method	Description
List<DataSource>	UnionQuery.getDataSources()

Methods in org.apache.druid.query.union with parameters of type DataSource

Modifier and Type	Method	Description
Query<Object>	UnionQuery.withDataSource(DataSource dataSource)

Method parameters in org.apache.druid.query.union with type arguments of type DataSource

Modifier and Type	Method	Description
Query<Object>	UnionQuery.withDataSources(List<DataSource> children)

Uses of DataSource in org.apache.druid.segment

Methods in org.apache.druid.segment with parameters of type DataSource

Modifier and Type	Method	Description
Iterable<Segment>	SegmentWrangler.getSegmentsForIntervals(DataSource dataSource, Iterable<org.joda.time.Interval> intervals)	Gets Segments for a particular datasource and set of intervals.

Uses of DataSource in org.apache.druid.segment.join

Methods in org.apache.druid.segment.join with parameters of type DataSource

Modifier and Type	Method	Description
Optional<Joinable>	FrameBasedInlineJoinableFactory.build(DataSource dataSource, JoinConditionAnalysis condition)
Optional<Joinable>	InlineJoinableFactory.build(DataSource dataSource, JoinConditionAnalysis condition)
Optional<Joinable>	JoinableFactory.build(DataSource dataSource, JoinConditionAnalysis condition)	Create a Joinable object.
Optional<Joinable>	MapJoinableFactory.build(DataSource dataSource, JoinConditionAnalysis condition)
Optional<Joinable>	NoopJoinableFactory.build(DataSource dataSource, JoinConditionAnalysis condition)
default Optional<byte[]>	JoinableFactory.computeJoinCacheKey(DataSource dataSource, JoinConditionAnalysis condition)	Compute the cache key for a data source participating in join operation.
Optional<byte[]>	MapJoinableFactory.computeJoinCacheKey(DataSource dataSource, JoinConditionAnalysis condition)
boolean	FrameBasedInlineJoinableFactory.isDirectlyJoinable(DataSource dataSource)
boolean	InlineJoinableFactory.isDirectlyJoinable(DataSource dataSource)
boolean	JoinableFactory.isDirectlyJoinable(DataSource dataSource)	Returns true if a Joinable **may** be created for a given DataSource, but is not a guarantee that JoinableFactory.build(org.apache.druid.query.DataSource, org.apache.druid.segment.join.JoinConditionAnalysis) will return a non-empty result.
boolean	MapJoinableFactory.isDirectlyJoinable(DataSource dataSource)
boolean	NoopJoinableFactory.isDirectlyJoinable(DataSource dataSource)

Constructor parameters in org.apache.druid.segment.join with type arguments of type DataSource

Modifier	Constructor	Description
	MapJoinableFactory(Set<JoinableFactory> factories, Map<Class<? extends JoinableFactory>,Class<? extends DataSource>> factoryToDataSource)