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.