io.druid.segment.realtime.firehose

Class EventReceiverFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.EventReceiverFirehoseFactory

All Implemented Interfaces:

FirehoseFactory<InputRowParser<Map<String,Object>>>

public class EventReceiverFirehoseFactory
extends Object
implements FirehoseFactory<InputRowParser<Map<String,Object>>>

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

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_FIREHOSE_PRODUCERS

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, AuthorizerMapper authorizerMapper)

Method Summary

Modifier and Type	Method and Description
Firehose	connect(InputRowParser<Map<String,Object>> firehoseParser, File temporaryDirectory) 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

Methods inherited from interface io.druid.data.input.FirehoseFactory

connect

Field Detail

MAX_FIREHOSE_PRODUCERS

public static final int MAX_FIREHOSE_PRODUCERS

See Also:

Constant Field Values

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,
                                    AuthorizerMapper authorizerMapper)

Method Detail

connect

public Firehose connect(InputRowParser<Map<String,Object>> firehoseParser,
                        File temporaryDirectory)
                 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.

Some fire hoses like PrefetchableTextFilesFirehoseFactory may use a temporary directory to cache data in it.

Specified by:

connect in interface FirehoseFactory<InputRowParser<Map<String,Object>>>

Parameters:

firehoseParser - an input row parser

temporaryDirectory - a directory where temporary files are stored

Throws:

IOException

getServiceName

public String getServiceName()

getBufferSize

public int getBufferSize()