io.druid.indexer

Class DeterminePartitionsJob.DeterminePartitionsDimSelectionPartitioner

java.lang.Object

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

io.druid.indexer.DeterminePartitionsJob.DeterminePartitionsDimSelectionPartitioner

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

Enclosing class:

DeterminePartitionsJob

public static class DeterminePartitionsJob.DeterminePartitionsDimSelectionPartitioner
extends org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text>
implements org.apache.hadoop.conf.Configurable

Constructor Summary

Constructors

Constructor and Description
DeterminePartitionsJob.DeterminePartitionsDimSelectionPartitioner()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.conf.Configuration	getConf()
int	getPartition(org.apache.hadoop.io.BytesWritable bytesWritable, org.apache.hadoop.io.Text text, int numPartitions)
void	setConf(org.apache.hadoop.conf.Configuration config)

Methods inherited from class java.lang.Object

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

Constructor Detail

DeterminePartitionsJob.DeterminePartitionsDimSelectionPartitioner

public DeterminePartitionsJob.DeterminePartitionsDimSelectionPartitioner()

Method Detail

getPartition

public int getPartition(org.apache.hadoop.io.BytesWritable bytesWritable,
               org.apache.hadoop.io.Text text,
               int numPartitions)

Specified by:

getPartition in class org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text>

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf

public void setConf(org.apache.hadoop.conf.Configuration config)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable