org.apache.druid.segment.realtime.firehose

Class EventReceiverFirehoseFactory.EventReceiverFirehose

java.lang.Object

org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory.EventReceiverFirehose

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.druid.data.input.Firehose, ChatHandler, EventReceiverFirehoseMetric

Enclosing class:

EventReceiverFirehoseFactory

public class EventReceiverFirehoseFactory.EventReceiverFirehose
extends Object
implements ChatHandler, org.apache.druid.data.input.Firehose, EventReceiverFirehoseMetric

Constructor Summary

Constructors

Constructor and Description
EventReceiverFirehose(org.apache.druid.data.input.impl.InputRowParser<Map<String,Object>> 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<org.apache.druid.data.input.InputRow> rows)
void	close()
Runnable	commit()
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()
boolean	isClosed()
org.apache.druid.data.input.InputRow	nextRow()
javax.ws.rs.core.Response	shutdown(String shutoffTime, javax.servlet.http.HttpServletRequest req)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventReceiverFirehose

public EventReceiverFirehose(org.apache.druid.data.input.impl.InputRowParser<Map<String,Object>> parser)

Method Detail

addAll

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

hasMore

public boolean hasMore()

Specified by:

hasMore in interface org.apache.druid.data.input.Firehose

nextRow

@Nullable
public org.apache.druid.data.input.InputRow nextRow()

Specified by:

nextRow in interface org.apache.druid.data.input.Firehose

commit

public Runnable commit()

Specified by:

commit in interface org.apache.druid.data.input.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()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

addRows

public void addRows(Iterable<org.apache.druid.data.input.InputRow> rows)
             throws InterruptedException

Throws:

InterruptedException

shutdown

public javax.ws.rs.core.Response shutdown(String shutoffTime,
                                          @Context
                                          javax.servlet.http.HttpServletRequest req)

isClosed

public boolean isClosed()