Class RangePartitioner
java.lang.Object
org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.Text,org.apache.hadoop.io.Writable>
org.apache.accumulo.core.client.mapreduce.lib.partition.RangePartitioner
- All Implemented Interfaces:
org.apache.hadoop.conf.Configurable
@Deprecated(since="2.0.0")
public class RangePartitioner
extends org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.Text,org.apache.hadoop.io.Writable>
implements org.apache.hadoop.conf.Configurable
Deprecated.
since 2.0.0; Use org.apache.accumulo.hadoop.mapreduce.partition instead from the
accumulo-hadoop-mapreduce.jar
Hadoop partitioner that uses ranges, and optionally sub-bins based on hashing.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.hadoop.conf.Configuration
getConf()
Deprecated.int
getPartition
(org.apache.hadoop.io.Text key, org.apache.hadoop.io.Writable value, int numPartitions) Deprecated.void
setConf
(org.apache.hadoop.conf.Configuration conf) Deprecated.static void
setNumSubBins
(org.apache.hadoop.mapreduce.Job job, int num) Deprecated.Sets the number of random sub-bins per rangestatic void
setSplitFile
(org.apache.hadoop.mapreduce.Job job, String file) Deprecated.Sets the hdfs file name to use, containing a newline separated list of Base64 encoded split points that represent ranges for partitioning
-
Constructor Details
-
RangePartitioner
public RangePartitioner()Deprecated.
-
-
Method Details
-
getPartition
public int getPartition(org.apache.hadoop.io.Text key, org.apache.hadoop.io.Writable value, int numPartitions) Deprecated.- Specified by:
getPartition
in classorg.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.Text,
org.apache.hadoop.io.Writable>
-
getConf
public org.apache.hadoop.conf.Configuration getConf()Deprecated.- Specified by:
getConf
in interfaceorg.apache.hadoop.conf.Configurable
-
setConf
public void setConf(org.apache.hadoop.conf.Configuration conf) Deprecated.- Specified by:
setConf
in interfaceorg.apache.hadoop.conf.Configurable
-
setSplitFile
Deprecated.Sets the hdfs file name to use, containing a newline separated list of Base64 encoded split points that represent ranges for partitioning -
setNumSubBins
public static void setNumSubBins(org.apache.hadoop.mapreduce.Job job, int num) Deprecated.Sets the number of random sub-bins per range
-