io.druid.indexer

Class IndexGeneratorJob

java.lang.Object

io.druid.indexer.IndexGeneratorJob

All Implemented Interfaces:

Jobby

public class IndexGeneratorJob
extends Object
implements Jobby

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IndexGeneratorJob.IndexGeneratorCombiner
static class	IndexGeneratorJob.IndexGeneratorMapper
static class	IndexGeneratorJob.IndexGeneratorOutputFormat
static class	IndexGeneratorJob.IndexGeneratorPartitioner
static class	IndexGeneratorJob.IndexGeneratorReducer
static class	IndexGeneratorJob.IndexGeneratorStats

Constructor Summary

Constructors

Constructor and Description
IndexGeneratorJob(HadoopDruidIndexerConfig config)

Method Summary

Modifier and Type	Method and Description
IndexGeneratorJob.IndexGeneratorStats	getJobStats()
static List<DataSegment>	getPublishedSegments(HadoopDruidIndexerConfig config)
boolean	run()
protected void	setReducerClass(org.apache.hadoop.mapreduce.Job job)

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexGeneratorJob

public IndexGeneratorJob(HadoopDruidIndexerConfig config)

Method Detail

getPublishedSegments

public static List<DataSegment> getPublishedSegments(HadoopDruidIndexerConfig config)

setReducerClass

protected void setReducerClass(org.apache.hadoop.mapreduce.Job job)

getJobStats

public IndexGeneratorJob.IndexGeneratorStats getJobStats()

run

public boolean run()

Specified by:

run in interface Jobby