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

Class uses public fields to work around http://jira.codehaus.org/browse/MSHADE-92 Adjust to JsonCreator and final fields when resolved.

Field Summary

Fields

Modifier and Type	Field and Description
String	paths

Constructor Summary

Constructors

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

Method Summary

Methods

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, 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

Field Detail

paths

public String paths

Constructor Detail

StaticPathSpec

public StaticPathSpec()

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 final void addToMultipleInputs(HadoopDruidIndexerConfig config,
                       org.apache.hadoop.mapreduce.Job job,
                       String path,
                       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