Package | Description |
---|---|
io.druid.segment.realtime.plumber |
Modifier and Type | Method and Description |
---|---|
Sink |
RealtimePlumber.getSink(long timestamp) |
Sink |
Plumber.getSink(long timestamp) |
Modifier and Type | Method and Description |
---|---|
Map<Long,Sink> |
RealtimePlumber.getSinks() |
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) |
Copyright © 2011–2015. All rights reserved.