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
DeterminePartitionsDimSelectionMapperHelper(HadoopDruidIndexerConfig config, String partitionDimension)

Method Summary

Modifier and Type	Method and Description
void	emitDimValueCounts(org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,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

DeterminePartitionsDimSelectionMapperHelper

public DeterminePartitionsDimSelectionMapperHelper(HadoopDruidIndexerConfig config,
                                                   String partitionDimension)

Method Detail

emitDimValueCounts

public void emitDimValueCounts(org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,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