io.druid.segment.realtime.firehose

Class EventReceiverFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.EventReceiverFirehoseFactory

All Implemented Interfaces:

FirehoseFactory<MapInputRowParser>

public class EventReceiverFirehoseFactory
extends Object
implements FirehoseFactory<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, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.fasterxml.jackson.databind.ObjectMapper smileMapper, EventReceiverFirehoseRegister eventReceiverFirehoseRegister)

Method Summary

Modifier and Type	Method and Description
Firehose	connect(MapInputRowParser firehoseParser) Initialization method that connects up the fire hose.
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,
                                    com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                    com.fasterxml.jackson.databind.ObjectMapper smileMapper,
                                    EventReceiverFirehoseRegister eventReceiverFirehoseRegister)

Method Detail

connect

public Firehose connect(MapInputRowParser firehoseParser)
                 throws IOException

Description copied from interface: FirehoseFactory

Initialization method that connects up the fire hose. If this method returns successfully it should be safe to call hasMore() on the returned Firehose (which might subsequently block).

If this method returns null, then any attempt to call hasMore(), nextRow(), commit() and close() on the return value will throw a surprising NPE. Throwing IOException on connection failure or runtime exception on invalid configuration is preferred over returning null.

Specified by:

connect in interface FirehoseFactory<MapInputRowParser>

Throws:

IOException

getServiceName

public String getServiceName()

getBufferSize

public int getBufferSize()