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,