io.druid.indexer.path

Class GranularityPathSpec

java.lang.Object

io.druid.indexer.path.GranularityPathSpec

All Implemented Interfaces:

PathSpec

Direct Known Subclasses:

GranularUnprocessedPathSpec

public class GranularityPathSpec
extends Object
implements PathSpec

Constructor Summary

Constructors

Constructor and Description
GranularityPathSpec()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.Job	addInputPaths(HadoopDruidIndexerConfig config, org.apache.hadoop.mapreduce.Job job)
Granularity	getDataGranularity()
String	getFilePattern()
Class<? extends org.apache.hadoop.mapreduce.InputFormat>	getInputFormat()
String	getInputPath()
String	getPathFormat()
void	setDataGranularity(Granularity dataGranularity)
void	setFilePattern(String filePattern)
void	setInputFormat(Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormat)
void	setInputPath(String inputPath)
void	setPathFormat(String pathFormat)

Methods inherited from class java.lang.Object

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

Constructor Detail

GranularityPathSpec

public GranularityPathSpec()

Method Detail

getInputPath

public String getInputPath()

setInputPath

public void setInputPath(String inputPath)

getInputFormat

public Class<? extends org.apache.hadoop.mapreduce.InputFormat> getInputFormat()

setInputFormat

public void setInputFormat(Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormat)

getFilePattern

public String getFilePattern()

setFilePattern

public void setFilePattern(String filePattern)

getDataGranularity

public Granularity getDataGranularity()

setDataGranularity

public void setDataGranularity(Granularity dataGranularity)

getPathFormat

public String getPathFormat()

setPathFormat

public void setPathFormat(String pathFormat)

addInputPaths

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

Specified by:

addInputPaths in interface PathSpec

Throws:

IOException