io.druid.indexer

Class DeterminePartitionsJob.DeterminePartitionsDimSelectionCombiner

java.lang.Object

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

io.druid.indexer.DeterminePartitionsJob.DeterminePartitionsDimSelectionCombiner

Enclosing class:

DeterminePartitionsJob

public static class DeterminePartitionsJob.DeterminePartitionsDimSelectionCombiner
extends org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text>

Nested Class Summary

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

org.apache.hadoop.mapreduce.Reducer.Context

Constructor Summary

Constructors

Constructor and Description
DeterminePartitionsJob.DeterminePartitionsDimSelectionCombiner()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	innerReduce(org.apache.hadoop.mapreduce.Reducer.Context context, SortableBytes keyBytes, Iterable<io.druid.indexer.DeterminePartitionsJob.DimValueCount> combinedIterable)

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

DeterminePartitionsJob.DeterminePartitionsDimSelectionCombiner

public DeterminePartitionsJob.DeterminePartitionsDimSelectionCombiner()

Method Detail

innerReduce

protected void innerReduce(org.apache.hadoop.mapreduce.Reducer.Context context,
               SortableBytes keyBytes,
               Iterable<io.druid.indexer.DeterminePartitionsJob.DimValueCount> combinedIterable)
                    throws IOException,
                           InterruptedException

Throws:

IOException

InterruptedException