io.druid.segment.realtime.firehose

Class IrcFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.IrcFirehoseFactory

All Implemented Interfaces:

io.druid.data.input.FirehoseFactory<IrcInputRowParser>

public class IrcFirehoseFactory
extends Object
implements io.druid.data.input.FirehoseFactory<IrcInputRowParser>

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

Methods

Modifier and Type	Method and Description
io.druid.data.input.Firehose	connect(IrcInputRowParser firehoseParser)
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

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 io.druid.data.input.Firehose connect(IrcInputRowParser firehoseParser)
                                     throws IOException

Specified by:

connect in interface io.druid.data.input.FirehoseFactory<IrcInputRowParser>

Throws:

IOException