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
SortableBytes.SortableBytesPartitioner()

Method Summary

Methods

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

SortableBytes.SortableBytesPartitioner

public SortableBytes.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>