svn commit: r1635556 - /pig/branches/branch-0.14/src/org/apache/pig/backend/hadoop/hbase/TableSplitComparable.java

[da...@apache.org]

Author: daijy
Date: Thu Oct 30 17:27:19 2014
New Revision: 1635556

URL: http://svn.apache.org/r1635556
Log:
PIG-2495: Using merge JOIN from a HBaseStorage produces an error

Added:
    pig/branches/branch-0.14/src/org/apache/pig/backend/hadoop/hbase/TableSplitComparable.java

Added: pig/branches/branch-0.14/src/org/apache/pig/backend/hadoop/hbase/TableSplitComparable.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.14/src/org/apache/pig/backend/hadoop/hbase/TableSplitComparable.java?rev=1635556&view=auto
==============================================================================
--- pig/branches/branch-0.14/src/org/apache/pig/backend/hadoop/hbase/TableSplitComparable.java (added)
+++ pig/branches/branch-0.14/src/org/apache/pig/backend/hadoop/hbase/TableSplitComparable.java Thu Oct 30 17:27:19 2014
@@ -0,0 +1,88 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with this
+ * work for additional information regarding copyright ownership. The ASF
+ * licenses this file to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package org.apache.pig.backend.hadoop.hbase;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.hadoop.io.WritableComparable;
+import org.apache.hadoop.hbase.mapreduce.TableSplit;
+
+public class TableSplitComparable implements WritableComparable<TableSplit> {
+
+    TableSplit tsplit;
+
+    // need a default constructor to be able to de-serialize using just the Writable interface
+    public TableSplitComparable() {
+        tsplit = new TableSplit();
+    }
+
+    public TableSplitComparable(TableSplit tsplit) {
+        this.tsplit = tsplit;
+    }
+
+    @Override
+    public void readFields(DataInput in) throws IOException {
+        tsplit.readFields(in);
+    }
+
+    @Override
+    public void write(DataOutput out) throws IOException {
+        tsplit.write(out);
+    }
+
+    @Override
+    public int compareTo(TableSplit split) {
+        return tsplit.compareTo((TableSplit) split);
+    }
+ 
+    @Override
+    public String toString() {
+        return "TableSplitComparable : " + tsplit.toString();
+    }
+ 
+    /* (non-Javadoc)
+     * @see java.lang.Object#hashCode()
+     */
+    @Override
+    public int hashCode() {
+        return ((tsplit == null) ? 0 : tsplit.hashCode());
+    }
+ 
+    /* (non-Javadoc)
+     * @see java.lang.Object#equals(java.lang.Object)
+     */
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj)
+            return true;
+        if (obj == null)
+            return false;
+        if (getClass() != obj.getClass())
+            return false;
+        TableSplitComparable other = (TableSplitComparable) obj;
+        if (tsplit == null) {
+            if (other.tsplit != null)
+                return false;
+        } else if (!tsplit.equals(other.tsplit)) {
+            return false;
+        }
+        return true;
+    }
+
+}