Uses of Interface
org.apache.druid.segment.ColumnSelectorFactory

Packages that use ColumnSelectorFactory

Package	Description
org.apache.druid.query.aggregation
org.apache.druid.query.aggregation.cardinality
org.apache.druid.query.aggregation.first
org.apache.druid.query.aggregation.hyperloglog
org.apache.druid.query.aggregation.last
org.apache.druid.query.filter
org.apache.druid.query.groupby
org.apache.druid.query.groupby.epinephelinae
org.apache.druid.segment
org.apache.druid.segment.filter
org.apache.druid.segment.incremental
org.apache.druid.segment.virtual

Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation

Methods in org.apache.druid.query.aggregation with parameters of type ColumnSelectorFactory

Modifier and Type	Method and Description
Aggregator	SuppressedAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	NullableAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	JavaScriptAggregatorFactory.factorize(ColumnSelectorFactory columnFactory)
Aggregator	HistogramAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	FilteredAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory)
Aggregator	CountAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
abstract Aggregator	AggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
protected Aggregator	DoubleSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseDoubleColumnValueSelector selector)
protected Aggregator	DoubleMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseDoubleColumnValueSelector selector)
protected Aggregator	DoubleMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseDoubleColumnValueSelector selector)
protected Aggregator	FloatSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseFloatColumnValueSelector selector)
protected Aggregator	FloatMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseFloatColumnValueSelector selector)
protected Aggregator	FloatMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseFloatColumnValueSelector selector)
protected Aggregator	LongSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseLongColumnValueSelector selector)
Aggregator	LongMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseLongColumnValueSelector selector)
protected Aggregator	LongMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseLongColumnValueSelector selector)
protected abstract Aggregator	NullableAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, T selector) Creates an Aggregator to aggregate values from several rows, by using the provided selector.
BufferAggregator	SuppressedAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)
BufferAggregator	NullableAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)
BufferAggregator	JavaScriptAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory)
BufferAggregator	HistogramAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)
BufferAggregator	FilteredAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory)
BufferAggregator	CountAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)
abstract BufferAggregator	AggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)
protected BufferAggregator	DoubleSumAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseDoubleColumnValueSelector selector)
protected BufferAggregator	DoubleMinAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseDoubleColumnValueSelector selector)
protected BufferAggregator	DoubleMaxAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseDoubleColumnValueSelector selector)
protected BufferAggregator	FloatSumAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseFloatColumnValueSelector selector)
protected BufferAggregator	FloatMinAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseFloatColumnValueSelector selector)
protected BufferAggregator	FloatMaxAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseFloatColumnValueSelector selector)
protected BufferAggregator	LongSumAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseLongColumnValueSelector selector)
BufferAggregator	LongMinAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseLongColumnValueSelector selector)
protected BufferAggregator	LongMaxAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseLongColumnValueSelector selector)
protected abstract BufferAggregator	NullableAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, T selector) Creates an BufferAggregator to aggregate values from several rows into a ByteBuffer.
protected BaseDoubleColumnValueSelector	SimpleDoubleAggregatorFactory.getDoubleColumnSelector(ColumnSelectorFactory metricFactory, double nullValue)
protected abstract T	NullableAggregatorFactory.selector(ColumnSelectorFactory metricFactory) Creates a ColumnValueSelector for the aggregated column.
protected BaseLongColumnValueSelector	LongSumAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected BaseLongColumnValueSelector	LongMinAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected BaseLongColumnValueSelector	LongMaxAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected BaseFloatColumnValueSelector	FloatSumAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected BaseFloatColumnValueSelector	FloatMinAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected BaseFloatColumnValueSelector	FloatMaxAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected BaseDoubleColumnValueSelector	DoubleSumAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected BaseDoubleColumnValueSelector	DoubleMinAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected BaseDoubleColumnValueSelector	DoubleMaxAggregatorFactory.selector(ColumnSelectorFactory metricFactory)

Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation.cardinality

Methods in org.apache.druid.query.aggregation.cardinality with parameters of type ColumnSelectorFactory

Modifier and Type	Method and Description
Aggregator	CardinalityAggregatorFactory.factorize(ColumnSelectorFactory columnFactory)
BufferAggregator	CardinalityAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnFactory)

Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation.first

Methods in org.apache.druid.query.aggregation.first with parameters of type ColumnSelectorFactory

