| Modifier and Type | Method and Description |
|---|---|
static Cache.NamedKey |
CacheUtil.computeSegmentCacheKey(String segmentIdentifier,
SegmentDescriptor descriptor,
byte[] queryCacheKey) |
| 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–2017. All rights reserved.