org.apache.hadoop.hbase.spark

Class IntegrationTestSparkBulkLoad.NaturalKeyPartitioner

java.lang.Object

Partitioner

org.apache.hadoop.hbase.spark.IntegrationTestSparkBulkLoad.NaturalKeyPartitioner

Enclosing class:

IntegrationTestSparkBulkLoad

public static class IntegrationTestSparkBulkLoad.NaturalKeyPartitioner
extends Partitioner

Class to figure out what partition to send a link in the chain to. This is based upon the linkKey's ChainId.

Constructor Summary

Constructors

Constructor and Description
NaturalKeyPartitioner(SerializableWritable swConf)

Method Summary

Modifier and Type	Method and Description
int	getPartition(java.lang.Object key)
int	numPartitions()

Methods inherited from class java.lang.Object

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

Constructor Detail

NaturalKeyPartitioner

public NaturalKeyPartitioner(SerializableWritable swConf)

Method Detail

numPartitions

public int numPartitions()

getPartition

public int getPartition(java.lang.Object key)