Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-11518 doc update for how to create non-shared HConnection (Qiang Tian)

This commit is contained in:
stack 2014-07-17 11:39:00 -07:00
parent d6c5e5f374
commit f8153a1456
1 changed files with 17 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
hbase-client/src/main/java/org/apache/hadoop/hbase/client/HConnectionManager.java
View File

@ -44,24 +44,18 @@ import org.apache.hadoop.hbase.security.User;
* connection.close(); * connection.close();
* } * }
* }</pre> * }</pre>
* <p>The following logic and API will be removed in the future:
* <p>This class has a static Map of {@link HConnection} instances keyed by * <p>This class has a static Map of {@link HConnection} instances keyed by
* {@link Configuration}; all invocations of {@link #getConnection(Configuration)} * {@link HConnectionKey}; A {@link HConnectionKey} is identified by a set of
* that pass the same {@link Configuration} instance will be returned the same * {@link Configuration} properties. Invocations of {@link #getConnection(Configuration)}
* {@link HConnection} instance (Adding properties to a Configuration * that pass the same {@link Configuration} instance will return the same
* instance does not change its object identity; for more on how this is done see * {@link HConnection} instance ONLY WHEN the set of properties are the same
* {@link HConnectionKey}). Sharing {@link HConnection} * (i.e. if you change properties in your {@link Configuration} instance, such as RPC timeout,
* instances is usually what you want; all clients of the {@link HConnection} * the codec used, HBase will create a new {@link HConnection} instance. For more details on
* instances share the HConnections' cache of Region locations rather than each * how this is done see {@link HConnectionKey}).
* having to discover for itself the location of meta, etc. It makes * <p>Sharing {@link HConnection} instances is usually what you want; all clients
* sense for the likes of the pool of HTables class {@link HTablePool}, for * of the {@link HConnection} instances share the HConnections' cache of Region
* instance (If concerned that a single {@link HConnection} is insufficient * locations rather than each having to discover for itself the location of meta, etc.
* for sharing amongst clients in say an heavily-multithreaded environment, * But sharing connections makes clean up of {@link HConnection} instances a little awkward.
* in practise its not proven to be an issue. Besides, {@link HConnection} is
* implemented atop Hadoop RPC and as of this writing, Hadoop RPC does a
* connection per cluster-member, exclusively).
*
* <p>But sharing connections makes clean up of {@link HConnection} instances a little awkward.
* Currently, clients cleanup by calling {@link #deleteConnection(Configuration)}. This will * Currently, clients cleanup by calling {@link #deleteConnection(Configuration)}. This will
* shutdown the zookeeper connection the HConnection was using and clean up all * shutdown the zookeeper connection the HConnection was using and clean up all
* HConnection resources as well as stopping proxies to servers out on the * HConnection resources as well as stopping proxies to servers out on the
@ -71,15 +65,15 @@ import org.apache.hadoop.hbase.security.User;
* subsequently used by another will cause breakage so be careful running * subsequently used by another will cause breakage so be careful running
* cleanup. * cleanup.
* <p>To create a {@link HConnection} that is not shared by others, you can * <p>To create a {@link HConnection} that is not shared by others, you can
* create a new {@link Configuration} instance, pass this new instance to * set property "hbase.client.instance.id" to a unique value for your {@link Configuration}
* {@link #getConnection(Configuration)}, and then when done, close it up by * instance, like the following:
* doing something like the following:
* <pre> * <pre>
* {@code * {@code
* Configuration newConfig = new Configuration(originalConf); * conf.set("hbase.client.instance.id", "12345");
* HConnection connection = HConnectionManager.getConnection(newConfig); * HConnection connection = HConnectionManager.getConnection(conf);
* // Use the connection to your hearts' delight and then when done... * // Use the connection to your hearts' delight and then when done...
* HConnectionManager.deleteConnection(newConfig, true); * conf.set("hbase.client.instance.id", "12345");
* HConnectionManager.deleteConnection(conf, true);
* } * }
* </pre> * </pre>
* <p>Cleanup used to be done inside in a shutdown hook. On startup we'd * <p>Cleanup used to be done inside in a shutdown hook. On startup we'd