io.druid.indexing.firehose

Class IngestSegmentFirehoseFactory

java.lang.Object

io.druid.indexing.firehose.IngestSegmentFirehoseFactory

All Implemented Interfaces:

FirehoseFactory<InputRowParser>

public class IngestSegmentFirehoseFactory
extends Object
implements FirehoseFactory<InputRowParser>

Constructor Summary

Constructors

Constructor and Description
IngestSegmentFirehoseFactory(String dataSource, org.joda.time.Interval interval, DimFilter dimFilter, List<String> dimensions, List<String> metrics, com.google.inject.Injector injector, IndexIO indexIO)

Method Summary

Modifier and Type	Method and Description
Firehose	connect(InputRowParser inputRowParser) Initialization method that connects up the fire hose.
String	getDataSource()
List<String>	getDimensions()
DimFilter	getDimensionsFilter()
org.joda.time.Interval	getInterval()
List<String>	getMetrics()

Methods inherited from class java.lang.Object

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

Constructor Detail

IngestSegmentFirehoseFactory

public IngestSegmentFirehoseFactory(String dataSource,
                                    org.joda.time.Interval interval,
                                    DimFilter dimFilter,
                                    List<String> dimensions,
                                    List<String> metrics,
                                    com.google.inject.Injector injector,
                                    IndexIO indexIO)

Method Detail

getDataSource

public String getDataSource()

getInterval

public org.joda.time.Interval getInterval()

getDimensionsFilter

public DimFilter getDimensionsFilter()

getDimensions

public List<String> getDimensions()

getMetrics

public List<String> getMetrics()

connect

public Firehose connect(InputRowParser inputRowParser)
                 throws IOException,
                        ParseException

Description copied from interface: FirehoseFactory

Initialization method that connects up the fire hose. If this method returns successfully it should be safe to call hasMore() on the returned Firehose (which might subsequently block).

If this method returns null, then any attempt to call hasMore(), nextRow(), commit() and close() on the return value will throw a surprising NPE. Throwing IOException on connection failure or runtime exception on invalid configuration is preferred over returning null.

Specified by:

connect in interface FirehoseFactory<InputRowParser>

Throws:

IOException

ParseException