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.