| 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 © 2015. All rights reserved.