| Package | Description |
|---|---|
| io.druid.client | |
| io.druid.segment.realtime.appenderator | |
| io.druid.timeline |
| Modifier and Type | Method and Description |
|---|---|
VersionedIntervalTimeline<String,SegmentLoadInfo> |
CoordinatorServerView.getTimeline(DataSource dataSource) |
VersionedIntervalTimeline<String,ServerSelector> |
BrokerServerView.getTimeline(DataSource dataSource) |
| Constructor and Description |
|---|
SinkQuerySegmentWalker(String dataSource,
VersionedIntervalTimeline<String,Sink> sinkTimeline,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
ExecutorService queryExecutorService,
Cache cache,
CacheConfig cacheConfig) |
| Modifier and Type | Method and Description |
|---|---|
static VersionedIntervalTimeline<String,DataSegment> |
VersionedIntervalTimeline.forSegments(Iterable<DataSegment> segments) |
Copyright © 2011–2017. All rights reserved.