io.druid.segment.realtime.plumber

Class Sink

java.lang.Object

io.druid.segment.realtime.plumber.Sink

All Implemented Interfaces:

Iterable<FireHydrant>

public class Sink
extends Object
implements Iterable<FireHydrant>

Constructor Summary

Constructors

Constructor and Description
Sink(org.joda.time.Interval interval, DataSchema schema, RealtimeTuningConfig config, String version)
Sink(org.joda.time.Interval interval, DataSchema schema, RealtimeTuningConfig config, String version, List<FireHydrant> hydrants)

Method Summary

Methods

Modifier and Type	Method and Description
int	add(io.druid.data.input.InputRow row)
FireHydrant	getCurrHydrant()
org.joda.time.Interval	getInterval()
io.druid.timeline.DataSegment	getSegment()
String	getVersion()
boolean	isEmpty()
Iterator<FireHydrant>	iterator()
FireHydrant	swap() If currHydrant is A, creates a new index B, sets currHydrant to B and returns A.
boolean	swappable()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Sink

public Sink(org.joda.time.Interval interval,
    DataSchema schema,
    RealtimeTuningConfig config,
    String version)

Sink

public Sink(org.joda.time.Interval interval,
    DataSchema schema,
    RealtimeTuningConfig config,
    String version,
    List<FireHydrant> hydrants)

Method Detail

getVersion

public String getVersion()

getInterval

public org.joda.time.Interval getInterval()

getCurrHydrant

public FireHydrant getCurrHydrant()

add

public int add(io.druid.data.input.InputRow row)

isEmpty

public boolean isEmpty()

swap

public FireHydrant swap()

If currHydrant is A, creates a new index B, sets currHydrant to B and returns A.

Returns:

the current index after swapping in a new one

swappable

public boolean swappable()

getSegment

public io.druid.timeline.DataSegment getSegment()

iterator

public Iterator<FireHydrant> iterator()

Specified by:

iterator in interface Iterable<FireHydrant>

toString

public String toString()

Overrides:

toString in class Object