io.druid.indexer

Class DeterminePartitionsJob.DeterminePartitionsDimSelectionMapperHelper

java.lang.Object

io.druid.indexer.DeterminePartitionsJob.DeterminePartitionsDimSelectionMapperHelper

Enclosing class:

DeterminePartitionsJob

public static class DeterminePartitionsJob.DeterminePartitionsDimSelectionMapperHelper
extends Object

Since we have two slightly different DimSelectionMappers, this class encapsulates the shared logic for emitting dimension value counts.

Constructor Summary

Constructors

Constructor and Description
DeterminePartitionsJob.DeterminePartitionsDimSelectionMapperHelper(HadoopDruidIndexerConfig config, String partitionDimension)

Method Summary

Methods

Modifier and Type	Method and Description
void	emitDimValueCounts(org.apache.hadoop.mapreduce.TaskInputOutputContext<? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text> context, org.joda.time.DateTime timestamp, Map<String,Iterable<String>> dims)

Methods inherited from class java.lang.Object

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

Constructor Detail

DeterminePartitionsJob.DeterminePartitionsDimSelectionMapperHelper

public DeterminePartitionsJob.DeterminePartitionsDimSelectionMapperHelper(HadoopDruidIndexerConfig config,
                                                                  String partitionDimension)

Method Detail

emitDimValueCounts

public void emitDimValueCounts(org.apache.hadoop.mapreduce.TaskInputOutputContext<? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text> context,
                      org.joda.time.DateTime timestamp,
                      Map<String,Iterable<String>> dims)
                        throws IOException,
                               InterruptedException

Throws:

IOException

InterruptedException