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.