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, io.druid.data.input.impl.InputRowParser parser, 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()
io.druid.data.input.impl.InputRowParser	getParser()
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,
                            io.druid.data.input.impl.InputRowParser parser,
                            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()

getParser

public io.druid.data.input.impl.InputRowParser getParser()

Specified by:

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