| Modifier and Type | Method and Description |
|---|---|
ColumnValueSelector |
ColumnSelectorPlus.getSelector() |
| Constructor and Description |
|---|
ColumnSelectorPlus(String columnName,
String outputName,
ColumnSelectorStrategyClass columnSelectorStrategy,
ColumnValueSelector selector) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
AggregateCombiner<T>
AggregateCombiner is used to fold rollup aggregation results from serveral "rows" of different indexes during index
merging (see
IndexMerger). |
| Modifier and Type | Class and Description |
|---|---|
class |
DoubleAggregateCombiner
Specialization of
AggregateCombiner for primitive double aggregations. |
class |
LongAggregateCombiner
Specialization of
AggregateCombiner for primitive long aggregations. |
class |
LongSumAggregateCombiner |
class |
NullableAggregateCombiner<T>
The result of a NullableAggregateCombiner will be null if all the values to be combined are null values or no values
are combined at all.
|
class |
ObjectAggregateCombiner<T>
Specialization of
AggregateCombiner for object aggregations. |
| Modifier and Type | Method and Description |
|---|---|
void |
NullableAggregateCombiner.fold(ColumnValueSelector selector) |
void |
LongSumAggregateCombiner.fold(ColumnValueSelector selector) |
void |
AggregateCombiner.fold(ColumnValueSelector selector)
Folds this AggregateCombiner's state value with the value of the given selector and saves it in this
AggregateCombiner's state, e.
|
void |
NullableAggregateCombiner.reset(ColumnValueSelector selector) |
void |
LongSumAggregateCombiner.reset(ColumnValueSelector selector) |
void |
AggregateCombiner.reset(ColumnValueSelector selector)
Resets this AggregateCombiner's state value to the value of the given selector, e.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HyperLogLogCollectorAggregateCombiner |
| Modifier and Type | Method and Description |
|---|---|
void |
HyperLogLogCollectorAggregateCombiner.fold(ColumnValueSelector selector) |
void |
HyperLogLogCollectorAggregateCombiner.reset(ColumnValueSelector selector) |
| Modifier and Type | Method and Description |
|---|---|
CardinalityAggregatorColumnSelectorStrategy |
CardinalityAggregatorColumnSelectorStrategyFactory.makeColumnSelectorStrategy(ColumnCapabilities capabilities,
ColumnValueSelector selector) |
| Modifier and Type | Class and Description |
|---|---|
class |
StringFirstAggregateCombiner |
| Modifier and Type | Method and Description |
|---|---|
protected ColumnValueSelector |
LongFirstAggregatorFactory.selector(ColumnSelectorFactory metricFactory) |
protected ColumnValueSelector |
FloatFirstAggregatorFactory.selector(ColumnSelectorFactory metricFactory) |
protected ColumnValueSelector |
DoubleFirstAggregatorFactory.selector(ColumnSelectorFactory metricFactory) |
| Modifier and Type | Method and Description |
|---|---|
protected Aggregator |
LongFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory,
ColumnValueSelector selector) |
protected Aggregator |
FloatFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory,
ColumnValueSelector selector) |
protected Aggregator |
DoubleFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory,
ColumnValueSelector 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) |
void |
StringFirstAggregateCombiner.fold(ColumnValueSelector selector) |
void |
StringFirstAggregateCombiner.reset(ColumnValueSelector selector) |
| Modifier and Type | Class and Description |
|---|---|
class |
StringLastAggregateCombiner |
| Modifier and Type | Method and Description |
|---|---|
protected ColumnValueSelector |
LongLastAggregatorFactory.selector(ColumnSelectorFactory metricFactory) |
protected ColumnValueSelector |
FloatLastAggregatorFactory.selector(ColumnSelectorFactory metricFactory) |
protected ColumnValueSelector |
DoubleLastAggregatorFactory.selector(ColumnSelectorFactory metricFactory) |
| Modifier and Type | Method and Description |
|---|---|
protected Aggregator |
LongLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory,
ColumnValueSelector selector) |
protected Aggregator |
FloatLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory,
ColumnValueSelector selector) |
protected Aggregator |
DoubleLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory,
ColumnValueSelector 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) |
void |
StringLastAggregateCombiner.fold(ColumnValueSelector selector) |
void |
StringLastAggregateCombiner.reset(ColumnValueSelector selector) |
| Modifier and Type | Method and Description |
|---|---|
ColumnSelectorStrategyClass |
ColumnSelectorStrategyFactory.makeColumnSelectorStrategy(ColumnCapabilities capabilities,
ColumnValueSelector selector) |
| Modifier and Type | Method and Description |
|---|---|
ValueMatcherColumnSelectorStrategy |
ValueMatcherColumnSelectorStrategyFactory.makeColumnSelectorStrategy(ColumnCapabilities capabilities,
ColumnValueSelector selector) |
| Modifier and Type | Method and Description |
|---|---|
ColumnValueSelector<?> |
RowBasedColumnSelectorFactory.makeColumnValueSelector(String columnName) |
| Modifier and Type | Method and Description |
|---|---|
Object |
StringGroupByColumnSelectorStrategy.getOnlyValue(ColumnValueSelector selector) |
Object |
NullableValueGroupByColumnSelectorStrategy.getOnlyValue(ColumnValueSelector selector) |
Object |
LongGroupByColumnSelectorStrategy.getOnlyValue(ColumnValueSelector selector) |
Object |
GroupByColumnSelectorStrategy.getOnlyValue(ColumnValueSelector selector)
Retrieve a single object using the
ColumnValueSelector. |
Object |
FloatGroupByColumnSelectorStrategy.getOnlyValue(ColumnValueSelector selector) |
Object |
DoubleGroupByColumnSelectorStrategy.getOnlyValue(ColumnValueSelector selector) |
Object |
DictionaryBuildingStringGroupByColumnSelectorStrategy.getOnlyValue(ColumnValueSelector selector) |
void |
StringGroupByColumnSelectorStrategy.initColumnValues(ColumnValueSelector selector,
int columnIndex,
Object[] valuess) |
void |
NullableValueGroupByColumnSelectorStrategy.initColumnValues(ColumnValueSelector selector,
int columnIndex,
Object[] values) |
void |
LongGroupByColumnSelectorStrategy.initColumnValues(ColumnValueSelector selector,
int columnIndex,
Object[] valuess) |
void |
GroupByColumnSelectorStrategy.initColumnValues(ColumnValueSelector selector,
int columnIndex,
Object[] valuess)
Retrieve a row object from the
ColumnValueSelector and put it in valuess at columnIndex. |
void |
FloatGroupByColumnSelectorStrategy.initColumnValues(ColumnValueSelector selector,
int columnIndex,
Object[] valuess) |
void |
DoubleGroupByColumnSelectorStrategy.initColumnValues(ColumnValueSelector selector,
int columnIndex,
Object[] values) |
void |
DictionaryBuildingStringGroupByColumnSelectorStrategy.initColumnValues(ColumnValueSelector selector,
int columnIndex,
Object[] valuess) |
| Modifier and Type | Method and Description |
|---|---|
SelectQueryEngine.SelectColumnSelectorStrategy |
SelectQueryEngine.SelectStrategyFactory.makeColumnSelectorStrategy(ColumnCapabilities capabilities,
ColumnValueSelector selector) |
| Modifier and Type | Method and Description |
|---|---|
void |
TopNQueryMetrics.columnValueSelector(ColumnValueSelector columnValueSelector)
This method is called exactly once with the columnValueSelector object of each cursor, processed for the query.
|
void |
DefaultTopNQueryMetrics.columnValueSelector(ColumnValueSelector columnValueSelector) |
| Modifier and Type | Method and Description |
|---|---|
TopNColumnSelectorStrategy |
TopNColumnSelectorStrategyFactory.makeColumnSelectorStrategy(ColumnCapabilities capabilities,
ColumnValueSelector selector) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
DimensionSelector |
interface |
DoubleColumnSelector
This interface is convenient for implementation of "double-sourcing"
ColumnValueSelectors, it provides
default implementations for all ColumnValueSelector's methods except BaseDoubleColumnValueSelector.getDouble(). |
interface |
FloatColumnSelector
This interface is convenient for implementation of "float-sourcing"
ColumnValueSelectors, it provides default
implementations for all ColumnValueSelector's methods except BaseFloatColumnValueSelector.getFloat(). |
interface |
LongColumnSelector
This interface is convenient for implementation of "long-sourcing"
ColumnValueSelectors, it provides default
implementations for all ColumnValueSelector's methods except BaseLongColumnValueSelector.getLong(). |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractDimensionSelector
An abstract class that provides an implementation of
AbstractDimensionSelector.getObject(). |
class |
BaseSingleValueDimensionSelector |
class |
ConstantDimensionSelector |
class |
ConstantExprEvalSelector |
class |
DoubleWrappingDimensionSelector |
class |
FloatWrappingDimensionSelector |
class |
LongWrappingDimensionSelector |
class |
NilColumnValueSelector
Represents "absent" column.
|
class |
ObjectColumnSelector<T>
This class is convenient for implementation of "object-sourcing"
ColumnValueSelectors, it provides default
implementations for all ColumnValueSelector's methods except BaseObjectColumnValueSelector.getObject() and BaseObjectColumnValueSelector.classOfObject(). |
class |
SingleScanTimeDimensionSelector
A special
DimensionSelector for projected time columns
- it assumes time values are scanned once and values are grouped together
(i.e. |
| Modifier and Type | Field and Description |
|---|---|
static ColumnValueSelector[] |
ColumnValueSelector.EMPTY_ARRAY |
| Modifier and Type | Method and Description |
|---|---|
Comparator<ColumnValueSelector> |
StringDimensionHandler.getEncodedValueSelectorComparator() |
Comparator<ColumnValueSelector> |
LongDimensionHandler.getEncodedValueSelectorComparator() |
Comparator<ColumnValueSelector> |
FloatDimensionHandler.getEncodedValueSelectorComparator() |
Comparator<ColumnValueSelector> |
DoubleDimensionHandler.getEncodedValueSelectorComparator() |
Comparator<ColumnValueSelector> |
DimensionHandler.getEncodedValueSelectorComparator()
Returns a comparator that knows how to compare
ColumnValueSelector of the assumed dimension type,
corresponding to this DimensionHandler. |
| Modifier and Type | Method and Description |
|---|---|
ColumnValueSelector |
StringDimensionMergerV9.convertSortedSegmentRowValuesToMergedRowValues(int segmentIndex,
ColumnValueSelector source) |
ColumnValueSelector |
NumericDimensionMergerV9.convertSortedSegmentRowValuesToMergedRowValues(int segmentIndex,
ColumnValueSelector source) |
ColumnValueSelector |
DimensionMerger.convertSortedSegmentRowValuesToMergedRowValues(int segmentIndex,
ColumnValueSelector source)
Creates a value selector, which converts values with per-segment, _sorted order_ (see
DimensionIndexer.convertUnsortedValuesToSorted(org.apache.druid.segment.ColumnValueSelector)) encoding from the given selector to their equivalent
representation in the merged set of rows. |
ColumnValueSelector |
StringDimensionIndexer.convertUnsortedValuesToSorted(ColumnValueSelector selectorWithUnsortedValues) |
ColumnValueSelector |
LongDimensionIndexer.convertUnsortedValuesToSorted(ColumnValueSelector selectorWithUnsortedValues) |
ColumnValueSelector |
FloatDimensionIndexer.convertUnsortedValuesToSorted(ColumnValueSelector selectorWithUnsortedValues) |
ColumnValueSelector |
DoubleDimensionIndexer.convertUnsortedValuesToSorted(ColumnValueSelector selectorWithUnsortedValues) |
ColumnValueSelector |
DimensionIndexer.convertUnsortedValuesToSorted(ColumnValueSelector selectorWithUnsortedValues)
Converts dictionary-encoded row values from unspecified (random) encoding order, to sorted encoding.
|
static TransformableRowIterator |
IndexMerger.makeRowIteratorWithConvertedDimensionColumns(TransformableRowIterator sourceRowIterator,
ColumnValueSelector[] convertedDimensionSelectors,
ColumnValueSelector[] convertedMarkedDimensionSelectors) |
static TransformableRowIterator |
IndexMerger.makeRowIteratorWithConvertedDimensionColumns(TransformableRowIterator sourceRowIterator,
ColumnValueSelector[] convertedDimensionSelectors,
ColumnValueSelector[] convertedMarkedDimensionSelectors) |
void |
StringDimensionMergerV9.processMergedRow(ColumnValueSelector selector) |
void |
NumericDimensionMergerV9.processMergedRow(ColumnValueSelector selector) |
void |
DimensionMerger.processMergedRow(ColumnValueSelector selector)
Process a column value(s) (potentially multi-value) of a row from the given selector and update the
DimensionMerger's internal state.
|
void |
LongColumnSerializerV2.serialize(ColumnValueSelector<?> selector) |
void |
LongColumnSerializer.serialize(ColumnValueSelector<?> selector) |
void |
FloatColumnSerializerV2.serialize(ColumnValueSelector<?> selector) |
void |
FloatColumnSerializer.serialize(ColumnValueSelector<?> selector) |
void |
DoubleColumnSerializerV2.serialize(ColumnValueSelector<?> selector) |
void |
DoubleColumnSerializer.serialize(ColumnValueSelector<?> selector) |
void |
GenericColumnSerializer.serialize(ColumnValueSelector<? extends T> selector) |
| Constructor and Description |
|---|
RowPointer(ColumnValueSelector timestampSelector,
ColumnValueSelector[] dimensionSelectors,
List<DimensionHandler> dimensionHandlers,
ColumnValueSelector[] metricSelectors,
List<String> metricNames,
IntSupplier rowNumPointer) |
RowPointer(ColumnValueSelector timestampSelector,
ColumnValueSelector[] dimensionSelectors,
List<DimensionHandler> dimensionHandlers,
ColumnValueSelector[] metricSelectors,
List<String> metricNames,
IntSupplier rowNumPointer) |
RowPointer(ColumnValueSelector timestampSelector,
ColumnValueSelector[] dimensionSelectors,
List<DimensionHandler> dimensionHandlers,
ColumnValueSelector[] metricSelectors,
List<String> metricNames,
IntSupplier rowNumPointer) |
| Modifier and Type | Method and Description |
|---|---|
ColumnValueSelector<?> |
LongsColumn.makeColumnValueSelector(ReadableOffset offset) |
ColumnValueSelector<?> |
FloatsColumn.makeColumnValueSelector(ReadableOffset offset) |
ColumnValueSelector<?> |
DoublesColumn.makeColumnValueSelector(ReadableOffset offset) |
default ColumnValueSelector<?> |
DictionaryEncodedColumn.makeColumnValueSelector(ReadableOffset offset) |
ColumnValueSelector<?> |
ComplexColumn.makeColumnValueSelector(ReadableOffset offset) |
ColumnValueSelector<?> |
BaseColumn.makeColumnValueSelector(ReadableOffset offset) |
| Modifier and Type | Method and Description |
|---|---|
DimensionSelector |
ValueType.makeNumericWrappingDimensionSelector(ColumnValueSelector numericColumnValueSelector,
ExtractionFn extractionFn) |
| Modifier and Type | Method and Description |
|---|---|
default ColumnValueSelector<Long> |
ColumnarLongs.makeColumnValueSelector(ReadableOffset offset,
ImmutableBitmap nullValueBitmap) |
default ColumnValueSelector<Float> |
ColumnarFloats.makeColumnValueSelector(ReadableOffset offset,
ImmutableBitmap nullValueBitmap) |
default ColumnValueSelector<Double> |
ColumnarDoubles.makeColumnValueSelector(ReadableOffset offset,
ImmutableBitmap nullValueBitmap) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
HistoricalColumnSelector<T> |
interface |
HistoricalDimensionSelector
Specialization for
DimensionSelector queryable via offsets from HistoricalCursor. |
interface |
SingleValueHistoricalDimensionSelector |
| Modifier and Type | Class and Description |
|---|---|
class |
IncrementalIndexRowHolder
IncrementalIndexRowHolder is a simple
IncrementalIndexRowHolder.get()/IncrementalIndexRowHolder.set(org.apache.druid.segment.incremental.IncrementalIndexRow) holder of IncrementalIndexRow. |
| Modifier and Type | Method and Description |
|---|---|
ColumnValueSelector<?> |
IncrementalIndex.makeMetricColumnValueSelector(String metric,
IncrementalIndexRowHolder currEntry) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
SettableColumnValueSelector<T>
SettableColumnValueSelectors are used in
QueryableIndexIndexableAdapter.RowIteratorImpl. |
| Modifier and Type | Class and Description |
|---|---|
class |
SettableDimensionValueSelector
Settable implementation of
DimensionSelector. |
class |
SettableDoubleColumnValueSelector |
class |
SettableFloatColumnValueSelector |
class |
SettableLongColumnValueSelector |
class |
SettableObjectColumnValueSelector<T> |
| Modifier and Type | Method and Description |
|---|---|
void |
SettableObjectColumnValueSelector.setValueFrom(ColumnValueSelector selector) |
void |
SettableLongColumnValueSelector.setValueFrom(ColumnValueSelector<?> selector) |
void |
SettableFloatColumnValueSelector.setValueFrom(ColumnValueSelector<?> selector) |
void |
SettableDoubleColumnValueSelector.setValueFrom(ColumnValueSelector<?> selector) |
void |
SettableDimensionValueSelector.setValueFrom(ColumnValueSelector<?> selector) |
void |
SettableColumnValueSelector.setValueFrom(ColumnValueSelector<?> selector) |
| Modifier and Type | Method and Description |
|---|---|
void |
LargeColumnSupportedComplexColumnSerializer.serialize(ColumnValueSelector<? extends T> selector) |
void |
ComplexColumnSerializer.serialize(ColumnValueSelector<? extends T> selector) |
| Modifier and Type | Class and Description |
|---|---|
class |
ExpressionColumnValueSelector |
class |
SingleLongInputCachingExpressionColumnValueSelector
Like
ExpressionColumnValueSelector, but caches the most recently computed value and re-uses it in the case
of runs in the underlying column. |
class |
SingleStringInputCachingExpressionColumnValueSelector
Like
ExpressionColumnValueSelector, but caches results for the first CACHE_SIZE dictionary IDs of
a string column. |
class |
SingleStringInputDimensionSelector
A DimensionSelector decorator that computes an expression on top of it.
|
| 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<?> |
VirtualizedColumnSelectorFactory.makeColumnValueSelector(String columnName) |
ColumnValueSelector<?> |
ExpressionVirtualColumn.makeColumnValueSelector(String columnName,
ColumnSelectorFactory factory) |
static ColumnValueSelector<ExprEval> |
ExpressionSelectors.makeExprEvalSelector(ColumnSelectorFactory columnSelectorFactory,
Expr expression)
Makes a ColumnValueSelector whose getObject method returns an
ExprEval. |
| Constructor and Description |
|---|
SingleLongInputCachingExpressionColumnValueSelector(ColumnValueSelector selector,
Expr expression,
boolean useLruCache) |
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.