io.druid.segment.realtime.firehose

Class IrcInputRowParser

java.lang.Object

io.druid.segment.realtime.firehose.IrcInputRowParser

All Implemented Interfaces:

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

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

Example Usage

Decoder definition: wikipedia-decoder.json

 <p/>
 {
   "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"
 }
 

Constructor Summary

Constructors

Constructor and Description
IrcInputRowParser(ParseSpec parseSpec, IrcDecoder decoder)

Method Summary

Modifier and Type	Method and Description
IrcDecoder	getDecoder()
ParseSpec	getParseSpec()
List<InputRow>	parseBatch(Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg> msg) Parse an input into list of InputRow.
InputRowParser	withParseSpec(ParseSpec parseSpec)

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.impl.InputRowParser

parse

Constructor Detail

IrcInputRowParser

public IrcInputRowParser(ParseSpec parseSpec,
                         IrcDecoder decoder)

Method Detail

getDecoder

public IrcDecoder getDecoder()

parseBatch

public List<InputRow> parseBatch(Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg> msg)

Description copied from interface: InputRowParser

Parse an input into list of InputRow. List can contains null for rows that should be thrown away, or throws ParseException if the input is unparseable. This method should never return null otherwise lots of things will break.

Specified by:

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

getParseSpec

public ParseSpec getParseSpec()

Specified by:

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

withParseSpec

public InputRowParser withParseSpec(ParseSpec parseSpec)

Specified by:

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