io.druid.segment.realtime.firehose

Class IrcParser

java.lang.Object

io.druid.segment.realtime.firehose.IrcParser

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 IrcParser
extends Object
implements io.druid.data.input.impl.InputRowParser<com.metamx.common.Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg>>

Constructor Summary

Constructors

Constructor and Description
IrcParser(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

IrcParser

public IrcParser(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>>