| 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.