io.druid.segment.realtime.firehose

Class EventReceiverFirehoseFactory.EventReceiverFirehose

java.lang.Object

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

All Implemented Interfaces:

io.druid.data.input.Firehose, ChatHandler, Closeable, AutoCloseable

Enclosing class:

EventReceiverFirehoseFactory

public class EventReceiverFirehoseFactory.EventReceiverFirehose
extends Object
implements ChatHandler, io.druid.data.input.Firehose

Constructor Summary

Constructors

Constructor and Description
EventReceiverFirehoseFactory.EventReceiverFirehose(io.druid.data.input.impl.MapInputRowParser parser)

Method Summary

Methods

Modifier and Type	Method and Description
javax.ws.rs.core.Response	addAll(Collection<Map<String,Object>> events)
void	close()
Runnable	commit()
boolean	hasMore()
io.druid.data.input.InputRow	nextRow()

Methods inherited from class java.lang.Object

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

Constructor Detail

EventReceiverFirehoseFactory.EventReceiverFirehose

public EventReceiverFirehoseFactory.EventReceiverFirehose(io.druid.data.input.impl.MapInputRowParser parser)

Method Detail

addAll

public javax.ws.rs.core.Response addAll(Collection<Map<String,Object>> events)

hasMore

public boolean hasMore()

Specified by:

hasMore in interface io.druid.data.input.Firehose

nextRow

public io.druid.data.input.InputRow nextRow()

Specified by:

nextRow in interface io.druid.data.input.Firehose

commit

public Runnable commit()

Specified by:

commit in interface io.druid.data.input.Firehose

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException