Modifier and Type | Interface and Description |
---|---|
interface |
InputRow
An InputRow is the interface definition of an event being input into the data ingestion layer.
|
Modifier and Type | Class and Description |
---|---|
class |
MapBasedInputRow |
class |
MapBasedRow |
Modifier and Type | Method and Description |
---|---|
int |
MapBasedRow.compareTo(Row o) |
Modifier and Type | Class and Description |
---|---|
class |
SegmentInputRow
SegmentInputRow serves as a marker that these InputRow instances have already been combined
and they contain the columns as they show up in the segment after ingestion, not what you would see in raw
data.
|
Modifier and Type | Method and Description |
---|---|
int |
SegmentInputRow.compareTo(Row row) |
Constructor and Description |
---|
SegmentInputRow(Row delegate,
List<String> dimensions) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Row> |
GroupByQueryRunnerFactory.createRunner(Segment segment) |
CacheStrategy<Row,Object,GroupByQuery> |
GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query) |
com.fasterxml.jackson.core.type.TypeReference<Row> |
GroupByQueryQueryToolChest.getResultTypeReference() |
com.google.common.collect.Ordering<Row> |
GroupByQuery.getRowOrdering(boolean granular) |
QueryToolChest<Row,GroupByQuery> |
GroupByQueryRunnerFactory.getToolchest() |
com.google.common.base.Function<Row,Row> |
GroupByQueryQueryToolChest.makePostComputeManipulatorFn(GroupByQuery query,
MetricManipulationFn fn) |
com.google.common.base.Function<Row,Row> |
GroupByQueryQueryToolChest.makePostComputeManipulatorFn(GroupByQuery query,
MetricManipulationFn fn) |
com.google.common.base.Function<Row,Row> |
GroupByQueryQueryToolChest.makePreComputeManipulatorFn(GroupByQuery query,
MetricManipulationFn fn) |
com.google.common.base.Function<Row,Row> |
GroupByQueryQueryToolChest.makePreComputeManipulatorFn(GroupByQuery query,
MetricManipulationFn fn) |
QueryRunner<Row> |
GroupByQueryQueryToolChest.mergeResults(QueryRunner<Row> runner) |
QueryRunner<Row> |
GroupByQueryRunnerFactory.mergeRunners(ExecutorService exec,
Iterable<QueryRunner<Row>> queryRunners) |
static Sequence<Row> |
GroupByQueryHelper.postAggregate(GroupByQuery query,
IncrementalIndex index) |
Sequence<Row> |
GroupByQuery.postProcess(Sequence<Row> results)
Apply the havingSpec and limitSpec.
|
QueryRunner<Row> |
GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Row> runner) |
Sequence<Row> |
GroupByQueryEngine.process(GroupByQuery query,
StorageAdapter storageAdapter) |
Query<Row> |
GroupByQuery.withDataSource(DataSource dataSource) |
Modifier and Type | Method and Description |
---|---|
static RowBasedColumnSelectorFactory |
RowBasedColumnSelectorFactory.create(com.google.common.base.Supplier<? extends Row> row,
Map<String,ValueType> rowSignature) |
static RowBasedColumnSelectorFactory |
RowBasedColumnSelectorFactory.create(ThreadLocal<? extends Row> row,
Map<String,ValueType> rowSignature) |
static IncrementalIndex |
GroupByQueryHelper.makeIncrementalIndex(GroupByQuery query,
GroupByQueryConfig config,
NonBlockingPool<ByteBuffer> bufferPool,
Sequence<Row> rows,
boolean combine) |
QueryRunner<Row> |
GroupByQueryQueryToolChest.mergeResults(QueryRunner<Row> runner) |
QueryRunner<Row> |
GroupByQueryRunnerFactory.mergeRunners(ExecutorService exec,
Iterable<QueryRunner<Row>> queryRunners) |
Sequence<Row> |
GroupByQuery.postProcess(Sequence<Row> results)
Apply the havingSpec and limitSpec.
|
QueryRunner<Row> |
GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Row> runner) |
Modifier and Type | Method and Description |
---|---|
Row |
GroupByBinaryFnV2.apply(Row arg1,
Row arg2) |
Modifier and Type | Method and Description |
---|---|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories,
int mergeBufferSize)
Create a single-threaded grouper and accumulator.
|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
int concurrencyHint,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories,
com.google.common.util.concurrent.ListeningExecutorService grouperSorter,
int priority,
boolean hasQueryTimeout,
long queryTimeoutAt,
int mergeBufferSize)
If isInputRaw is true, transformations such as timestamp truncation and extraction functions have not
been applied to the input rows yet, for example, in a nested query, if an extraction function is being
applied in the outer query to a field of the inner query.
|
static CloseableGrouperIterator<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey,Row> |
RowBasedGrouperHelper.makeGrouperIterator(Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey> grouper,
GroupByQuery query,
Closeable closeable) |
static Sequence<Row> |
GroupByQueryEngineV2.process(GroupByQuery query,
StorageAdapter storageAdapter,
NonBlockingPool<ByteBuffer> intermediateResultsBufferPool,
GroupByQueryConfig config) |
static Sequence<Row> |
GroupByRowProcessor.process(Query queryParam,
Sequence<Row> rows,
Map<String,ValueType> rowSignature,
GroupByQueryConfig config,
GroupByQueryResource resource,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
String processingTmpDir,
int mergeBufferSize) |
Sequence<Row> |
GroupByMergingQueryRunnerV2.run(QueryPlus<Row> queryPlus,
Map<String,Object> responseContext) |
Modifier and Type | Method and Description |
---|---|
Row |
GroupByBinaryFnV2.apply(Row arg1,
Row arg2) |
Modifier and Type | Method and Description |
---|---|
static Sequence<Row> |
GroupByRowProcessor.process(Query queryParam,
Sequence<Row> rows,
Map<String,ValueType> rowSignature,
GroupByQueryConfig config,
GroupByQueryResource resource,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
String processingTmpDir,
int mergeBufferSize) |
Sequence<Row> |
GroupByMergingQueryRunnerV2.run(QueryPlus<Row> queryPlus,
Map<String,Object> responseContext) |
Constructor and Description |
---|
GroupByMergingQueryRunnerV2(GroupByQueryConfig config,
ExecutorService exec,
QueryWatcher queryWatcher,
Iterable<QueryRunner<Row>> queryables,
int concurrencyHint,
NonBlockingPool<ByteBuffer> processingBufferPool,
BlockingPool<ByteBuffer> mergeBufferPool,
int mergeBufferSize,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
String processingTmpDir) |
Modifier and Type | Method and Description |
---|---|
boolean |
OrHavingSpec.eval(Row row) |
boolean |
NotHavingSpec.eval(Row row) |
boolean |
NeverHavingSpec.eval(Row row) |
boolean |
LessThanHavingSpec.eval(Row row) |
boolean |
HavingSpec.eval(Row row)
Evaluates if a given row satisfies the having spec.
|
boolean |
GreaterThanHavingSpec.eval(Row row) |
boolean |
EqualToHavingSpec.eval(Row row) |
boolean |
DimensionSelectorHavingSpec.eval(Row row) |
boolean |
DimFilterHavingSpec.eval(Row row) |
boolean |
AndHavingSpec.eval(Row row) |
boolean |
AlwaysHavingSpec.eval(Row row) |
Modifier and Type | Method and Description |
---|---|
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
NoopLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst) |
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
NoopLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst) |
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
LimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst)
Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
|
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
LimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst)
Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
|
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
DefaultLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst) |
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
DefaultLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Row> |
GroupByStrategyV2.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator,
QueryRunner<Row> runner,
GroupByQueryQueryToolChest toolChest) |
QueryRunner<Row> |
GroupByStrategyV1.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator,
QueryRunner<Row> runner,
GroupByQueryQueryToolChest toolChest) |
QueryRunner<Row> |
GroupByStrategy.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator,
QueryRunner<Row> runner,
GroupByQueryQueryToolChest toolChest)
Decorate a runner with an interval chunking decorator.
|
Sequence<Row> |
GroupByStrategyV2.mergeResults(QueryRunner<Row> baseRunner,
GroupByQuery query,
Map<String,Object> responseContext) |
Sequence<Row> |
GroupByStrategyV1.mergeResults(QueryRunner<Row> baseRunner,
GroupByQuery query,
Map<String,Object> responseContext) |
Sequence<Row> |
GroupByStrategy.mergeResults(QueryRunner<Row> baseRunner,
GroupByQuery query,
Map<String,Object> responseContext) |
QueryRunner<Row> |
GroupByStrategyV2.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec,
Iterable<QueryRunner<Row>> queryRunners) |
QueryRunner<Row> |
GroupByStrategyV1.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec,
Iterable<QueryRunner<Row>> queryRunners) |
QueryRunner<Row> |
GroupByStrategy.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec,
Iterable<QueryRunner<Row>> queryRunners) |
Sequence<Row> |
GroupByStrategyV2.process(GroupByQuery query,
StorageAdapter storageAdapter) |
Sequence<Row> |
GroupByStrategyV1.process(GroupByQuery query,
StorageAdapter storageAdapter) |
Sequence<Row> |
GroupByStrategy.process(GroupByQuery query,
StorageAdapter storageAdapter) |
Sequence<Row> |
GroupByStrategyV2.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
Sequence<Row> |
GroupByStrategyV1.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
Sequence<Row> |
GroupByStrategy.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Row> |
GroupByStrategyV2.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator,
QueryRunner<Row> runner,
GroupByQueryQueryToolChest toolChest) |
QueryRunner<Row> |
GroupByStrategyV1.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator,
QueryRunner<Row> runner,
GroupByQueryQueryToolChest toolChest) |
QueryRunner<Row> |
GroupByStrategy.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator,
QueryRunner<Row> runner,
GroupByQueryQueryToolChest toolChest)
Decorate a runner with an interval chunking decorator.
|
Sequence<Row> |
GroupByStrategyV2.mergeResults(QueryRunner<Row> baseRunner,
GroupByQuery query,
Map<String,Object> responseContext) |
Sequence<Row> |
GroupByStrategyV1.mergeResults(QueryRunner<Row> baseRunner,
GroupByQuery query,
Map<String,Object> responseContext) |
Sequence<Row> |
GroupByStrategy.mergeResults(QueryRunner<Row> baseRunner,
GroupByQuery query,
Map<String,Object> responseContext) |
QueryRunner<Row> |
GroupByStrategyV2.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec,
Iterable<QueryRunner<Row>> queryRunners) |
QueryRunner<Row> |
GroupByStrategyV1.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec,
Iterable<QueryRunner<Row>> queryRunners) |
QueryRunner<Row> |
GroupByStrategy.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec,
Iterable<QueryRunner<Row>> queryRunners) |
Sequence<Row> |
GroupByStrategyV2.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
Sequence<Row> |
GroupByStrategyV1.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
Sequence<Row> |
GroupByStrategy.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
Modifier and Type | Method and Description |
---|---|
Iterable<Row> |
IncrementalIndex.iterableWithPostAggregations(List<PostAggregator> postAggs,
boolean descending) |
Iterator<Row> |
IncrementalIndex.iterator() |
Modifier and Type | Class and Description |
---|---|
static class |
Transformer.TransformedInputRow |
Modifier and Type | Method and Description |
---|---|
int |
Transformer.TransformedInputRow.compareTo(Row o) |
Object |
RowFunction.eval(Row row) |
Copyright © 2011–2018. All rights reserved.