Package uk.gov.gchq.gaffer.sparkaccumulo.operation.utils

Class AccumuloKeyRangePartitioner

java.lang.Object

org.apache.spark.Partitioner

uk.gov.gchq.gaffer.sparkaccumulo.operation.utils.AccumuloKeyRangePartitioner

All Implemented Interfaces:

Serializable, scala.Serializable

public class AccumuloKeyRangePartitioner
extends org.apache.spark.Partitioner

This is a spark compatible implementation of the accumulo RangePartitioner ( @link org.apache.accumulo.core.client.mapreduce.lib.partition.RangePartitioner }

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
AccumuloKeyRangePartitioner(AccumuloStore store)

Method Summary

Modifier and Type	Method	Description
int	getPartition(Object obj)
static String[]	getSplits(AccumuloStore store)
int	numPartitions()
void	setNumSubBins(int numSubBins)

Methods inherited from class org.apache.spark.Partitioner

defaultPartitioner

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumuloKeyRangePartitioner

public AccumuloKeyRangePartitioner(AccumuloStore store)
                            throws OperationException

Throws:

OperationException

Method Detail

setNumSubBins

public void setNumSubBins(int numSubBins)

numPartitions

public int numPartitions()

Specified by:

numPartitions in class org.apache.spark.Partitioner

getPartition

public int getPartition(Object obj)

Specified by:

getPartition in class org.apache.spark.Partitioner

getSplits

public static String[] getSplits(AccumuloStore store)
                          throws OperationException

Throws:

OperationException