io.druid.segment.realtime.plumber

Interface Plumber

All Known Implementing Classes:

FlushingPlumber, RealtimePlumber

public interface Plumber

Method Summary

Methods

Modifier and Type	Method and Description
int	add(io.druid.data.input.InputRow row)
void	finishJob() Perform any final processing and clean up after ourselves.
<T> QueryRunner<T>	getQueryRunner(Query<T> query)
Sink	getSink(long timestamp)
void	persist(Runnable commitRunnable) Persist any in-memory indexed data to durable storage.
void	startJob() Perform any initial setup.

Method Detail

startJob

void startJob()

Perform any initial setup. Should be called before using any other methods, and should be paired with a corresponding call to finishJob().

add

int add(io.druid.data.input.InputRow row)
        throws IndexSizeExceededException

Parameters:

row - - the row to insert

Returns:

- positive numbers indicate how many summarized rows exist in the index for that timestamp, -1 means a row was thrown away because it was too late

Throws:

IndexSizeExceededException

getQueryRunner

<T> QueryRunner<T> getQueryRunner(Query<T> query)

persist

void persist(Runnable commitRunnable)

Persist any in-memory indexed data to durable storage. This may be only somewhat durable, e.g. the machine's local disk.

Parameters:

commitRunnable - code to run after persisting data

finishJob

void finishJob()

Perform any final processing and clean up after ourselves. Should be called after all data has been fed into sinks and persisted.

getSink

Sink getSink(long timestamp)