io.druid.segment.realtime.firehose

Class EventReceiverFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.EventReceiverFirehoseFactory

All Implemented Interfaces:

io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.MapInputRowParser>

public class EventReceiverFirehoseFactory
extends Object
implements io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.MapInputRowParser>

Builds firehoses that accept events through the EventReceiver interface. Can also register these firehoses with an ServiceAnnouncingChatHandlerProvider.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	EventReceiverFirehoseFactory.EventReceiverFirehose

Constructor Summary

Constructors

Constructor and Description
EventReceiverFirehoseFactory(String serviceName, Integer bufferSize, ChatHandlerProvider chatHandlerProvider)

Method Summary

Methods

Modifier and Type	Method and Description
io.druid.data.input.Firehose	connect(io.druid.data.input.impl.MapInputRowParser firehoseParser)
int	getBufferSize()
String	getServiceName()

Methods inherited from class java.lang.Object

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

Constructor Detail

EventReceiverFirehoseFactory

public EventReceiverFirehoseFactory(String serviceName,
                            Integer bufferSize,
                            ChatHandlerProvider chatHandlerProvider)

Method Detail

connect

public io.druid.data.input.Firehose connect(io.druid.data.input.impl.MapInputRowParser firehoseParser)
                                     throws IOException

Specified by:

connect in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.MapInputRowParser>

Throws:

IOException

getServiceName

public String getServiceName()

getBufferSize

public int getBufferSize()