Index: src/main/java/org/apache/hadoop/hbase/rest/client/RemoteHTable.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/rest/client/RemoteHTable.java (revision 1306666) +++ src/main/java/org/apache/hadoop/hbase/rest/client/RemoteHTable.java (working copy) @@ -616,12 +616,12 @@ } @Override - public void batch(List actions, Object[] results) throws IOException { + public void batch(List actions, Object[] results) throws IOException { throw new IOException("batch not supported"); } @Override - public Object[] batch(List actions) throws IOException { + public Object[] batch(List actions) throws IOException { throw new IOException("batch not supported"); } Index: src/main/java/org/apache/hadoop/hbase/client/Mutation.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/client/Mutation.java (revision 1306666) +++ src/main/java/org/apache/hadoop/hbase/client/Mutation.java (working copy) @@ -35,7 +35,7 @@ @InterfaceAudience.Public @InterfaceStability.Evolving -public abstract class Mutation extends OperationWithAttributes { +public abstract class Mutation extends OperationWithAttributes implements Row { // Attribute used in Mutations to indicate the originating cluster. private static final String CLUSTER_ID_ATTR = "_c.id_"; @@ -152,6 +152,7 @@ * Method for retrieving the delete's row * @return row */ + @Override public byte [] getRow() { return this.row; } Index: src/main/java/org/apache/hadoop/hbase/client/Delete.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/client/Delete.java (revision 1306666) +++ src/main/java/org/apache/hadoop/hbase/client/Delete.java (working copy) @@ -69,7 +69,7 @@ @InterfaceAudience.Public @InterfaceStability.Stable public class Delete extends Mutation - implements Writable, Row, Comparable { + implements Writable, Comparable { private static final byte DELETE_VERSION = (byte)3; /** Constructor for Writable. DO NOT USE */ Index: src/main/java/org/apache/hadoop/hbase/client/Append.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/client/Append.java (revision 1306666) +++ src/main/java/org/apache/hadoop/hbase/client/Append.java (working copy) @@ -45,8 +45,7 @@ */ @InterfaceAudience.Public @InterfaceStability.Stable -public class Append extends Mutation implements Row { - // TODO: refactor to derive from Put? +public class Append extends Mutation { private static final String RETURN_RESULTS = "_rr_"; private static final byte APPEND_VERSION = (byte)1; Index: src/main/java/org/apache/hadoop/hbase/client/Put.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/client/Put.java (revision 1306666) +++ src/main/java/org/apache/hadoop/hbase/client/Put.java (working copy) @@ -48,7 +48,7 @@ @InterfaceAudience.Public @InterfaceStability.Stable public class Put extends Mutation - implements HeapSize, Writable, Row, Comparable { + implements HeapSize, Writable, Comparable { private static final byte PUT_VERSION = (byte)2; private static final long OVERHEAD = ClassSize.align( Index: src/main/java/org/apache/hadoop/hbase/client/HTableInterface.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/client/HTableInterface.java (revision 1306666) +++ src/main/java/org/apache/hadoop/hbase/client/HTableInterface.java (working copy) @@ -92,7 +92,7 @@ * @throws IOException * @since 0.90.0 */ - void batch(final List actions, final Object[] results) throws IOException, InterruptedException; + void batch(final List actions, final Object[] results) throws IOException, InterruptedException; /** * Same as {@link #batch(List, Object[])}, but returns an array of @@ -104,7 +104,7 @@ * @throws IOException * @since 0.90.0 */ - Object[] batch(final List actions) throws IOException, InterruptedException; + Object[] batch(final List actions) throws IOException, InterruptedException; /** * Extracts certain cells from a given row. Index: src/main/java/org/apache/hadoop/hbase/client/HTablePool.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/client/HTablePool.java (revision 1306666) +++ src/main/java/org/apache/hadoop/hbase/client/HTablePool.java (working copy) @@ -354,13 +354,13 @@ } @Override - public void batch(List actions, Object[] results) throws IOException, + public void batch(List actions, Object[] results) throws IOException, InterruptedException { table.batch(actions, results); } @Override - public Object[] batch(List actions) throws IOException, + public Object[] batch(List actions) throws IOException, InterruptedException { return table.batch(actions); } Index: src/main/java/org/apache/hadoop/hbase/client/HTable.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/client/HTable.java (revision 1306666) +++ src/main/java/org/apache/hadoop/hbase/client/HTable.java (working copy) @@ -700,7 +700,7 @@ * {@inheritDoc} */ @Override - public synchronized void batch(final List actions, final Object[] results) + public synchronized void batch(final List actions, final Object[] results) throws InterruptedException, IOException { connection.processBatch(actions, tableName, pool, results); } @@ -709,7 +709,7 @@ * {@inheritDoc} */ @Override - public synchronized Object[] batch(final List actions) throws InterruptedException, IOException { + public synchronized Object[] batch(final List actions) throws InterruptedException, IOException { Object[] results = new Object[actions.size()]; connection.processBatch(actions, tableName, pool, results); return results; Index: src/main/java/org/apache/hadoop/hbase/coprocessor/CoprocessorHost.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/coprocessor/CoprocessorHost.java (revision 1306666) +++ src/main/java/org/apache/hadoop/hbase/coprocessor/CoprocessorHost.java (working copy) @@ -470,13 +470,13 @@ } @Override - public void batch(List actions, Object[] results) + public void batch(List actions, Object[] results) throws IOException, InterruptedException { table.batch(actions, results); } @Override - public Object[] batch(List actions) + public Object[] batch(List actions) throws IOException, InterruptedException { return table.batch(actions); }