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

Packages that use Sink

Package	Description
io.druid.segment.realtime.plumber

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

Methods in io.druid.segment.realtime.plumber that return Sink

Modifier and Type	Method and Description
Sink	RealtimePlumber.getSink(long timestamp)

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)