io.druid.indexer.path

Class StaticPathSpec

java.lang.Object

io.druid.indexer.path.StaticPathSpec

All Implemented Interfaces:

PathSpec

public class StaticPathSpec
extends Object
implements PathSpec

Constructor Summary

Constructors

Constructor and Description
StaticPathSpec(String paths, Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormat)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.Job	addInputPaths(HadoopDruidIndexerConfig config, org.apache.hadoop.mapreduce.Job job)
static void	addToMultipleInputs(HadoopDruidIndexerConfig config, org.apache.hadoop.mapreduce.Job job, Set<String> paths, Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)
static void	addToMultipleInputs(HadoopDruidIndexerConfig config, org.apache.hadoop.mapreduce.Job job, String path, Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)
boolean	equals(Object o)
Class<? extends org.apache.hadoop.mapreduce.InputFormat>	getInputFormat()
String	getPaths()
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

StaticPathSpec

public StaticPathSpec(String paths,
                      Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormat)

Method Detail

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

getInputFormat

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

getPaths

public String getPaths()

addToMultipleInputs

public static void addToMultipleInputs(HadoopDruidIndexerConfig config,
                                       org.apache.hadoop.mapreduce.Job job,
                                       String path,
                                       Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)

addToMultipleInputs

public static void addToMultipleInputs(HadoopDruidIndexerConfig config,
                                       org.apache.hadoop.mapreduce.Job job,
                                       Set<String> paths,
                                       Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object