org.apache.druid.segment.realtime.plumber

Class Sink

java.lang.Object

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

Method Summary

Modifier and Type	Method and Description
IncrementalIndexAddResult	add(org.apache.druid.data.input.InputRow row, boolean skipMaxRowsInMemoryCheck)
boolean	canAppendRow()
void	clearDedupCache()
boolean	finished()
boolean	finishWriting() Marks sink as 'finished', preventing further writes.
long	getBytesInMemory()
FireHydrant	getCurrHydrant()
org.joda.time.Interval	getInterval()
int	getNumRows()
int	getNumRowsInMemory()
org.apache.druid.timeline.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,
            org.apache.druid.timeline.partition.ShardSpec shardSpec,
            String version,
            int maxRowsInMemory,
            long maxBytesInMemory,
            boolean reportParseExceptions,
            String dedupColumn)

Sink

public Sink(org.joda.time.Interval interval,
            DataSchema schema,
            org.apache.druid.timeline.partition.ShardSpec shardSpec,
            String version,
            int maxRowsInMemory,
            long maxBytesInMemory,
            boolean reportParseExceptions,
            String dedupColumn,
            List<FireHydrant> hydrants)

Method Detail

clearDedupCache

public void clearDedupCache()

getVersion

public String getVersion()

getInterval

public org.joda.time.Interval getInterval()

getCurrHydrant

public FireHydrant getCurrHydrant()

add

public IncrementalIndexAddResult add(org.apache.druid.data.input.InputRow row,
                                     boolean skipMaxRowsInMemoryCheck)
                              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 boolean finishWriting()

Marks sink as 'finished', preventing further writes.

Returns:

'true' if sink was sucessfully finished, 'false' if sink was already finished

getSegment

public org.apache.druid.timeline.DataSegment getSegment()

getNumRows

public int getNumRows()

getNumRowsInMemory

public int getNumRowsInMemory()

getBytesInMemory

public long getBytesInMemory()

iterator

public Iterator<FireHydrant> iterator()

Specified by:

iterator in interface Iterable<FireHydrant>

toString

public String toString()

Overrides:

toString in class Object