Modifier and Type | Method and Description |
---|---|
Aggregator |
TimestampAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
LongSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
LongMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
LongMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
JavaScriptAggregatorFactory.factorize(ColumnSelectorFactory columnFactory) |
Aggregator |
HistogramAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
FilteredAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory) |
Aggregator |
DoubleSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
DoubleMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
DoubleMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
CountAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
abstract Aggregator |
AggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
BufferAggregator |
TimestampAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) |
BufferAggregator |
LongSumAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) |
BufferAggregator |
LongMinAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) |
BufferAggregator |
LongMaxAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) |
BufferAggregator |
JavaScriptAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory) |
BufferAggregator |
HistogramAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) |
BufferAggregator |
FilteredAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory) |
BufferAggregator |
DoubleSumAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) |
BufferAggregator |
DoubleMinAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) |
BufferAggregator |
DoubleMaxAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) |
BufferAggregator |
CountAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) |
abstract BufferAggregator |
AggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) |
static FloatColumnSelector |
AggregatorUtil.getFloatColumnSelector(ColumnSelectorFactory metricFactory,
String fieldName,
String fieldExpression,
float nullValue) |
static LongColumnSelector |
AggregatorUtil.getLongColumnSelector(ColumnSelectorFactory metricFactory,
String fieldName,
String fieldExpression,
long nullValue) |
Modifier and Type | Method and Description |
---|---|
Aggregator |
CardinalityAggregatorFactory.factorize(ColumnSelectorFactory columnFactory) |
BufferAggregator |
CardinalityAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnFactory) |
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 |
DoubleFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
BufferAggregator |
LongFirstAggregatorFactory.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 |
DoubleLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
BufferAggregator |
LongLastAggregatorFactory.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 |
---|
BufferGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
Grouper.KeySerde<KeyType> keySerde,
ColumnSelectorFactory columnSelectorFactory,
AggregatorFactory[] aggregatorFactories,
int bufferGrouperMaxSize,
float maxLoadFactor,
int initialBuckets) |
ConcurrentGrouper(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,
int concurrencyHint) |
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) |
Modifier and Type | Interface and Description |
---|---|
interface |
Cursor |
Modifier and Type | Method and Description |
---|---|
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 cursor)
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) |
DimensionSelector |
MapVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec,
ColumnSelectorFactory factory) |
DimensionSelector |
VirtualColumns.makeDimensionSelector(DimensionSpec dimensionSpec,
ColumnSelectorFactory factory) |
DimensionSelector |
VirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec,
ColumnSelectorFactory factory)
Build a selector corresponding to this virtual column.
|
FloatColumnSelector |
MapVirtualColumn.makeFloatColumnSelector(String columnName,
ColumnSelectorFactory factory) |
FloatColumnSelector |
VirtualColumns.makeFloatColumnSelector(String columnName,
ColumnSelectorFactory factory) |
FloatColumnSelector |
VirtualColumn.makeFloatColumnSelector(String columnName,
ColumnSelectorFactory factory)
Build a selector corresponding to this virtual column.
|
LongColumnSelector |
MapVirtualColumn.makeLongColumnSelector(String columnName,
ColumnSelectorFactory factory) |
LongColumnSelector |
VirtualColumns.makeLongColumnSelector(String columnName,
ColumnSelectorFactory factory) |
LongColumnSelector |
VirtualColumn.makeLongColumnSelector(String columnName,
ColumnSelectorFactory factory)
Build a selector corresponding to this virtual column.
|
ObjectColumnSelector |
MapVirtualColumn.makeObjectColumnSelector(String dimension,
ColumnSelectorFactory factory) |
ObjectColumnSelector |
VirtualColumns.makeObjectColumnSelector(String columnName,
ColumnSelectorFactory factory) |
ObjectColumnSelector |
VirtualColumn.makeObjectColumnSelector(String columnName,
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 ExpressionObjectSelector |
ExpressionObjectSelector.from(ColumnSelectorFactory columnSelectorFactory,
Expr expression) |
static DimensionSelector |
ExpressionSelectors.makeDimensionSelector(ColumnSelectorFactory columnSelectorFactory,
Expr expression,
ExtractionFn extractionFn) |
DimensionSelector |
ExpressionVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec,
ColumnSelectorFactory columnSelectorFactory) |
static FloatColumnSelector |
ExpressionSelectors.makeFloatColumnSelector(ColumnSelectorFactory columnSelectorFactory,
Expr expression,
float nullValue) |
FloatColumnSelector |
ExpressionVirtualColumn.makeFloatColumnSelector(String columnName,
ColumnSelectorFactory columnSelectorFactory) |
static LongColumnSelector |
ExpressionSelectors.makeLongColumnSelector(ColumnSelectorFactory columnSelectorFactory,
Expr expression,
long nullValue) |
LongColumnSelector |
ExpressionVirtualColumn.makeLongColumnSelector(String columnName,
ColumnSelectorFactory columnSelectorFactory) |
static ExpressionObjectSelector |
ExpressionSelectors.makeObjectColumnSelector(ColumnSelectorFactory columnSelectorFactory,
Expr expression) |
ObjectColumnSelector |
ExpressionVirtualColumn.makeObjectColumnSelector(String columnName,
ColumnSelectorFactory columnSelectorFactory) |
Constructor and Description |
---|
VirtualizedColumnSelectorFactory(ColumnSelectorFactory baseFactory,
VirtualColumns virtualColumns) |
Copyright © 2011–2017. All rights reserved.