public class EventReceiverFirehoseFactory extends Object implements FirehoseFactory<InputRowParser<Map<String,Object>>>
EventReceiver
interface. Can also register these
firehoses with an ServiceAnnouncingChatHandlerProvider
.Modifier and Type | Class and Description |
---|---|
class |
EventReceiverFirehoseFactory.EventReceiverFirehose |
Modifier and Type | Field and Description |
---|---|
static int |
MAX_FIREHOSE_PRODUCERS |
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) |
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() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect
public static final int MAX_FIREHOSE_PRODUCERS
public EventReceiverFirehoseFactory(String serviceName, Integer bufferSize, ChatHandlerProvider chatHandlerProvider, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.fasterxml.jackson.databind.ObjectMapper smileMapper, EventReceiverFirehoseRegister eventReceiverFirehoseRegister, AuthorizerMapper authorizerMapper)
public Firehose connect(InputRowParser<Map<String,Object>> firehoseParser, File temporaryDirectory) throws IOException
FirehoseFactory
PrefetchableTextFilesFirehoseFactory
may use a temporary
directory to cache data in it.connect
in interface FirehoseFactory<InputRowParser<Map<String,Object>>>
firehoseParser
- an input row parsertemporaryDirectory
- a directory where temporary files are storedIOException
public String getServiceName()
public int getBufferSize()
Copyright © 2011–2018. All rights reserved.