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
LegacyIndexGeneratorReducer()

Method Summary

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

LegacyIndexGeneratorReducer

public 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