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, ShardSpec shardSpec, String version, int maxRowsInMemory, boolean reportParseExceptions)
Sink(org.joda.time.Interval interval, DataSchema schema, ShardSpec shardSpec, String version, int maxRowsInMemory, boolean reportParseExceptions, List<FireHydrant> hydrants)

Method Summary

Modifier and Type	Method and Description
int	add(InputRow row)
boolean	canAppendRow()
boolean	finished()
void	finishWriting()
FireHydrant	getCurrHydrant()
org.joda.time.Interval	getInterval()
int	getNumRows()
int	getNumRowsInMemory()
DataSegment	getSegment()
String	getVersion()
boolean	isEmpty()
boolean	isWritable()
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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

Sink

public Sink(org.joda.time.Interval interval,
            DataSchema schema,
            ShardSpec shardSpec,
            String version,
            int maxRowsInMemory,
            boolean reportParseExceptions)

Sink

public Sink(org.joda.time.Interval interval,
            DataSchema schema,
            ShardSpec shardSpec,
            String version,
            int maxRowsInMemory,
            boolean reportParseExceptions,
            List<FireHydrant> hydrants)

Method Detail

getVersion

public String getVersion()

getInterval

public org.joda.time.Interval getInterval()

getCurrHydrant

public FireHydrant getCurrHydrant()

add

public int add(InputRow row)
        throws IndexSizeExceededException

Throws:

IndexSizeExceededException

canAppendRow

public boolean canAppendRow()

isEmpty

public boolean isEmpty()

isWritable

public boolean isWritable()

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()

finished

public boolean finished()

finishWriting

public void finishWriting()

getSegment

public DataSegment getSegment()

getNumRows

public int getNumRows()

getNumRowsInMemory

public int getNumRowsInMemory()

iterator

public Iterator<FireHydrant> iterator()

Specified by:

iterator in interface Iterable<FireHydrant>

toString

public String toString()

Overrides:

toString in class Object