| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
CardinalityAggregatorFactory.factorize(ColumnSelectorFactory columnFactory)  | 
BufferAggregator | 
CardinalityAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
DoublesSketchMergeAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
DoublesSketchAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
DoublesSketchMergeAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
DoublesSketchAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
SketchAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
SketchAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
DistinctCountAggregatorFactory.factorize(ColumnSelectorFactory columnFactory)  | 
BufferAggregator | 
DistinctCountAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
LongFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
FloatFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
DoubleFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
LongFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
FloatFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
DoubleFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
ApproximateHistogramFoldingAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
ApproximateHistogramAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
ApproximateHistogramFoldingAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
ApproximateHistogramAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
HyperUniquesAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
HyperUniquesAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
LongLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
FloatLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
DoubleLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
LongLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
FloatLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
DoubleLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
VarianceAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
VarianceAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| 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. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
RowBasedColumnSelectorFactory  | 
| 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,
                 com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
                 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)  | 
| Modifier and Type | Method and Description | 
|---|---|
ColumnSelectorFactory | 
Cursor.getColumnSelectorFactory()  | 
ColumnSelectorFactory | 
VirtualColumns.wrap(ColumnSelectorFactory baseFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
static <ColumnSelectorStrategyClass extends ColumnSelectorStrategy> | 
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> | 
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. 
 | 
static ColumnValueSelector | 
DimensionHandlerUtils.getColumnValueSelectorFromDimensionSpec(DimensionSpec dimSpec,
                                       ColumnSelectorFactory columnSelectorFactory)  | 
ColumnValueSelector<?> | 
MapVirtualColumn.makeColumnValueSelector(String columnName,
                       ColumnSelectorFactory factory)  | 
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 | 
MapVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec,
                     ColumnSelectorFactory factory)  | 
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)  | 
| 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. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
VirtualizedColumnSelectorFactory  | 
| 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. | 
| Constructor and Description | 
|---|
VirtualizedColumnSelectorFactory(ColumnSelectorFactory baseFactory,
                                VirtualColumns virtualColumns)  | 
Copyright © 2011–2018. All rights reserved.