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)
Class<? extends org.apache.hadoop.mapreduce.InputFormat>	getInputFormat()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, 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()

Specified by:

getInputFormat in interface PathSpec