org.apache.druid.segment.realtime.firehose

Class EventReceiverFirehoseFactory

java.lang.Object

org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory

All Implemented Interfaces:

org.apache.druid.data.input.FirehoseFactory<org.apache.druid.data.input.impl.InputRowParser<Map<String,Object>>>

public class EventReceiverFirehoseFactory
extends Object
implements org.apache.druid.data.input.FirehoseFactory<org.apache.druid.data.input.impl.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, Long maxIdleTime, 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
org.apache.druid.data.input.Firehose	connect(org.apache.druid.data.input.impl.InputRowParser<Map<String,Object>> firehoseParser, File temporaryDirectory)
int	getBufferSize()
long	getMaxIdleTime()
String	getServiceName()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.data.input.FirehoseFactory

connect, isSplittable

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,
                                    Long maxIdleTime,
                                    ChatHandlerProvider chatHandlerProvider,
                                    com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                    com.fasterxml.jackson.databind.ObjectMapper smileMapper,
                                    EventReceiverFirehoseRegister eventReceiverFirehoseRegister,
                                    AuthorizerMapper authorizerMapper)

Method Detail

connect

public org.apache.druid.data.input.Firehose connect(org.apache.druid.data.input.impl.InputRowParser<Map<String,Object>> firehoseParser,
                                                    File temporaryDirectory)

Specified by:

connect in interface org.apache.druid.data.input.FirehoseFactory<org.apache.druid.data.input.impl.InputRowParser<Map<String,Object>>>

getServiceName

public String getServiceName()

getBufferSize

public int getBufferSize()

getMaxIdleTime

public long getMaxIdleTime()