io.druid.examples.web

Class WebFirehoseFactory

java.lang.Object

io.druid.examples.web.WebFirehoseFactory

All Implemented Interfaces:

io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.InputRowParser>

public class WebFirehoseFactory
extends Object
implements io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.InputRowParser>

Constructor Summary

Constructors

Constructor and Description
WebFirehoseFactory(String url, Map<String,String> renamedDimensions, String timeDimension, String timeFormat)
WebFirehoseFactory(UpdateStreamFactory factory, String timeFormat)

Method Summary

Methods

Modifier and Type	Method and Description
io.druid.data.input.Firehose	connect(io.druid.data.input.impl.InputRowParser parser)
io.druid.data.input.impl.InputRowParser	getParser()

Methods inherited from class java.lang.Object

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

Constructor Detail

WebFirehoseFactory

public WebFirehoseFactory(String url,
                  Map<String,String> renamedDimensions,
                  String timeDimension,
                  String timeFormat)

WebFirehoseFactory

public WebFirehoseFactory(UpdateStreamFactory factory,
                  String timeFormat)

Method Detail

connect

public io.druid.data.input.Firehose connect(io.druid.data.input.impl.InputRowParser parser)
                                     throws IOException

Specified by:

connect in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.InputRowParser>

Throws:

IOException

getParser

public io.druid.data.input.impl.InputRowParser getParser()

Specified by:

getParser in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.InputRowParser>