You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2018/12/04 20:59:27 UTC
[accumulo] branch master updated: Fixes #776 - Move partitioners
out of hadoopImpl (#794)
This is an automated email from the ASF dual-hosted git repository.
kturner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/master by this push:
new 835eadb Fixes #776 - Move partitioners out of hadoopImpl (#794)
835eadb is described below
commit 835eadbf4044b7f994735fa15543190a2f0cb616
Author: Christopher McTague <cj...@apache.org>
AuthorDate: Tue Dec 4 15:59:23 2018 -0500
Fixes #776 - Move partitioners out of hadoopImpl (#794)
---
.../lib => hadoop/mapreduce}/partition/KeyRangePartitioner.java | 4 +++-
.../lib => hadoop/mapreduce}/partition/RangePartitioner.java | 4 +++-
.../lib => hadoop/mapreduce}/partition/RangePartitionerTest.java | 2 +-
3 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/partition/KeyRangePartitioner.java b/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoop/mapreduce/partition/KeyRangePartitioner.java
similarity index 96%
rename from hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/partition/KeyRangePartitioner.java
rename to hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoop/mapreduce/partition/KeyRangePartitioner.java
index af36f59..cf8b42c 100644
--- a/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/partition/KeyRangePartitioner.java
+++ b/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoop/mapreduce/partition/KeyRangePartitioner.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.accumulo.hadoopImpl.mapreduce.lib.partition;
+package org.apache.accumulo.hadoop.mapreduce.partition;
import org.apache.accumulo.core.data.Key;
import org.apache.hadoop.conf.Configurable;
@@ -25,6 +25,8 @@ import org.apache.hadoop.mapreduce.Partitioner;
/**
* Hadoop partitioner that uses ranges based on row keys, and optionally sub-bins based on hashing.
+ *
+ * @since 2.0.0
*/
public class KeyRangePartitioner extends Partitioner<Key,Writable> implements Configurable {
private RangePartitioner rp = new RangePartitioner();
diff --git a/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/partition/RangePartitioner.java b/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoop/mapreduce/partition/RangePartitioner.java
similarity index 98%
rename from hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/partition/RangePartitioner.java
rename to hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoop/mapreduce/partition/RangePartitioner.java
index ddc3708..8658340 100644
--- a/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/partition/RangePartitioner.java
+++ b/hadoop-mapreduce/src/main/java/org/apache/accumulo/hadoop/mapreduce/partition/RangePartitioner.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.accumulo.hadoopImpl.mapreduce.lib.partition;
+package org.apache.accumulo.hadoop.mapreduce.partition;
import static java.nio.charset.StandardCharsets.UTF_8;
@@ -42,6 +42,8 @@ import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
/**
* Hadoop partitioner that uses ranges, and optionally sub-bins based on hashing.
+ *
+ * @since 2.0.0
*/
public class RangePartitioner extends Partitioner<Text,Writable> implements Configurable {
private static final String PREFIX = RangePartitioner.class.getName();
diff --git a/hadoop-mapreduce/src/test/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/partition/RangePartitionerTest.java b/hadoop-mapreduce/src/test/java/org/apache/accumulo/hadoop/mapreduce/partition/RangePartitionerTest.java
similarity index 98%
rename from hadoop-mapreduce/src/test/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/partition/RangePartitionerTest.java
rename to hadoop-mapreduce/src/test/java/org/apache/accumulo/hadoop/mapreduce/partition/RangePartitionerTest.java
index 325e5ed..0579646 100644
--- a/hadoop-mapreduce/src/test/java/org/apache/accumulo/hadoopImpl/mapreduce/lib/partition/RangePartitionerTest.java
+++ b/hadoop-mapreduce/src/test/java/org/apache/accumulo/hadoop/mapreduce/partition/RangePartitionerTest.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.accumulo.hadoopImpl.mapreduce.lib.partition;
+package org.apache.accumulo.hadoop.mapreduce.partition;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;