io.druid.indexer.path

Class GranularUnprocessedPathSpec

java.lang.Object

io.druid.indexer.path.GranularityPathSpec

io.druid.indexer.path.GranularUnprocessedPathSpec

All Implemented Interfaces:

PathSpec

public class GranularUnprocessedPathSpec
extends GranularityPathSpec

Constructor Summary

Constructors

Constructor and Description
GranularUnprocessedPathSpec()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.Job	addInputPaths(HadoopDruidIndexerConfig config, org.apache.hadoop.mapreduce.Job job)
int	getMaxBuckets()
void	setMaxBuckets(int maxBuckets)

Methods inherited from class io.druid.indexer.path.GranularityPathSpec

getDataGranularity, getFilePattern, getInputPath, getPathFormat, setDataGranularity, setFilePattern, setInputPath, setPathFormat

Methods inherited from class java.lang.Object

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

Constructor Detail

GranularUnprocessedPathSpec

public GranularUnprocessedPathSpec()

Method Detail

getMaxBuckets

public int getMaxBuckets()

setMaxBuckets

public void setMaxBuckets(int maxBuckets)

addInputPaths

public org.apache.hadoop.mapreduce.Job addInputPaths(HadoopDruidIndexerConfig config,
                                            org.apache.hadoop.mapreduce.Job job)
                                              throws IOException

Specified by:

addInputPaths in interface PathSpec

Overrides:

addInputPaths in class GranularityPathSpec

Throws:

IOException