io.druid.segment.realtime.firehose

Class IrcFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.IrcFirehoseFactory

All Implemented Interfaces:

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

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

Example Usage

Decoder definition: wikipedia-decoder.json

{
   "type": "wikipedia",
   "namespaces": {
     "#en.wikipedia": {
       "": "main",
       "Category": "category",
       "Template talk": "template talk",
       "Help talk": "help talk",
       "Media": "media",
       "MediaWiki talk": "mediawiki talk",
       "File talk": "file talk",
       "MediaWiki": "mediawiki",
       "User": "user",
       "File": "file",
       "User talk": "user talk",
       "Template": "template",
       "Help": "help",
       "Special": "special",
       "Talk": "talk",
       "Category talk": "category talk"
     }
   },
   "geoIpDatabase": "path/to/GeoLite2-City.mmdb"
 }
 

Example code:

IrcDecoder wikipediaDecoder = new ObjectMapper().readValue(
   new File("wikipedia-decoder.json"),
   IrcDecoder.class
 );

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

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
io.druid.data.input.Firehose	connect(IrcParser firehoseParser)
List<String>	getChannels()
IrcDecoder	getDecoder()
String	getHost()
String	getNick()
IrcParser	getParser()

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,
                  IrcDecoder decoder)

Method Detail

getNick

public String getNick()

getHost

public String getHost()

getChannels

public List<String> getChannels()

getDecoder

public IrcDecoder getDecoder()

connect

public io.druid.data.input.Firehose connect(IrcParser firehoseParser)
                                     throws IOException

Specified by:

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

Throws:

IOException

getParser

public IrcParser getParser()

Specified by:

getParser in interface io.druid.data.input.FirehoseFactory<IrcParser>