| Package | Description | 
|---|---|
| io.druid.client | |
| io.druid.segment.realtime.appenderator | |
| io.druid.server | |
| 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,
                      ServiceEmitter emitter,
                      QueryRunnerFactoryConglomerate conglomerate,
                      ExecutorService queryExecutorService,
                      Cache cache,
                      CacheConfig cacheConfig)  | 
| Modifier and Type | Method and Description | 
|---|---|
VersionedIntervalTimeline<String,ReferenceCountingSegment> | 
SegmentManager.DataSourceState.getTimeline()  | 
VersionedIntervalTimeline<String,ReferenceCountingSegment> | 
SegmentManager.getTimeline(String dataSource)  | 
| Modifier and Type | Method and Description | 
|---|---|
static VersionedIntervalTimeline<String,DataSegment> | 
VersionedIntervalTimeline.forSegments(Iterable<DataSegment> segments)  | 
Copyright © 2011–2018. All rights reserved.