io.druid.indexer.path

Class DatasourcePathSpec

java.lang.Object

io.druid.indexer.path.DatasourcePathSpec

All Implemented Interfaces:

PathSpec

public class DatasourcePathSpec
extends Object
implements PathSpec

Constructor Summary

Constructors

Constructor and Description
DatasourcePathSpec(com.fasterxml.jackson.databind.ObjectMapper mapper, List<WindowedDataSegment> segments, DatasourceIngestionSpec spec, Long maxSplitSize)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.Job	addInputPaths(HadoopDruidIndexerConfig config, org.apache.hadoop.mapreduce.Job job)
boolean	equals(Object o)
DatasourceIngestionSpec	getIngestionSpec()
long	getMaxSplitSize()
List<WindowedDataSegment>	getSegments()
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

DatasourcePathSpec

public DatasourcePathSpec(com.fasterxml.jackson.databind.ObjectMapper mapper,
                          List<WindowedDataSegment> segments,
                          DatasourceIngestionSpec spec,
                          Long maxSplitSize)

Method Detail

getSegments

public List<WindowedDataSegment> getSegments()

getIngestionSpec

public DatasourceIngestionSpec getIngestionSpec()

getMaxSplitSize

public long getMaxSplitSize()

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

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object