io.druid.segment.realtime.firehose

Class EventReceiverFirehoseFactory.EventReceiverFirehose

java.lang.Object

io.druid.segment.realtime.firehose.EventReceiverFirehoseFactory.EventReceiverFirehose

All Implemented Interfaces:

Firehose, ChatHandler, EventReceiverFirehoseMetric, Closeable, AutoCloseable

Enclosing class:

EventReceiverFirehoseFactory

public class EventReceiverFirehoseFactory.EventReceiverFirehose
extends Object
implements ChatHandler, Firehose, EventReceiverFirehoseMetric

Constructor Summary

Constructors

Constructor and Description
EventReceiverFirehose(MapInputRowParser parser)

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	addAll(InputStream in, javax.servlet.http.HttpServletRequest req)
void	addRows(Iterable<InputRow> rows)
void	close()
Runnable	commit() Returns a runnable that will "commit" everything read up to the point at which commit() is called.
long	getBytesReceived() Return the number of bytes received by the firehose.
int	getCapacity() Return the capacity of the buffer.
int	getCurrentBufferSize() Return the current number of InputRow that are stored in the buffer.
boolean	hasMore() Returns whether there are more rows to process.
boolean	isClosed()
InputRow	nextRow() The next row available.
javax.ws.rs.core.Response	shutdown(String shutoffTime)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventReceiverFirehose

public EventReceiverFirehose(MapInputRowParser parser)

Method Detail

addAll

public javax.ws.rs.core.Response addAll(InputStream in,
                                        @Context
                                        javax.servlet.http.HttpServletRequest req)

hasMore

public boolean hasMore()

Description copied from interface: Firehose

Returns whether there are more rows to process. This is used to indicate that another item is immediately available via ##nextRow(). Thus, if the stream is still available but there are no new messages on it, this call should block until a new message is available. If something happens such that the stream is no longer available, this should return false.

Specified by:

hasMore in interface Firehose

Returns:

true if and when there is another row available, false if the stream has dried up

nextRow

public InputRow nextRow()

Description copied from interface: Firehose

The next row available. Should only be called if hasMore returns true.

Specified by:

nextRow in interface Firehose

Returns:

The next row

commit

public Runnable commit()

Description copied from interface: Firehose

Returns a runnable that will "commit" everything read up to the point at which commit() is called. This is often equivalent to everything that has been read since the last commit() call (or instantiation of the object), but doesn't necessarily have to be. This method is called when the main processing loop starts to persist its current batch of things to process. The returned runnable will be run when the current batch has been successfully persisted, there is usually some time lag between when this method is called and when the runnable is run. The Runnable is also run on a separate thread so its operation should be thread-safe. The Runnable is essentially just a lambda/closure that is run() after data supplied by this instance has been committed on the writer side of this interface protocol.

A simple implementation of this interface might do nothing when run() is called (in which case the same do-nothing instance can be returned every time), or a more complex implementation might clean up temporary resources that are no longer needed because of InputRows delivered by prior calls to ##nextRow().

Specified by:

commit in interface Firehose

getCurrentBufferSize

public int getCurrentBufferSize()

Description copied from interface: EventReceiverFirehoseMetric

Return the current number of InputRow that are stored in the buffer.

Specified by:

getCurrentBufferSize in interface EventReceiverFirehoseMetric

getCapacity

public int getCapacity()

Description copied from interface: EventReceiverFirehoseMetric

Return the capacity of the buffer.

Specified by:

getCapacity in interface EventReceiverFirehoseMetric

getBytesReceived

public long getBytesReceived()

Description copied from interface: EventReceiverFirehoseMetric

Return the number of bytes received by the firehose.

Specified by:

getBytesReceived in interface EventReceiverFirehoseMetric

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

addRows

public void addRows(Iterable<InputRow> rows)
             throws InterruptedException

Throws:

InterruptedException

shutdown

public javax.ws.rs.core.Response shutdown(String shutoffTime)

isClosed

public boolean isClosed()