Uses of Class
io.druid.segment.realtime.plumber.Sink

Packages that use Sink

Package	Description
io.druid.segment.realtime.appenderator
io.druid.segment.realtime.plumber

Uses of Sink in io.druid.segment.realtime.appenderator

Constructor parameters in io.druid.segment.realtime.appenderator with type arguments of type Sink

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)

Uses of Sink in io.druid.segment.realtime.plumber

Methods in io.druid.segment.realtime.plumber that return types with arguments of type Sink

Modifier and Type	Method and Description
Map<Long,Sink>	RealtimePlumber.getSinks()

Methods in io.druid.segment.realtime.plumber with parameters of type Sink

Modifier and Type	Method and Description
protected void	RealtimePlumber.abandonSegment(long truncatedTime, Sink sink) Unannounces a given sink and removes all local references to it.
protected void	FlushingPlumber.flushAfterDuration(long truncatedTime, Sink sink)