Modifier and Type | Method and Description |
---|---|
Result<T> |
Druids.ResultBuilder.build() |
Modifier and Type | Method and Description |
---|---|
static <T> com.metamx.common.guava.Sequence<Result<T>> |
QueryRunnerHelper.makeCursorBasedQuery(StorageAdapter adapter,
List<org.joda.time.Interval> queryIntervals,
Filter filter,
QueryGranularity granularity,
com.google.common.base.Function<Cursor,Result<T>> mapFn) |
Modifier and Type | Method and Description |
---|---|
int |
ResultGranularTimestampComparator.compare(Result<T> r1,
Result<T> r2) |
int |
ResultGranularTimestampComparator.compare(Result<T> r1,
Result<T> r2) |
int |
Result.compareTo(Result<T> tResult) |
Modifier and Type | Method and Description |
---|---|
static <T> com.metamx.common.guava.Sequence<Result<T>> |
QueryRunnerHelper.makeCursorBasedQuery(StorageAdapter adapter,
List<org.joda.time.Interval> queryIntervals,
Filter filter,
QueryGranularity granularity,
com.google.common.base.Function<Cursor,Result<T>> mapFn) |
Modifier and Type | Method and Description |
---|---|
Iterable<Result<DataSourceMetadataResultValue>> |
DataSourceMetadataQuery.mergeResults(List<Result<DataSourceMetadataResultValue>> results) |
QueryRunner<Result<DataSourceMetadataResultValue>> |
DataSourceQueryQueryToolChest.mergeResults(QueryRunner<Result<DataSourceMetadataResultValue>> runner) |
QueryRunner<Result<DataSourceMetadataResultValue>> |
DataSourceMetadataQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<DataSourceMetadataResultValue>>> queryRunners) |
com.metamx.common.guava.Sequence<Result<DataSourceMetadataResultValue>> |
DataSourceQueryQueryToolChest.mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<DataSourceMetadataResultValue>>> seqOfSequences) |
com.metamx.common.guava.Sequence<Result<DataSourceMetadataResultValue>> |
DataSourceQueryQueryToolChest.mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<DataSourceMetadataResultValue>>> seqOfSequences) |
Modifier and Type | Method and Description |
---|---|
Result<SearchResultValue> |
SearchBinaryFn.apply(Result<SearchResultValue> arg1,
Result<SearchResultValue> arg2) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<SearchResultValue>> |
SearchQueryRunnerFactory.createRunner(Segment segment) |
CacheStrategy<Result<SearchResultValue>,Object,SearchQuery> |
SearchQueryQueryToolChest.getCacheStrategy(SearchQuery query) |
com.google.common.collect.Ordering<Result<SearchResultValue>> |
SearchQueryQueryToolChest.getOrdering() |
List<Result<SearchResultValue>> |
BySegmentSearchResultValue.getResults() |
com.fasterxml.jackson.core.type.TypeReference<Result<SearchResultValue>> |
SearchQueryQueryToolChest.getResultTypeReference() |
QueryToolChest<Result<SearchResultValue>,SearchQuery> |
SearchQueryRunnerFactory.getToolchest() |
com.google.common.base.Function<Result<SearchResultValue>,Result<SearchResultValue>> |
SearchQueryQueryToolChest.makePreComputeManipulatorFn(SearchQuery query,
MetricManipulationFn fn) |
com.google.common.base.Function<Result<SearchResultValue>,Result<SearchResultValue>> |
SearchQueryQueryToolChest.makePreComputeManipulatorFn(SearchQuery query,
MetricManipulationFn fn) |
QueryRunner<Result<SearchResultValue>> |
SearchQueryQueryToolChest.mergeResults(QueryRunner<Result<SearchResultValue>> runner) |
QueryRunner<Result<SearchResultValue>> |
SearchQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<SearchResultValue>>> queryRunners) |
com.metamx.common.guava.Sequence<Result<SearchResultValue>> |
SearchQueryQueryToolChest.mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<SearchResultValue>>> seqOfSequences) |
com.metamx.common.guava.Sequence<Result<SearchResultValue>> |
SearchQueryQueryToolChest.mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<SearchResultValue>>> seqOfSequences) |
QueryRunner<Result<SearchResultValue>> |
SearchQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SearchResultValue>> runner) |
com.metamx.common.guava.Sequence<Result<SearchResultValue>> |
SearchQueryRunner.run(Query<Result<SearchResultValue>> input,
Map<String,Object> responseContext) |
Modifier and Type | Method and Description |
---|---|
Result<SearchResultValue> |
SearchBinaryFn.apply(Result<SearchResultValue> arg1,
Result<SearchResultValue> arg2) |
Result<SearchResultValue> |
SearchBinaryFn.apply(Result<SearchResultValue> arg1,
Result<SearchResultValue> arg2) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<SearchResultValue>> |
SearchQueryQueryToolChest.mergeResults(QueryRunner<Result<SearchResultValue>> runner) |
QueryRunner<Result<SearchResultValue>> |
SearchQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<SearchResultValue>>> queryRunners) |
com.metamx.common.guava.Sequence<Result<SearchResultValue>> |
SearchQueryQueryToolChest.mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<SearchResultValue>>> seqOfSequences) |
com.metamx.common.guava.Sequence<Result<SearchResultValue>> |
SearchQueryQueryToolChest.mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<SearchResultValue>>> seqOfSequences) |
QueryRunner<Result<SearchResultValue>> |
SearchQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SearchResultValue>> runner) |
com.metamx.common.guava.Sequence<Result<SearchResultValue>> |
SearchQueryRunner.run(Query<Result<SearchResultValue>> input,
Map<String,Object> responseContext) |
Constructor and Description |
---|
BySegmentSearchResultValue(List<Result<SearchResultValue>> results,
String segmentId,
org.joda.time.Interval interval) |
Modifier and Type | Method and Description |
---|---|
Query<Result<SearchResultValue>> |
SearchQuery.withDataSource(DataSource dataSource) |
Modifier and Type | Method and Description |
---|---|
Result<SelectResultValue> |
SelectBinaryFn.apply(Result<SelectResultValue> arg1,
Result<SelectResultValue> arg2) |
Result<SelectResultValue> |
SelectResultValueBuilder.build() |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<SelectResultValue>> |
SelectQueryRunnerFactory.createRunner(Segment segment) |
CacheStrategy<Result<SelectResultValue>,Object,SelectQuery> |
SelectQueryQueryToolChest.getCacheStrategy(SelectQuery query) |
com.google.common.collect.Ordering<Result<SelectResultValue>> |
SelectQueryQueryToolChest.getOrdering() |
com.fasterxml.jackson.core.type.TypeReference<Result<SelectResultValue>> |
SelectQueryQueryToolChest.getResultTypeReference() |
QueryToolChest<Result<SelectResultValue>,SelectQuery> |
SelectQueryRunnerFactory.getToolchest() |
com.google.common.base.Function<Result<SelectResultValue>,Result<SelectResultValue>> |
SelectQueryQueryToolChest.makePreComputeManipulatorFn(SelectQuery query,
MetricManipulationFn fn) |
com.google.common.base.Function<Result<SelectResultValue>,Result<SelectResultValue>> |
SelectQueryQueryToolChest.makePreComputeManipulatorFn(SelectQuery query,
MetricManipulationFn fn) |
QueryRunner<Result<SelectResultValue>> |
SelectQueryQueryToolChest.mergeResults(QueryRunner<Result<SelectResultValue>> queryRunner) |
QueryRunner<Result<SelectResultValue>> |
SelectQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<SelectResultValue>>> queryRunners) |
com.metamx.common.guava.Sequence<Result<SelectResultValue>> |
SelectQueryQueryToolChest.mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<SelectResultValue>>> seqOfSequences) |
com.metamx.common.guava.Sequence<Result<SelectResultValue>> |
SelectQueryQueryToolChest.mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<SelectResultValue>>> seqOfSequences) |
QueryRunner<Result<SelectResultValue>> |
SelectQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SelectResultValue>> runner) |
com.metamx.common.guava.Sequence<Result<SelectResultValue>> |
SelectQueryEngine.process(SelectQuery query,
Segment segment) |
Query<Result<SelectResultValue>> |
SelectQuery.withDataSource(DataSource dataSource) |
Modifier and Type | Method and Description |
---|---|
Result<SelectResultValue> |
SelectBinaryFn.apply(Result<SelectResultValue> arg1,
Result<SelectResultValue> arg2) |
Result<SelectResultValue> |
SelectBinaryFn.apply(Result<SelectResultValue> arg1,
Result<SelectResultValue> arg2) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<SelectResultValue>> |
SelectQueryQueryToolChest.mergeResults(QueryRunner<Result<SelectResultValue>> queryRunner) |
QueryRunner<Result<SelectResultValue>> |
SelectQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<SelectResultValue>>> queryRunners) |
com.metamx.common.guava.Sequence<Result<SelectResultValue>> |
SelectQueryQueryToolChest.mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<SelectResultValue>>> seqOfSequences) |
com.metamx.common.guava.Sequence<Result<SelectResultValue>> |
SelectQueryQueryToolChest.mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<SelectResultValue>>> seqOfSequences) |
QueryRunner<Result<SelectResultValue>> |
SelectQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SelectResultValue>> runner) |
Modifier and Type | Method and Description |
---|---|
Iterable<Result<TimeBoundaryResultValue>> |
TimeBoundaryQuery.buildResult(org.joda.time.DateTime timestamp,
org.joda.time.DateTime min,
org.joda.time.DateTime max) |
QueryRunner<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryRunnerFactory.createRunner(Segment segment) |
CacheStrategy<Result<TimeBoundaryResultValue>,Object,TimeBoundaryQuery> |
TimeBoundaryQueryQueryToolChest.getCacheStrategy(TimeBoundaryQuery query) |
com.google.common.collect.Ordering<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryQueryToolChest.getOrdering() |
com.fasterxml.jackson.core.type.TypeReference<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryQueryToolChest.getResultTypeReference() |
QueryToolChest<Result<TimeBoundaryResultValue>,TimeBoundaryQuery> |
TimeBoundaryQueryRunnerFactory.getToolchest() |
com.google.common.base.Function<Result<TimeBoundaryResultValue>,Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryQueryToolChest.makePreComputeManipulatorFn(TimeBoundaryQuery query,
MetricManipulationFn fn) |
com.google.common.base.Function<Result<TimeBoundaryResultValue>,Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryQueryToolChest.makePreComputeManipulatorFn(TimeBoundaryQuery query,
MetricManipulationFn fn) |
Iterable<Result<TimeBoundaryResultValue>> |
TimeBoundaryQuery.mergeResults(List<Result<TimeBoundaryResultValue>> results) |
QueryRunner<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeBoundaryResultValue>> runner) |
QueryRunner<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<TimeBoundaryResultValue>>> queryRunners) |
com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryQueryToolChest.mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>>> seqOfSequences) |
com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryQueryToolChest.mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>>> seqOfSequences) |
Query<Result<TimeBoundaryResultValue>> |
TimeBoundaryQuery.withDataSource(DataSource dataSource) |
Modifier and Type | Method and Description |
---|---|
Iterable<Result<TimeBoundaryResultValue>> |
TimeBoundaryQuery.mergeResults(List<Result<TimeBoundaryResultValue>> results) |
QueryRunner<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeBoundaryResultValue>> runner) |
QueryRunner<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<TimeBoundaryResultValue>>> queryRunners) |
com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryQueryToolChest.mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>>> seqOfSequences) |
com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryQueryToolChest.mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>>> seqOfSequences) |
Modifier and Type | Method and Description |
---|---|
Result<TimeseriesResultValue> |
TimeseriesBinaryFn.apply(Result<TimeseriesResultValue> arg1,
Result<TimeseriesResultValue> arg2) |
Result<TimeseriesResultValue> |
TimeseriesResultBuilder.build() |
Modifier and Type | Method and Description |
---|---|
Result<TimeseriesResultValue> |
TimeseriesBinaryFn.apply(Result<TimeseriesResultValue> arg1,
Result<TimeseriesResultValue> arg2) |
Result<TimeseriesResultValue> |
TimeseriesBinaryFn.apply(Result<TimeseriesResultValue> arg1,
Result<TimeseriesResultValue> arg2) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<TimeseriesResultValue>> |
TimeseriesQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeseriesResultValue>> queryRunner) |
QueryRunner<Result<TimeseriesResultValue>> |
TimeseriesQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<TimeseriesResultValue>>> queryRunners) |
com.metamx.common.guava.Sequence<Result<TimeseriesResultValue>> |
TimeseriesQueryQueryToolChest.mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TimeseriesResultValue>>> seqOfSequences) |
com.metamx.common.guava.Sequence<Result<TimeseriesResultValue>> |
TimeseriesQueryQueryToolChest.mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TimeseriesResultValue>>> seqOfSequences) |
QueryRunner<Result<TimeseriesResultValue>> |
TimeseriesQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TimeseriesResultValue>> runner) |
Modifier and Type | Method and Description |
---|---|
Result<TopNResultValue> |
TopNMapFn.apply(Cursor cursor) |
Result<TopNResultValue> |
TopNBinaryFn.apply(Result<TopNResultValue> arg1,
Result<TopNResultValue> arg2) |
Result<TopNResultValue> |
TopNResultBuilder.build() |
Result<TopNResultValue> |
TopNNumericResultBuilder.build() |
Result<TopNResultValue> |
TopNLexicographicResultBuilder.build() |
Result<TopNResultValue> |
TopNResultMerger.getResult(Result<TopNResultValue> result,
Comparator comparator) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<TopNResultValue>> |
TopNQueryRunnerFactory.createRunner(Segment segment) |
CacheStrategy<Result<TopNResultValue>,Object,TopNQuery> |
TopNQueryQueryToolChest.getCacheStrategy(TopNQuery query) |
com.google.common.collect.Ordering<Result<TopNResultValue>> |
TopNQueryQueryToolChest.getOrdering() |
List<Result<TopNResultValue>> |
BySegmentTopNResultValue.getResults() |
com.fasterxml.jackson.core.type.TypeReference<Result<TopNResultValue>> |
TopNQueryQueryToolChest.getResultTypeReference() |
QueryToolChest<Result<TopNResultValue>,TopNQuery> |
TopNQueryRunnerFactory.getToolchest() |
com.google.common.base.Function<Result<TopNResultValue>,Result<TopNResultValue>> |
TopNQueryQueryToolChest.makePostComputeManipulatorFn(TopNQuery query,
MetricManipulationFn fn) |
com.google.common.base.Function<Result<TopNResultValue>,Result<TopNResultValue>> |
TopNQueryQueryToolChest.makePostComputeManipulatorFn(TopNQuery query,
MetricManipulationFn fn) |
com.google.common.base.Function<Result<TopNResultValue>,Result<TopNResultValue>> |
TopNQueryQueryToolChest.makePreComputeManipulatorFn(TopNQuery query,
MetricManipulationFn fn) |
com.google.common.base.Function<Result<TopNResultValue>,Result<TopNResultValue>> |
TopNQueryQueryToolChest.makePreComputeManipulatorFn(TopNQuery query,
MetricManipulationFn fn) |
QueryRunner<Result<TopNResultValue>> |
TopNQueryQueryToolChest.mergeResults(QueryRunner<Result<TopNResultValue>> runner) |
QueryRunner<Result<TopNResultValue>> |
TopNQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<TopNResultValue>>> queryRunners) |
com.metamx.common.guava.Sequence<Result<TopNResultValue>> |
TopNQueryQueryToolChest.mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TopNResultValue>>> seqOfSequences) |
com.metamx.common.guava.Sequence<Result<TopNResultValue>> |
TopNQueryQueryToolChest.mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TopNResultValue>>> seqOfSequences) |
QueryRunner<Result<TopNResultValue>> |
TopNQueryQueryToolChest.postMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner) |
QueryRunner<Result<TopNResultValue>> |
TopNQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner) |
com.metamx.common.guava.Sequence<Result<TopNResultValue>> |
TopNQueryEngine.query(TopNQuery query,
StorageAdapter adapter) |
Query<Result<TopNResultValue>> |
TopNQuery.withDataSource(DataSource dataSource) |
Modifier and Type | Method and Description |
---|---|
Result<TopNResultValue> |
TopNBinaryFn.apply(Result<TopNResultValue> arg1,
Result<TopNResultValue> arg2) |
Result<TopNResultValue> |
TopNBinaryFn.apply(Result<TopNResultValue> arg1,
Result<TopNResultValue> arg2) |
Result<TopNResultValue> |
TopNResultMerger.getResult(Result<TopNResultValue> result,
Comparator comparator) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<TopNResultValue>> |
TopNQueryQueryToolChest.mergeResults(QueryRunner<Result<TopNResultValue>> runner) |
QueryRunner<Result<TopNResultValue>> |
TopNQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<TopNResultValue>>> queryRunners) |
com.metamx.common.guava.Sequence<Result<TopNResultValue>> |
TopNQueryQueryToolChest.mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TopNResultValue>>> seqOfSequences) |
com.metamx.common.guava.Sequence<Result<TopNResultValue>> |
TopNQueryQueryToolChest.mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TopNResultValue>>> seqOfSequences) |
QueryRunner<Result<TopNResultValue>> |
TopNQueryQueryToolChest.postMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner) |
QueryRunner<Result<TopNResultValue>> |
TopNQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner) |
Constructor and Description |
---|
BySegmentTopNResultValue(List<Result<TopNResultValue>> results,
String segmentId,
org.joda.time.Interval interval) |
Copyright © 2011–2015. All rights reserved.