io.druid.indexer

Class SortableBytes.SortableBytesPartitioner

java.lang.Object

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

io.druid.indexer.SortableBytes.SortableBytesPartitioner

Enclosing class:

SortableBytes

public static class SortableBytes.SortableBytesPartitioner
extends org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.BytesWritable,Object>

Constructor Summary

Constructors

Constructor and Description
SortableBytesPartitioner()

Method Summary

Modifier and Type	Method and Description
int	getPartition(org.apache.hadoop.io.BytesWritable bytesWritable, Object o, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

SortableBytesPartitioner

public SortableBytesPartitioner()

Method Detail

getPartition

public int getPartition(org.apache.hadoop.io.BytesWritable bytesWritable,
                        Object o,
                        int numPartitions)

Specified by:

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