accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ktur...@apache.org
Subject [accumulo] branch master updated: Fixes #776 - Move partitioners out of hadoopImpl (#794)
Date Tue, 04 Dec 2018 20:59:27 GMT
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 <cjmctague@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;


Mime
View raw message