io.druid.indexer

Class LegacyIndexGeneratorJob.LegacyIndexGeneratorReducer

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text>

io.druid.indexer.IndexGeneratorJob.IndexGeneratorReducer

io.druid.indexer.LegacyIndexGeneratorJob.LegacyIndexGeneratorReducer

Enclosing class:

LegacyIndexGeneratorJob

public static class LegacyIndexGeneratorJob.LegacyIndexGeneratorReducer
extends IndexGeneratorJob.IndexGeneratorReducer

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Reducer

org.apache.hadoop.mapreduce.Reducer.Context

Field Summary

Fields inherited from class io.druid.indexer.IndexGeneratorJob.IndexGeneratorReducer

config

Constructor Summary

Constructors

Constructor and Description
LegacyIndexGeneratorJob.LegacyIndexGeneratorReducer()

Method Summary

Methods

Modifier and Type	Method and Description
protected ProgressIndicator	makeProgressIndicator(org.apache.hadoop.mapreduce.Reducer.Context context)
protected File	mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] aggs, File file, ProgressIndicator progressIndicator)
protected File	persist(IncrementalIndex index, org.joda.time.Interval interval, File file, ProgressIndicator progressIndicator)

Methods inherited from class io.druid.indexer.IndexGeneratorJob.IndexGeneratorReducer

reduce, setup

Methods inherited from class org.apache.hadoop.mapreduce.Reducer

cleanup, run

Methods inherited from class java.lang.Object

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

Constructor Detail

LegacyIndexGeneratorJob.LegacyIndexGeneratorReducer

public LegacyIndexGeneratorJob.LegacyIndexGeneratorReducer()

Method Detail

makeProgressIndicator

protected ProgressIndicator makeProgressIndicator(org.apache.hadoop.mapreduce.Reducer.Context context)

Overrides:

makeProgressIndicator in class IndexGeneratorJob.IndexGeneratorReducer

persist

protected File persist(IncrementalIndex index,
           org.joda.time.Interval interval,
           File file,
           ProgressIndicator progressIndicator)
                throws IOException

Overrides:

persist in class IndexGeneratorJob.IndexGeneratorReducer

Throws:

IOException

mergeQueryableIndex

protected File mergeQueryableIndex(List<QueryableIndex> indexes,
                       AggregatorFactory[] aggs,
                       File file,
                       ProgressIndicator progressIndicator)
                            throws IOException

Overrides:

mergeQueryableIndex in class IndexGeneratorJob.IndexGeneratorReducer

Throws:

IOException