Package | Description |
---|---|
io.druid.data.input | |
io.druid.indexer.hadoop | |
io.druid.query.groupby | |
io.druid.query.groupby.having | |
io.druid.query.groupby.orderby | |
io.druid.segment.incremental |
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) |
static InputRow |
Rows.toCaseInsensitiveInputRow(Row row,
List<String> dimensions) |
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) |
Modifier and Type | Method and Description |
---|---|
com.metamx.common.guava.Sequence<Row> |
GroupByQuery.applyLimit(com.metamx.common.guava.Sequence<Row> results) |
QueryRunner<Row> |
GroupByQueryRunnerFactory.createRunner(Segment segment) |
CacheStrategy<Row,Object,GroupByQuery> |
GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query) |
com.fasterxml.jackson.core.type.TypeReference<Row> |
GroupByQueryQueryToolChest.getResultTypeReference() |
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) |
QueryRunner<Row> |
GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Row> runner) |
com.metamx.common.guava.Sequence<Row> |
GroupByQueryEngine.process(GroupByQuery query,
StorageAdapter storageAdapter) |
Query<Row> |
GroupByQuery.withDataSource(DataSource dataSource) |
Modifier and Type | Method and Description |
---|---|
com.metamx.common.guava.Sequence<Row> |
GroupByQuery.applyLimit(com.metamx.common.guava.Sequence<Row> results) |
QueryRunner<Row> |
GroupByQueryQueryToolChest.mergeResults(QueryRunner<Row> runner) |
QueryRunner<Row> |
GroupByQueryRunnerFactory.mergeRunners(ExecutorService exec,
Iterable<QueryRunner<Row>> queryRunners) |
QueryRunner<Row> |
GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Row> runner) |
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 |
AndHavingSpec.eval(Row row) |
boolean |
AlwaysHavingSpec.eval(Row row) |
Modifier and Type | Method and Description |
---|---|
com.google.common.base.Function<com.metamx.common.guava.Sequence<Row>,com.metamx.common.guava.Sequence<Row>> |
NoopLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs) |
com.google.common.base.Function<com.metamx.common.guava.Sequence<Row>,com.metamx.common.guava.Sequence<Row>> |
NoopLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs) |
com.google.common.base.Function<com.metamx.common.guava.Sequence<Row>,com.metamx.common.guava.Sequence<Row>> |
LimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs) |
com.google.common.base.Function<com.metamx.common.guava.Sequence<Row>,com.metamx.common.guava.Sequence<Row>> |
LimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs) |
com.google.common.base.Function<com.metamx.common.guava.Sequence<Row>,com.metamx.common.guava.Sequence<Row>> |
DefaultLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs) |
com.google.common.base.Function<com.metamx.common.guava.Sequence<Row>,com.metamx.common.guava.Sequence<Row>> |
DefaultLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs) |
Modifier and Type | Method and Description |
---|---|
Iterable<Row> |
IncrementalIndex.iterableWithPostAggregations(List<PostAggregator> postAggs,
boolean descending) |
Iterator<Row> |
IncrementalIndex.iterator() |
Copyright © 2011–2016. All rights reserved.