You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by li...@apache.org on 2014/03/12 22:17:20 UTC

svn commit: r1576909 [3/18] - in /hbase/branches/0.89-fb/src: ./ examples/thrift/ main/java/org/apache/hadoop/hbase/ main/java/org/apache/hadoop/hbase/avro/ main/java/org/apache/hadoop/hbase/avro/generated/ main/java/org/apache/hadoop/hbase/client/ mai...

Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/client/HConnection.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/client/HConnection.java?rev=1576909&r1=1576908&r2=1576909&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/client/HConnection.java (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/client/HConnection.java Wed Mar 12 21:17:13 2014
@@ -19,7 +19,12 @@
  */
 package org.apache.hadoop.hbase.client;
 
-import org.apache.hadoop.hbase.*;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.HRegionInfo;
+import org.apache.hadoop.hbase.HRegionLocation;
+import org.apache.hadoop.hbase.HServerAddress;
+import org.apache.hadoop.hbase.HTableDescriptor;
+import org.apache.hadoop.hbase.MasterNotRunningException;
 import org.apache.hadoop.hbase.ipc.HBaseRPCOptions;
 import org.apache.hadoop.hbase.ipc.HMasterInterface;
 import org.apache.hadoop.hbase.ipc.HRegionInterface;
@@ -145,8 +150,8 @@ public interface HConnection extends Clo
    * @return proxy for HRegionServer
    * @throws IOException if a remote or network exception occurs
    */
-  public HRegionInterface getHRegionConnection(HServerAddress regionServer, HBaseRPCOptions options)
-  throws IOException;
+  public HRegionInterface getHRegionConnection(HServerAddress regionServer,
+      HBaseRPCOptions options) throws IOException;
 
   /**
    * Establishes a connection to the region server at the specified address.
@@ -216,7 +221,10 @@ public interface HConnection extends Clo
    * @throws RuntimeException other unspecified error
    */
   public <T> T getRegionServerWithoutRetries(ServerCallable<T> callable)
-  throws IOException, RuntimeException;
+      throws IOException, RuntimeException;
+
+  public <T> T getRegionServerWithoutRetries(ServerCallable<T> callable, boolean instantiateRegionLocation)
+      throws IOException, RuntimeException;
 
   /**
    * Process a batch of Gets. Does the retries.
@@ -262,8 +270,7 @@ public interface HConnection extends Clo
   throws IOException;
 
   public int processBatchOfRowMutations(final List<RowMutations> list,
-    final byte[] tableName, HBaseRPCOptions options)
-  throws IOException;
+      final byte[] tableName, final HBaseRPCOptions options) throws IOException;
 
   /**
    * Process a mixed batch of Get actions. All actions for a
@@ -294,8 +301,8 @@ public interface HConnection extends Clo
    * @param pool thread pool for parallel execution
    * @param failures populated with failed operation if there are errors.
    * @param options HBaseRPCOptions to be used
-   * @throws IOException,InterruptedException if there are problems talking to META.
-   *  Or, operations were not successfully completed.
+   * @throws IOException,InterruptedException if there are problems talking to
+   * META. Or, operations were not successfully completed.
    */
   public void processBatchedMutations(List<Mutation> actions, final byte[] tableName,
       ExecutorService pool, List<Mutation> failures, HBaseRPCOptions options)
@@ -388,6 +395,7 @@ public interface HConnection extends Clo
    */
   public void resetOperationContext();
 
+  public Configuration getConf();
   /**
    * Returns if the most recent flush on this region happens in the window
    * [current server time - acceptableWindowForLastFlush,