Package | Description |
---|---|
io.druid.segment.realtime.plumber |
Modifier and Type | Method and Description |
---|---|
FireHydrant |
Sink.getCurrHydrant() |
FireHydrant |
Sink.swap()
If currHydrant is A, creates a new index B, sets currHydrant to B and returns A.
|
Modifier and Type | Method and Description |
---|---|
Iterator<FireHydrant> |
Sink.iterator() |
Modifier and Type | Method and Description |
---|---|
protected int |
RealtimePlumber.persistHydrant(FireHydrant indexToPersist,
DataSchema schema,
org.joda.time.Interval interval)
Persists the given hydrant and returns the number of rows persisted
|
Constructor and Description |
---|
Sink(org.joda.time.Interval interval,
DataSchema schema,
RealtimeTuningConfig config,
String version,
List<FireHydrant> hydrants) |
Copyright © 2011–2015. All rights reserved.