Modifier and Type	Method and Description
Aggregator	StringFirstFoldingAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
Aggregator	StringFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
protected Aggregator	LongFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected Aggregator	FloatFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected Aggregator	DoubleFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
BufferAggregator	StringFirstFoldingAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
BufferAggregator	StringFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
protected BufferAggregator	LongFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected BufferAggregator	FloatFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected BufferAggregator	DoubleFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected BaseObjectColumnValueSelector	StringFirstAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected ColumnValueSelector	LongFirstAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected ColumnValueSelector	FloatFirstAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected ColumnValueSelector	DoubleFirstAggregatorFactory.selector(ColumnSelectorFactory metricFactory)

Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation.hyperloglog

Methods in org.apache.druid.query.aggregation.hyperloglog with parameters of type ColumnSelectorFactory

Modifier and Type	Method and Description
Aggregator	HyperUniquesAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
BufferAggregator	HyperUniquesAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)

Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation.last

Methods in org.apache.druid.query.aggregation.last with parameters of type ColumnSelectorFactory

Modifier and Type	Method and Description
Aggregator	StringLastFoldingAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
Aggregator	StringLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
protected Aggregator	LongLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected Aggregator	FloatLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected Aggregator	DoubleLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
BufferAggregator	StringLastFoldingAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
BufferAggregator	StringLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
protected BufferAggregator	LongLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected BufferAggregator	FloatLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected BufferAggregator	DoubleLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected BaseObjectColumnValueSelector	StringLastAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected ColumnValueSelector	LongLastAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected ColumnValueSelector	FloatLastAggregatorFactory.selector(ColumnSelectorFactory metricFactory)
protected ColumnValueSelector	DoubleLastAggregatorFactory.selector(ColumnSelectorFactory metricFactory)

Uses of ColumnSelectorFactory in org.apache.druid.query.filter

Methods in org.apache.druid.query.filter with parameters of type ColumnSelectorFactory

Modifier and Type	Method and Description
ValueMatcher	BooleanFilter.makeMatcher(BitmapIndexSelector selector, ColumnSelectorFactory columnSelectorFactory, RowOffsetMatcherFactory rowOffsetMatcherFactory) Get a ValueMatcher that applies this filter to row values.
ValueMatcher	Filter.makeMatcher(ColumnSelectorFactory factory) Get a ValueMatcher that applies this filter to row values.

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

Classes in org.apache.druid.query.groupby that implement ColumnSelectorFactory

Modifier and Type	Class and Description
class	RowBasedColumnSelectorFactory

Uses of ColumnSelectorFactory in org.apache.druid.query.groupby.epinephelinae

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

Constructor and Description
BufferArrayGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, int cardinality)
BufferHashGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier, Grouper.KeySerde<KeyType> keySerde, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, int bufferGrouperMaxSize, float maxLoadFactor, int initialBuckets, boolean useDefaultSorting)
ConcurrentGrouper(GroupByQueryConfig groupByQueryConfig, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, ReferenceCountingResourceHolder<ByteBuffer> combineBufferHolder, Grouper.KeySerdeFactory<KeyType> keySerdeFactory, Grouper.KeySerdeFactory<KeyType> combineKeySerdeFactory, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, int concurrencyHint, DefaultLimitSpec limitSpec, boolean sortHasNonGroupingFields, com.google.common.util.concurrent.ListeningExecutorService executor, int priority, boolean hasQueryTimeout, long queryTimeoutAt)
LimitedBufferHashGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier, Grouper.KeySerde<KeyType> keySerde, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, int bufferGrouperMaxSize, float maxLoadFactor, int initialBuckets, int limit, boolean sortHasNonGroupingFields)
SpillingGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier, Grouper.KeySerdeFactory<KeyType> keySerdeFactory, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, int bufferGrouperMaxSize, float bufferGrouperMaxLoadFactor, int bufferGrouperInitialBuckets, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, boolean spillingAllowed, DefaultLimitSpec limitSpec, boolean sortHasNonGroupingFields, int mergeBufferSize)

Uses of ColumnSelectorFactory in org.apache.druid.segment

Methods in org.apache.druid.segment that return ColumnSelectorFactory

Modifier and Type	Method and Description
ColumnSelectorFactory	Cursor.getColumnSelectorFactory()
ColumnSelectorFactory	VirtualColumns.wrap(ColumnSelectorFactory baseFactory)

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

