public class IngestSegmentFirehoseFactory extends Object implements FirehoseFactory<InputRowParser>
Constructor and Description |
---|
IngestSegmentFirehoseFactory(String dataSource,
org.joda.time.Interval interval,
DimFilter dimFilter,
List<String> dimensions,
List<String> metrics,
IndexIO indexIO) |
Modifier and Type | Method and Description |
---|---|
Firehose |
connect(InputRowParser inputRowParser,
File temporaryDirectory)
Initialization method that connects up the fire hose.
|
String |
getDataSource() |
List<String> |
getDimensions() |
DimFilter |
getDimensionsFilter() |
org.joda.time.Interval |
getInterval() |
List<String> |
getMetrics() |
void |
setTaskToolbox(TaskToolbox taskToolbox) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect
public String getDataSource()
public org.joda.time.Interval getInterval()
public DimFilter getDimensionsFilter()
public void setTaskToolbox(TaskToolbox taskToolbox)
public Firehose connect(InputRowParser inputRowParser, File temporaryDirectory) throws IOException, ParseException
FirehoseFactory
PrefetchableTextFilesFirehoseFactory
may use a temporary
directory to cache data in it.connect
in interface FirehoseFactory<InputRowParser>
inputRowParser
- an input row parsertemporaryDirectory
- a directory where temporary files are storedIOException
ParseException
Copyright © 2011–2018. All rights reserved.