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 |
ObjectAggregateCombiner<T>
Specialization of
AggregateCombiner for object aggregations. |
Modifier and Type | Field and Description |
---|---|
protected BaseLongColumnValueSelector |
LongBufferAggregator.selector |
Modifier and Type | Method and Description |
---|---|
static BaseLongColumnValueSelector |
AggregatorUtil.makeColumnValueSelectorWithLongDefault(ColumnSelectorFactory metricFactory,
ExprMacroTable macroTable,
String fieldName,
String fieldExpression,
long nullValue) |
Constructor and Description |
---|
LongMaxAggregator(BaseLongColumnValueSelector selector) |
LongMinAggregator(BaseLongColumnValueSelector selector) |
LongSumAggregator(BaseLongColumnValueSelector selector) |
Modifier and Type | Class and Description |
---|---|
class |
HyperLogLogCollectorAggregateCombiner |
Modifier and Type | Method and Description |
---|---|
void |
LongCardinalityAggregatorColumnSelectorStrategy.hashRow(BaseLongColumnValueSelector dimSelector,
com.google.common.hash.Hasher hasher) |
void |
LongCardinalityAggregatorColumnSelectorStrategy.hashValues(BaseLongColumnValueSelector dimSelector,
HyperLogLogCollector collector) |
Constructor and Description |
---|
DoubleFirstAggregator(BaseLongColumnValueSelector timeSelector,
BaseDoubleColumnValueSelector valueSelector) |
DoubleFirstBufferAggregator(BaseLongColumnValueSelector timeSelector,
BaseDoubleColumnValueSelector valueSelector) |
FloatFirstAggregator(BaseLongColumnValueSelector timeSelector,
BaseFloatColumnValueSelector valueSelector) |
FloatFirstBufferAggregator(BaseLongColumnValueSelector timeSelector,
BaseFloatColumnValueSelector valueSelector) |
LongFirstAggregator(BaseLongColumnValueSelector timeSelector,
BaseLongColumnValueSelector valueSelector) |
LongFirstBufferAggregator(BaseLongColumnValueSelector timeSelector,
BaseLongColumnValueSelector valueSelector) |
Constructor and Description |
---|
DoubleLastAggregator(BaseLongColumnValueSelector timeSelector,
BaseDoubleColumnValueSelector valueSelector) |
DoubleLastBufferAggregator(BaseLongColumnValueSelector timeSelector,
BaseDoubleColumnValueSelector valueSelector) |
FloatLastAggregator(BaseLongColumnValueSelector timeSelector,
BaseFloatColumnValueSelector valueSelector) |
FloatLastBufferAggregator(BaseLongColumnValueSelector timeSelector,
BaseFloatColumnValueSelector valueSelector) |
LongLastAggregator(BaseLongColumnValueSelector timeSelector,
BaseLongColumnValueSelector valueSelector) |
LongLastBufferAggregator(BaseLongColumnValueSelector timeSelector,
BaseLongColumnValueSelector valueSelector) |
Constructor and Description |
---|
LongVarianceAggregator(BaseLongColumnValueSelector selector) |
LongVarianceAggregator(BaseLongColumnValueSelector selector) |
Modifier and Type | Method and Description |
---|---|
ValueGetter |
LongValueMatcherColumnSelectorStrategy.makeValueGetter(BaseLongColumnValueSelector selector) |
ValueMatcher |
LongValueMatcherColumnSelectorStrategy.makeValueMatcher(BaseLongColumnValueSelector selector,
DruidPredicateFactory predicateFactory) |
ValueMatcher |
LongValueMatcherColumnSelectorStrategy.makeValueMatcher(BaseLongColumnValueSelector selector,
String value) |
Modifier and Type | Method and Description |
---|---|
void |
SearchQueryRunner.LongSearchColumnSelectorStrategy.updateSearchResultSet(String outputName,
BaseLongColumnValueSelector selector,
SearchQuerySpec searchQuerySpec,
int limit,
it.unimi.dsi.fastutil.objects.Object2IntRBTreeMap<SearchHit> set) |
Modifier and Type | Method and Description |
---|---|
void |
SelectQueryEngine.LongSelectColumnSelectorStrategy.addRowValuesToSelectResult(String outputName,
BaseLongColumnValueSelector selector,
Map<String,Object> resultMap) |
static Map<String,Object> |
SelectQueryEngine.singleEvent(String timestampKey,
BaseLongColumnValueSelector timestampColumnSelector,
List<ColumnSelectorPlus<SelectQueryEngine.SelectColumnSelectorStrategy>> selectorPlusList,
Map<String,BaseObjectColumnValueSelector<?>> metSelectors) |
Modifier and Type | Interface and Description |
---|---|
interface |
ColumnValueSelector<T>
Base type for interfaces that manage column value selection, e.g.
|
interface |
DimensionSelector |
interface |
DoubleColumnSelector
This interface is convenient for implementation of "double-sourcing"
ColumnValueSelector s, it provides
default implementations for all ColumnValueSelector 's methods except BaseDoubleColumnValueSelector.getDouble() . |
interface |
FloatColumnSelector
This interface is convenient for implementation of "float-sourcing"
ColumnValueSelector s, it provides default
implementations for all ColumnValueSelector 's methods except BaseFloatColumnValueSelector.getFloat() . |
interface |
LongColumnSelector
This interface is convenient for implementation of "long-sourcing"
ColumnValueSelector s, it provides default
implementations for all ColumnValueSelector 's methods except getLong() . |
interface |
ObjectColumnSelector<T>
This interface is convenient for implementation of "object-sourcing"
ColumnValueSelector s, it provides
default implementations for all ColumnValueSelector 's methods except BaseObjectColumnValueSelector.getObject() and BaseObjectColumnValueSelector.classOfObject() . |
Modifier and Type | Class and Description |
---|---|
class |
ConstantColumnValueSelector<T> |
class |
ConstantDimensionSelector |
class |
DoubleWrappingDimensionSelector |
class |
FloatWrappingDimensionSelector |
class |
LongWrappingDimensionSelector |
class |
NilColumnValueSelector
Represents "absent" column.
|
class |
NullDimensionSelector |
class |
SingleScanTimeDimSelector |
Constructor and Description |
---|
LongWrappingDimensionSelector(BaseLongColumnValueSelector selector,
ExtractionFn extractionFn) |
SingleScanTimeDimSelector(BaseLongColumnValueSelector selector,
ExtractionFn extractionFn,
boolean descending) |
Modifier and Type | Method and Description |
---|---|
static ValueMatcher |
Filters.getLongPredicateMatcher(BaseLongColumnValueSelector longSelector,
DruidLongPredicate predicate) |
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 |
BaseSingleValueDimensionSelector |
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.
|
Copyright © 2011–2018. All rights reserved.