| Modifier and Type | Method and Description | 
|---|---|
static Cache.NamedKey | 
CacheUtil.computeSegmentCacheKey(String segmentIdentifier,
                      SegmentDescriptor descriptor,
                      byte[] queryCacheKey)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> QueryRunner<T> | 
CachingClusteredClient.getQueryRunnerForSegments(Query<T> query,
                         Iterable<SegmentDescriptor> specs)  | 
| Constructor and Description | 
|---|
CachingQueryRunner(String segmentIdentifier,
                  SegmentDescriptor segmentDescriptor,
                  com.fasterxml.jackson.databind.ObjectMapper mapper,
                  Cache cache,
                  QueryToolChest toolchest,
                  QueryRunner<T> base,
                  ExecutorService backgroundExecutorService,
                  CacheConfig cacheConfig)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> QueryRunner<T> | 
ThreadPoolTaskRunner.getQueryRunnerForSegments(Query<T> query,
                         Iterable<SegmentDescriptor> specs)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> QueryRunner<T> | 
QuerySegmentWalker.getQueryRunnerForSegments(Query<T> query,
                         Iterable<SegmentDescriptor> specs)
Gets the Queryable for a given list of SegmentSpecs. 
 | 
| Constructor and Description | 
|---|
LocatedSegmentDescriptor(SegmentDescriptor descriptor,
                        long size,
                        List<DruidServerMetadata> candidates)  | 
ReferenceCountingSegmentQueryRunner(QueryRunnerFactory<T,Query<T>> factory,
                                   ReferenceCountingSegment adapter,
                                   SegmentDescriptor descriptor)  | 
ReportTimelineMissingSegmentQueryRunner(SegmentDescriptor descriptor)  | 
| Modifier and Type | Method and Description | 
|---|---|
SegmentDescriptor | 
SpecificSegmentSpec.getDescriptor()  | 
| Modifier and Type | Method and Description | 
|---|---|
List<SegmentDescriptor> | 
MultipleSpecificSegmentSpec.getDescriptors()  | 
| Constructor and Description | 
|---|
SpecificSegmentSpec(SegmentDescriptor descriptor)  | 
| Constructor and Description | 
|---|
MultipleSpecificSegmentSpec(List<SegmentDescriptor> descriptors)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> QueryRunner<T> | 
RealtimeManager.getQueryRunnerForSegments(Query<T> query,
                         Iterable<SegmentDescriptor> specs)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> QueryRunner<T> | 
SinkQuerySegmentWalker.getQueryRunnerForSegments(Query<T> query,
                         Iterable<SegmentDescriptor> specs)  | 
<T> QueryRunner<T> | 
AppenderatorImpl.getQueryRunnerForSegments(Query<T> query,
                         Iterable<SegmentDescriptor> specs)  | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
SegmentHandoffNotifier.registerSegmentHandoffCallback(SegmentDescriptor descriptor,
                              Executor exec,
                              Runnable handOffRunnable)
register a handOffCallback to be called when segment handoff is complete. 
 | 
boolean | 
CoordinatorBasedSegmentHandoffNotifier.registerSegmentHandoffCallback(SegmentDescriptor descriptor,
                              Executor exec,
                              Runnable handOffRunnable)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> QueryRunner<T> | 
DirectClientQuerySegmentWalker.getQueryRunnerForSegments(Query<T> query,
                         Iterable<SegmentDescriptor> specs)  | 
<T> QueryRunner<T> | 
ClientQuerySegmentWalker.getQueryRunnerForSegments(Query<T> query,
                         Iterable<SegmentDescriptor> specs)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> QueryRunner<T> | 
ServerManager.getQueryRunnerForSegments(Query<T> query,
                         Iterable<SegmentDescriptor> specs)  | 
| Modifier and Type | Method and Description | 
|---|---|
SegmentDescriptor | 
DataSegment.toDescriptor()  | 
Copyright © 2011–2018. All rights reserved.