Hbase 1.1.2 and BigTable support

src/jpa-engine/core/src/main/java/com/impetus/kundera/persistence/AbstractEntityReader.java

@@ -101,7 +101,6 @@ protected EnhanceEntity findById(Object primaryKey, EntityMetadata m, Client cli
      * 
      * @param entity
      * @param relationsMap
-     * @param client
      * @param m
      * @param pd
      * @param relationStack
@@ -193,13 +192,9 @@ private void onRelation(final Object entity, final Map<String, Object> relations
      * 
      * @param entity
      *            relation owning entity.
-     * @param entityId
-     *            entity id of relation owning entity.
      * @param relationsMap
      *            contains relation name and it's value.
      * @param relationStack
-     * @param m
-     *            entity metadata.
      */
     private void onRelation(Object entity, Map<String, Object> relationsMap, final Relation relation,
             final EntityMetadata metadata, final PersistenceDelegator pd, boolean lazilyloaded,
@@ -510,7 +505,6 @@ else if (!relation.isUnary())
      * 
      * @param entity
      * @param relationsMap
-     * @param client
      * @param m
      * @param pd
      * @return

src/jpa-engine/core/src/main/java/com/impetus/kundera/persistence/EntityReader.java

@@ -39,10 +39,6 @@ public interface EntityReader
      * 
      * @param m
      *            entity meta data
-     * @param relationNames
-     *            relation names
-     * @param isParent
-     *            if entity is not holding any relation.
      * @param client
      *            client instance
      * @return list of wrapped enhance entities.
@@ -52,20 +48,9 @@ public interface EntityReader
     /**
      * Returns populated entity along with all relational value.
      * 
-     * @param e
-     *            enhance entity
-     * @param graphs
-     *            entity graph
-     * @param collectionHolder
-     *            collection holder.
-     * @param client
-     *            client
      * @param m
      *            entity meta data
      * @param relationStack 
-     * @param persistenceDelegeator
-     *            persistence delegator.
-     * @param lazily loaded. true if invoked over lazily fetched object.           
      * @return populate entity.
      * @throws Exception
      *             the exception
@@ -81,8 +66,6 @@ Object recursivelyFindEntities(Object entity, Map<String, Object> relationsMap,
      *            the primary key
      * @param m
      *            the m
-     * @param relationNames
-     *            the relation names
      * @param client
      *            the client
      * @return the enhance entity

src/kundera-hbase/kundera-hbase/pom.xml

@@ -14,16 +14,12 @@
 	<url>http://maven.apache.org</url>
 
 	<properties>
-		<hadoop.version>2.2.0</hadoop.version>
-		<hbase.version>0.96.1.1-hadoop2</hbase.version>
+		<hadoop.version>2.5.1</hadoop.version>
+		<hbase.version>1.1.2</hbase.version>
 		<thrift.version>0.9.0</thrift.version>
 	</properties>
 
-	<!-- Dependencies -->
 	<dependencies>
-
-
-
 		<dependency>
 			<groupId>org.apache.hbase</groupId>
 			<artifactId>hbase-client</artifactId>
@@ -36,6 +32,20 @@
 			</exclusions>
 		</dependency>
 		<dependency>
+            <groupId>org.apache.hbase</groupId>
+            <artifactId>hbase-hadoop-compat</artifactId>
+            <version>${hbase.version}</version>
+            <scope>test</scope>
+            <type>test-jar</type>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.hbase</groupId>
+            <artifactId>hbase-hadoop2-compat</artifactId>
+            <version>${hbase.version}</version>
+            <scope>test</scope>
+            <type>test-jar</type>
+        </dependency>
+        <dependency>
 			<groupId>org.apache.hbase</groupId>
 			<artifactId>hbase-server</artifactId>
 			<version>${hbase.version}</version>
@@ -81,8 +91,11 @@
 			<artifactId>hadoop-common</artifactId>
 			<version>${hadoop.version}</version>
 		</dependency>
-
-
+		<dependency>
+            <groupId>org.apache.hadoop</groupId>
+            <artifactId>hadoop-minicluster</artifactId>
+            <version>${hadoop.version}</version>
+        </dependency>
 	</dependencies>
 
 	<!-- Assembly build -->

src/kundera-hbase/kundera-hbase/src/main/java/com/impetus/client/hbase/AdminRequest.java

@@ -0,0 +1,16 @@
+package com.impetus.client.hbase;
+
+import java.io.IOException;
+
+import org.apache.hadoop.hbase.client.Admin;
+import org.apache.hadoop.hbase.client.Connection;
+
+public abstract class AdminRequest implements HBaseRequest<Void> {
+    public Void execute(Connection connection) throws IOException {
+        try (Admin admin = connection.getAdmin()) {
+            execute(admin);
+            return null;
+        }
+    }
+    protected abstract void execute(Admin admin) throws IOException;
+}

src/kundera-hbase/kundera-hbase/src/main/java/com/impetus/client/hbase/BatchPutRequest.java

@@ -0,0 +1,22 @@
+package com.impetus.client.hbase;
+
+import java.io.IOException;
+import java.util.List;
+
+import org.apache.hadoop.hbase.TableName;
+import org.apache.hadoop.hbase.client.Put;
+import org.apache.hadoop.hbase.client.Table;
+
+public class BatchPutRequest extends TableRequest<Void> {
+    private final List<Put> puts;
+
+    public BatchPutRequest(TableName tableName, List<Put> puts) {
+        super(tableName);
+        this.puts = puts;
+    }
+
+    protected Void execute(Table table) throws IOException {
+        table.put(puts);
+        return null;
+    }
+}