Modifier and Type	Method and Description
static <ColumnSelectorStrategyClass extends ColumnSelectorStrategy> ColumnSelectorPlus<ColumnSelectorStrategyClass>	DimensionHandlerUtils.createColumnSelectorPlus(ColumnSelectorStrategyFactory<ColumnSelectorStrategyClass> strategyFactory, DimensionSpec dimensionSpec, ColumnSelectorFactory cursor) Convenience function equivalent to calling DimensionHandlerUtils.createColumnSelectorPluses(ColumnSelectorStrategyFactory, List, ColumnSelectorFactory) with a singleton list of dimensionSpecs and then retrieving the only element in the returned array.
static <ColumnSelectorStrategyClass extends ColumnSelectorStrategy> ColumnSelectorPlus<ColumnSelectorStrategyClass>[]	DimensionHandlerUtils.createColumnSelectorPluses(ColumnSelectorStrategyFactory<ColumnSelectorStrategyClass> strategyFactory, List<DimensionSpec> dimensionSpecs, ColumnSelectorFactory columnSelectorFactory) Creates an array of ColumnSelectorPlus objects, selectors that handle type-specific operations within query processing engines, using a strategy factory provided by the query engine.
ColumnValueSelector<?>	VirtualColumns.makeColumnValueSelector(String columnName, ColumnSelectorFactory factory) Create a column value selector.
ColumnValueSelector<?>	VirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory factory) Build a selector corresponding to this virtual column.
DimensionSelector	VirtualColumns.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory factory) Create a dimension (string) selector.
DimensionSelector	VirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory factory) Build a selector corresponding to this virtual column.
ColumnSelectorFactory	VirtualColumns.wrap(ColumnSelectorFactory baseFactory)

Uses of ColumnSelectorFactory in org.apache.druid.segment.filter

Methods in org.apache.druid.segment.filter with parameters of type ColumnSelectorFactory

Modifier and Type	Method and Description
ValueMatcher	OrFilter.makeMatcher(BitmapIndexSelector selector, ColumnSelectorFactory columnSelectorFactory, RowOffsetMatcherFactory rowOffsetMatcherFactory)
ValueMatcher	AndFilter.makeMatcher(BitmapIndexSelector selector, ColumnSelectorFactory columnSelectorFactory, RowOffsetMatcherFactory rowOffsetMatcherFactory)
ValueMatcher	TrueFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	SpatialFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	SelectorFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	OrFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	NotFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	LikeFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	JavaScriptFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	InFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	ExpressionFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	DimensionPredicateFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	ColumnComparisonFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	BoundFilter.makeMatcher(ColumnSelectorFactory factory)
ValueMatcher	AndFilter.makeMatcher(ColumnSelectorFactory factory)
static ValueMatcher	Filters.makeValueMatcher(ColumnSelectorFactory columnSelectorFactory, String columnName, DruidPredicateFactory predicateFactory) Create a ValueMatcher that applies a predicate to row values.
static ValueMatcher	Filters.makeValueMatcher(ColumnSelectorFactory columnSelectorFactory, String columnName, String value) Create a ValueMatcher that compares row values to the provided string.

Uses of ColumnSelectorFactory in org.apache.druid.segment.incremental

Methods in org.apache.druid.segment.incremental that return ColumnSelectorFactory

Modifier and Type	Method and Description
protected ColumnSelectorFactory	IncrementalIndex.makeColumnSelectorFactory(AggregatorFactory agg, com.google.common.base.Supplier<InputRow> in, boolean deserializeComplexMetrics)
static ColumnSelectorFactory	IncrementalIndex.makeColumnSelectorFactory(VirtualColumns virtualColumns, AggregatorFactory agg, com.google.common.base.Supplier<InputRow> in, boolean deserializeComplexMetrics) Column selector used at ingestion time for inputs to aggregators.

Uses of ColumnSelectorFactory in org.apache.druid.segment.virtual

Classes in org.apache.druid.segment.virtual that implement ColumnSelectorFactory

Modifier and Type	Class and Description
class	VirtualizedColumnSelectorFactory

Methods in org.apache.druid.segment.virtual with parameters of type ColumnSelectorFactory

Modifier and Type	Method and Description
static ColumnValueSelector	ExpressionSelectors.makeColumnValueSelector(ColumnSelectorFactory columnSelectorFactory, Expr expression) Makes a ColumnValueSelector whose getObject method returns an Object that is the value computed by an ExprEval.
ColumnValueSelector<?>	ExpressionVirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory factory)
static DimensionSelector	ExpressionSelectors.makeDimensionSelector(ColumnSelectorFactory columnSelectorFactory, Expr expression, ExtractionFn extractionFn)
DimensionSelector	ExpressionVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory columnSelectorFactory)
static ColumnValueSelector<ExprEval>	ExpressionSelectors.makeExprEvalSelector(ColumnSelectorFactory columnSelectorFactory, Expr expression) Makes a ColumnValueSelector whose getObject method returns an ExprEval.

Constructors in org.apache.druid.segment.virtual with parameters of type ColumnSelectorFactory

Constructor and Description
VirtualizedColumnSelectorFactory(ColumnSelectorFactory baseFactory, VirtualColumns virtualColumns)