public class EventReceiverFirehoseFactory.EventReceiverFirehose extends Object implements ChatHandler, io.druid.data.input.Firehose, EventReceiverFirehoseMetric
Constructor and Description |
---|
EventReceiverFirehose(io.druid.data.input.impl.MapInputRowParser parser) |
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
addAll(InputStream in,
javax.servlet.http.HttpServletRequest req) |
void |
addRows(Iterable<io.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() |
io.druid.data.input.InputRow |
nextRow() |
public EventReceiverFirehose(io.druid.data.input.impl.MapInputRowParser parser)
public javax.ws.rs.core.Response addAll(InputStream in, @Context javax.servlet.http.HttpServletRequest req)
public boolean hasMore()
hasMore
in interface io.druid.data.input.Firehose
public io.druid.data.input.InputRow nextRow()
nextRow
in interface io.druid.data.input.Firehose
public Runnable commit()
commit
in interface io.druid.data.input.Firehose
public int getCurrentBufferSize()
EventReceiverFirehoseMetric
InputRow
that are stored in the buffer.getCurrentBufferSize
in interface EventReceiverFirehoseMetric
public int getCapacity()
EventReceiverFirehoseMetric
getCapacity
in interface EventReceiverFirehoseMetric
public long getBytesReceived()
EventReceiverFirehoseMetric
getBytesReceived
in interface EventReceiverFirehoseMetric
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public void addRows(Iterable<io.druid.data.input.InputRow> rows) throws InterruptedException
InterruptedException
Copyright © 2011–2016. All rights reserved.