io.druid.indexer

Class IndexGeneratorJob.IndexGeneratorPartitioner

java.lang.Object

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

io.druid.indexer.IndexGeneratorJob.IndexGeneratorPartitioner

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

Enclosing class:

IndexGeneratorJob

public static class IndexGeneratorJob.IndexGeneratorPartitioner
extends org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Writable>
implements org.apache.hadoop.conf.Configurable

Constructor Summary

Constructors

Constructor and Description
IndexGeneratorJob.IndexGeneratorPartitioner()

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.Writable value, 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

IndexGeneratorJob.IndexGeneratorPartitioner

public IndexGeneratorJob.IndexGeneratorPartitioner()

Method Detail

getPartition

public int getPartition(org.apache.hadoop.io.BytesWritable bytesWritable,
               org.apache.hadoop.io.Writable value,
               int numPartitions)

Specified by:

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

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