io.druid.segment.realtime.firehose

Class IrcInputRowParser

java.lang.Object

io.druid.segment.realtime.firehose.IrcInputRowParser

All Implemented Interfaces:

io.druid.data.input.impl.InputRowParser<com.metamx.common.Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg>>

public class IrcInputRowParser
extends Object
implements io.druid.data.input.impl.InputRowParser<com.metamx.common.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(io.druid.data.input.impl.ParseSpec parseSpec, IrcDecoder decoder)

Method Summary

Methods

Modifier and Type	Method and Description
IrcDecoder	getDecoder()
io.druid.data.input.impl.ParseSpec	getParseSpec()
io.druid.data.input.InputRow	parse(com.metamx.common.Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg> msg)
io.druid.data.input.impl.InputRowParser	withParseSpec(io.druid.data.input.impl.ParseSpec parseSpec)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IrcInputRowParser

public IrcInputRowParser(io.druid.data.input.impl.ParseSpec parseSpec,
                 IrcDecoder decoder)

Method Detail

getDecoder

public IrcDecoder getDecoder()

parse

public io.druid.data.input.InputRow parse(com.metamx.common.Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg> msg)

Specified by:

parse in interface io.druid.data.input.impl.InputRowParser<com.metamx.common.Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg>>

getParseSpec

public io.druid.data.input.impl.ParseSpec getParseSpec()

Specified by:

getParseSpec in interface io.druid.data.input.impl.InputRowParser<com.metamx.common.Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg>>

withParseSpec

public io.druid.data.input.impl.InputRowParser withParseSpec(io.druid.data.input.impl.ParseSpec parseSpec)

Specified by:

withParseSpec in interface io.druid.data.input.impl.InputRowParser<com.metamx.common.Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg>>