io.druid.segment.realtime.firehose

Class IrcFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.IrcFirehoseFactory

All Implemented Interfaces:

FirehoseFactory<InputRowParser<Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg>>>

public class IrcFirehoseFactory
extends Object
implements FirehoseFactory<InputRowParser<Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg>>>

Example code:

 <p/>
 IrcFirehoseFactory factory = new IrcFirehoseFactory(
     "wiki123",
     "irc.wikimedia.org",
     Lists.newArrayList(
         "#en.wikipedia",
         "#fr.wikipedia",
         "#de.wikipedia",
         "#ja.wikipedia"
     )
 );
 

Constructor Summary

Constructors

Constructor and Description
IrcFirehoseFactory(String nick, String host, List<String> channels)

Method Summary

Modifier and Type	Method and Description
Firehose	connect(InputRowParser<Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg>> firehoseParser, File temporaryDirectory) Initialization method that connects up the fire hose.
List<String>	getChannels()
String	getHost()
String	getNick()

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

Constructor Detail

IrcFirehoseFactory

public IrcFirehoseFactory(String nick,
                          String host,
                          List<String> channels)

Method Detail

getNick

public String getNick()

getHost

public String getHost()

getChannels

public List<String> getChannels()

connect

public Firehose connect(InputRowParser<Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg>> 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<Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg>>>

Parameters:

firehoseParser - an input row parser

temporaryDirectory - a directory where temporary files are stored

Throws:

IOException