http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cba900e4/apidocs/overview-tree.html ---------------------------------------------------------------------- diff --git a/apidocs/overview-tree.html b/apidocs/overview-tree.html index e8708c2..3a6add8 100644 --- a/apidocs/overview-tree.html +++ b/apidocs/overview-tree.html @@ -880,33 +880,33 @@ <li type="circle">java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true"; title="class or interface in java.lang"><span class="typeNameLink">Enum</span></a><E> (implements java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true"; title="class or interface in java.lang">Comparable</a><T>, java.io.<a href="http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a>) <ul> <li type="circle">org.apache.hadoop.hbase.util.<a href="org/apache/hadoop/hbase/util/Order.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">Order</span></a></li> -<li type="circle">org.apache.hadoop.hbase.<a href="org/apache/hadoop/hbase/KeepDeletedCells.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">KeepDeletedCells</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="org/apache/hadoop/hbase/MemoryCompactionPolicy.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">MemoryCompactionPolicy</span></a></li> +<li type="circle">org.apache.hadoop.hbase.<a href="org/apache/hadoop/hbase/KeepDeletedCells.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">KeepDeletedCells</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="org/apache/hadoop/hbase/CompareOperator.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">CompareOperator</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="org/apache/hadoop/hbase/ProcedureState.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">ProcedureState</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="org/apache/hadoop/hbase/CellBuilderType.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">CellBuilderType</span></a></li> -<li type="circle">org.apache.hadoop.hbase.filter.<a href="org/apache/hadoop/hbase/filter/BitComparator.BitwiseOp.html" title="enum in org.apache.hadoop.hbase.filter"><span class="typeNameLink">BitComparator.BitwiseOp</span></a></li> <li type="circle">org.apache.hadoop.hbase.filter.<a href="org/apache/hadoop/hbase/filter/FilterList.Operator.html" title="enum in org.apache.hadoop.hbase.filter"><span class="typeNameLink">FilterList.Operator</span></a></li> <li type="circle">org.apache.hadoop.hbase.filter.<a href="org/apache/hadoop/hbase/filter/CompareFilter.CompareOp.html" title="enum in org.apache.hadoop.hbase.filter"><span class="typeNameLink">CompareFilter.CompareOp</span></a></li> -<li type="circle">org.apache.hadoop.hbase.filter.<a href="org/apache/hadoop/hbase/filter/Filter.ReturnCode.html" title="enum in org.apache.hadoop.hbase.filter"><span class="typeNameLink">Filter.ReturnCode</span></a></li> +<li type="circle">org.apache.hadoop.hbase.filter.<a href="org/apache/hadoop/hbase/filter/BitComparator.BitwiseOp.html" title="enum in org.apache.hadoop.hbase.filter"><span class="typeNameLink">BitComparator.BitwiseOp</span></a></li> <li type="circle">org.apache.hadoop.hbase.filter.<a href="org/apache/hadoop/hbase/filter/RegexStringComparator.EngineType.html" title="enum in org.apache.hadoop.hbase.filter"><span class="typeNameLink">RegexStringComparator.EngineType</span></a></li> +<li type="circle">org.apache.hadoop.hbase.filter.<a href="org/apache/hadoop/hbase/filter/Filter.ReturnCode.html" title="enum in org.apache.hadoop.hbase.filter"><span class="typeNameLink">Filter.ReturnCode</span></a></li> <li type="circle">org.apache.hadoop.hbase.io.encoding.<a href="org/apache/hadoop/hbase/io/encoding/DataBlockEncoding.html" title="enum in org.apache.hadoop.hbase.io.encoding"><span class="typeNameLink">DataBlockEncoding</span></a></li> <li type="circle">org.apache.hadoop.hbase.regionserver.<a href="org/apache/hadoop/hbase/regionserver/BloomType.html" title="enum in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">BloomType</span></a></li> +<li type="circle">org.apache.hadoop.hbase.quotas.<a href="org/apache/hadoop/hbase/quotas/SpaceViolationPolicy.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="typeNameLink">SpaceViolationPolicy</span></a></li> <li type="circle">org.apache.hadoop.hbase.quotas.<a href="org/apache/hadoop/hbase/quotas/ThrottlingException.Type.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="typeNameLink">ThrottlingException.Type</span></a></li> <li type="circle">org.apache.hadoop.hbase.quotas.<a href="org/apache/hadoop/hbase/quotas/QuotaScope.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="typeNameLink">QuotaScope</span></a></li> -<li type="circle">org.apache.hadoop.hbase.quotas.<a href="org/apache/hadoop/hbase/quotas/ThrottleType.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="typeNameLink">ThrottleType</span></a></li> <li type="circle">org.apache.hadoop.hbase.quotas.<a href="org/apache/hadoop/hbase/quotas/QuotaType.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="typeNameLink">QuotaType</span></a></li> -<li type="circle">org.apache.hadoop.hbase.quotas.<a href="org/apache/hadoop/hbase/quotas/SpaceViolationPolicy.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="typeNameLink">SpaceViolationPolicy</span></a></li> -<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/Durability.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">Durability</span></a></li> +<li type="circle">org.apache.hadoop.hbase.quotas.<a href="org/apache/hadoop/hbase/quotas/ThrottleType.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="typeNameLink">ThrottleType</span></a></li> <li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/SnapshotType.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">SnapshotType</span></a></li> -<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/MasterSwitchType.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">MasterSwitchType</span></a></li> -<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/CompactType.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">CompactType</span></a></li> +<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/Durability.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">Durability</span></a></li> <li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/MobCompactPartitionPolicy.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">MobCompactPartitionPolicy</span></a></li> -<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/CompactionState.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">CompactionState</span></a></li> -<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/Scan.ReadType.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">Scan.ReadType</span></a></li> -<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/RequestController.ReturnCode.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">RequestController.ReturnCode</span></a></li> <li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/IsolationLevel.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">IsolationLevel</span></a></li> +<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/RequestController.ReturnCode.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">RequestController.ReturnCode</span></a></li> +<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/Scan.ReadType.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">Scan.ReadType</span></a></li> +<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/CompactionState.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">CompactionState</span></a></li> +<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/MasterSwitchType.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">MasterSwitchType</span></a></li> <li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/Consistency.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">Consistency</span></a></li> +<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/CompactType.html" title="enum in org.apache.hadoop.hbase.client"><span class="typeNameLink">CompactType</span></a></li> <li type="circle">org.apache.hadoop.hbase.client.security.<a href="org/apache/hadoop/hbase/client/security/SecurityCapability.html" title="enum in org.apache.hadoop.hbase.client.security"><span class="typeNameLink">SecurityCapability</span></a></li> </ul> </li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cba900e4/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html ---------------------------------------------------------------------- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html b/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html index 7e14b42..11bfb15 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html @@ -1208,126 +1208,131 @@ <span class="sourceLineNo">1200</span> public static final String REPLICATION_SOURCE_MAXTHREADS_KEY =<a name="line.1200"></a> <span class="sourceLineNo">1201</span> "hbase.replication.source.maxthreads";<a name="line.1201"></a> <span class="sourceLineNo">1202</span><a name="line.1202"></a> -<span class="sourceLineNo">1203</span> public static final int REPLICATION_SOURCE_MAXTHREADS_DEFAULT = 10;<a name="line.1203"></a> -<span class="sourceLineNo">1204</span><a name="line.1204"></a> -<span class="sourceLineNo">1205</span> /** Configuration key for SplitLog manager timeout */<a name="line.1205"></a> -<span class="sourceLineNo">1206</span> public static final String HBASE_SPLITLOG_MANAGER_TIMEOUT = "hbase.splitlog.manager.timeout";<a name="line.1206"></a> -<span class="sourceLineNo">1207</span><a name="line.1207"></a> -<span class="sourceLineNo">1208</span> /**<a name="line.1208"></a> -<span class="sourceLineNo">1209</span> * Configuration keys for Bucket cache<a name="line.1209"></a> -<span class="sourceLineNo">1210</span> */<a name="line.1210"></a> -<span class="sourceLineNo">1211</span> // TODO moving these bucket cache implementation specific configs to this level is violation of<a name="line.1211"></a> -<span class="sourceLineNo">1212</span> // encapsulation. But as these has to be referred from hbase-common and bucket cache<a name="line.1212"></a> -<span class="sourceLineNo">1213</span> // sits in hbase-server, there were no other go! Can we move the cache implementation to<a name="line.1213"></a> -<span class="sourceLineNo">1214</span> // hbase-common?<a name="line.1214"></a> -<span class="sourceLineNo">1215</span><a name="line.1215"></a> -<span class="sourceLineNo">1216</span> /**<a name="line.1216"></a> -<span class="sourceLineNo">1217</span> * Current ioengine options in include: heap, offheap and file:PATH (where PATH is the path<a name="line.1217"></a> -<span class="sourceLineNo">1218</span> * to the file that will host the file-based cache. See BucketCache#getIOEngineFromName() for<a name="line.1218"></a> -<span class="sourceLineNo">1219</span> * list of supported ioengine options.<a name="line.1219"></a> -<span class="sourceLineNo">1220</span> * <p>Set this option and a non-zero {@link #BUCKET_CACHE_SIZE_KEY} to enable bucket cache.<a name="line.1220"></a> -<span class="sourceLineNo">1221</span> */<a name="line.1221"></a> -<span class="sourceLineNo">1222</span> public static final String BUCKET_CACHE_IOENGINE_KEY = "hbase.bucketcache.ioengine";<a name="line.1222"></a> -<span class="sourceLineNo">1223</span><a name="line.1223"></a> -<span class="sourceLineNo">1224</span> /**<a name="line.1224"></a> -<span class="sourceLineNo">1225</span> * When using bucket cache, this is a float that EITHER represents a percentage of total heap<a name="line.1225"></a> -<span class="sourceLineNo">1226</span> * memory size to give to the cache (if &lt; 1.0) OR, it is the capacity in<a name="line.1226"></a> -<span class="sourceLineNo">1227</span> * megabytes of the cache.<a name="line.1227"></a> -<span class="sourceLineNo">1228</span> */<a name="line.1228"></a> -<span class="sourceLineNo">1229</span> public static final String BUCKET_CACHE_SIZE_KEY = "hbase.bucketcache.size";<a name="line.1229"></a> -<span class="sourceLineNo">1230</span><a name="line.1230"></a> -<span class="sourceLineNo">1231</span> /**<a name="line.1231"></a> -<span class="sourceLineNo">1232</span> * HConstants for fast fail on the client side follow<a name="line.1232"></a> +<span class="sourceLineNo">1203</span> /** Drop edits for tables that been deleted from the replication source and target */<a name="line.1203"></a> +<span class="sourceLineNo">1204</span> public static final String REPLICATION_DROP_ON_DELETED_TABLE_KEY =<a name="line.1204"></a> +<span class="sourceLineNo">1205</span> "hbase.replication.drop.on.deleted.table";<a name="line.1205"></a> +<span class="sourceLineNo">1206</span><a name="line.1206"></a> +<span class="sourceLineNo">1207</span> /** Maximum number of threads used by the replication source for shipping edits to the sinks */<a name="line.1207"></a> +<span class="sourceLineNo">1208</span> public static final int REPLICATION_SOURCE_MAXTHREADS_DEFAULT = 10;<a name="line.1208"></a> +<span class="sourceLineNo">1209</span><a name="line.1209"></a> +<span class="sourceLineNo">1210</span> /** Configuration key for SplitLog manager timeout */<a name="line.1210"></a> +<span class="sourceLineNo">1211</span> public static final String HBASE_SPLITLOG_MANAGER_TIMEOUT = "hbase.splitlog.manager.timeout";<a name="line.1211"></a> +<span class="sourceLineNo">1212</span><a name="line.1212"></a> +<span class="sourceLineNo">1213</span> /**<a name="line.1213"></a> +<span class="sourceLineNo">1214</span> * Configuration keys for Bucket cache<a name="line.1214"></a> +<span class="sourceLineNo">1215</span> */<a name="line.1215"></a> +<span class="sourceLineNo">1216</span> // TODO moving these bucket cache implementation specific configs to this level is violation of<a name="line.1216"></a> +<span class="sourceLineNo">1217</span> // encapsulation. But as these has to be referred from hbase-common and bucket cache<a name="line.1217"></a> +<span class="sourceLineNo">1218</span> // sits in hbase-server, there were no other go! Can we move the cache implementation to<a name="line.1218"></a> +<span class="sourceLineNo">1219</span> // hbase-common?<a name="line.1219"></a> +<span class="sourceLineNo">1220</span><a name="line.1220"></a> +<span class="sourceLineNo">1221</span> /**<a name="line.1221"></a> +<span class="sourceLineNo">1222</span> * Current ioengine options in include: heap, offheap and file:PATH (where PATH is the path<a name="line.1222"></a> +<span class="sourceLineNo">1223</span> * to the file that will host the file-based cache. See BucketCache#getIOEngineFromName() for<a name="line.1223"></a> +<span class="sourceLineNo">1224</span> * list of supported ioengine options.<a name="line.1224"></a> +<span class="sourceLineNo">1225</span> * <p>Set this option and a non-zero {@link #BUCKET_CACHE_SIZE_KEY} to enable bucket cache.<a name="line.1225"></a> +<span class="sourceLineNo">1226</span> */<a name="line.1226"></a> +<span class="sourceLineNo">1227</span> public static final String BUCKET_CACHE_IOENGINE_KEY = "hbase.bucketcache.ioengine";<a name="line.1227"></a> +<span class="sourceLineNo">1228</span><a name="line.1228"></a> +<span class="sourceLineNo">1229</span> /**<a name="line.1229"></a> +<span class="sourceLineNo">1230</span> * When using bucket cache, this is a float that EITHER represents a percentage of total heap<a name="line.1230"></a> +<span class="sourceLineNo">1231</span> * memory size to give to the cache (if &lt; 1.0) OR, it is the capacity in<a name="line.1231"></a> +<span class="sourceLineNo">1232</span> * megabytes of the cache.<a name="line.1232"></a> <span class="sourceLineNo">1233</span> */<a name="line.1233"></a> -<span class="sourceLineNo">1234</span> /**<a name="line.1234"></a> -<span class="sourceLineNo">1235</span> * Config for enabling/disabling the fast fail mode.<a name="line.1235"></a> -<span class="sourceLineNo">1236</span> */<a name="line.1236"></a> -<span class="sourceLineNo">1237</span> public static final String HBASE_CLIENT_FAST_FAIL_MODE_ENABLED =<a name="line.1237"></a> -<span class="sourceLineNo">1238</span> "hbase.client.fast.fail.mode.enabled";<a name="line.1238"></a> -<span class="sourceLineNo">1239</span><a name="line.1239"></a> -<span class="sourceLineNo">1240</span> public static final boolean HBASE_CLIENT_ENABLE_FAST_FAIL_MODE_DEFAULT =<a name="line.1240"></a> -<span class="sourceLineNo">1241</span> false;<a name="line.1241"></a> -<span class="sourceLineNo">1242</span><a name="line.1242"></a> -<span class="sourceLineNo">1243</span> public static final String HBASE_CLIENT_FAST_FAIL_THREASHOLD_MS =<a name="line.1243"></a> -<span class="sourceLineNo">1244</span> "hbase.client.fastfail.threshold";<a name="line.1244"></a> -<span class="sourceLineNo">1245</span><a name="line.1245"></a> -<span class="sourceLineNo">1246</span> public static final long HBASE_CLIENT_FAST_FAIL_THREASHOLD_MS_DEFAULT =<a name="line.1246"></a> -<span class="sourceLineNo">1247</span> 60000;<a name="line.1247"></a> -<span class="sourceLineNo">1248</span><a name="line.1248"></a> -<span class="sourceLineNo">1249</span> public static final String HBASE_CLIENT_FAST_FAIL_CLEANUP_MS_DURATION_MS =<a name="line.1249"></a> -<span class="sourceLineNo">1250</span> "hbase.client.fast.fail.cleanup.duration";<a name="line.1250"></a> -<span class="sourceLineNo">1251</span><a name="line.1251"></a> -<span class="sourceLineNo">1252</span> public static final long HBASE_CLIENT_FAST_FAIL_CLEANUP_DURATION_MS_DEFAULT =<a name="line.1252"></a> -<span class="sourceLineNo">1253</span> 600000;<a name="line.1253"></a> -<span class="sourceLineNo">1254</span><a name="line.1254"></a> -<span class="sourceLineNo">1255</span> public static final String HBASE_CLIENT_FAST_FAIL_INTERCEPTOR_IMPL =<a name="line.1255"></a> -<span class="sourceLineNo">1256</span> "hbase.client.fast.fail.interceptor.impl";<a name="line.1256"></a> -<span class="sourceLineNo">1257</span><a name="line.1257"></a> -<span class="sourceLineNo">1258</span> /** Config key for if the server should send backpressure and if the client should listen to<a name="line.1258"></a> -<span class="sourceLineNo">1259</span> * that backpressure from the server */<a name="line.1259"></a> -<span class="sourceLineNo">1260</span> public static final String ENABLE_CLIENT_BACKPRESSURE = "hbase.client.backpressure.enabled";<a name="line.1260"></a> -<span class="sourceLineNo">1261</span> public static final boolean DEFAULT_ENABLE_CLIENT_BACKPRESSURE = false;<a name="line.1261"></a> +<span class="sourceLineNo">1234</span> public static final String BUCKET_CACHE_SIZE_KEY = "hbase.bucketcache.size";<a name="line.1234"></a> +<span class="sourceLineNo">1235</span><a name="line.1235"></a> +<span class="sourceLineNo">1236</span> /**<a name="line.1236"></a> +<span class="sourceLineNo">1237</span> * HConstants for fast fail on the client side follow<a name="line.1237"></a> +<span class="sourceLineNo">1238</span> */<a name="line.1238"></a> +<span class="sourceLineNo">1239</span> /**<a name="line.1239"></a> +<span class="sourceLineNo">1240</span> * Config for enabling/disabling the fast fail mode.<a name="line.1240"></a> +<span class="sourceLineNo">1241</span> */<a name="line.1241"></a> +<span class="sourceLineNo">1242</span> public static final String HBASE_CLIENT_FAST_FAIL_MODE_ENABLED =<a name="line.1242"></a> +<span class="sourceLineNo">1243</span> "hbase.client.fast.fail.mode.enabled";<a name="line.1243"></a> +<span class="sourceLineNo">1244</span><a name="line.1244"></a> +<span class="sourceLineNo">1245</span> public static final boolean HBASE_CLIENT_ENABLE_FAST_FAIL_MODE_DEFAULT =<a name="line.1245"></a> +<span class="sourceLineNo">1246</span> false;<a name="line.1246"></a> +<span class="sourceLineNo">1247</span><a name="line.1247"></a> +<span class="sourceLineNo">1248</span> public static final String HBASE_CLIENT_FAST_FAIL_THREASHOLD_MS =<a name="line.1248"></a> +<span class="sourceLineNo">1249</span> "hbase.client.fastfail.threshold";<a name="line.1249"></a> +<span class="sourceLineNo">1250</span><a name="line.1250"></a> +<span class="sourceLineNo">1251</span> public static final long HBASE_CLIENT_FAST_FAIL_THREASHOLD_MS_DEFAULT =<a name="line.1251"></a> +<span class="sourceLineNo">1252</span> 60000;<a name="line.1252"></a> +<span class="sourceLineNo">1253</span><a name="line.1253"></a> +<span class="sourceLineNo">1254</span> public static final String HBASE_CLIENT_FAST_FAIL_CLEANUP_MS_DURATION_MS =<a name="line.1254"></a> +<span class="sourceLineNo">1255</span> "hbase.client.fast.fail.cleanup.duration";<a name="line.1255"></a> +<span class="sourceLineNo">1256</span><a name="line.1256"></a> +<span class="sourceLineNo">1257</span> public static final long HBASE_CLIENT_FAST_FAIL_CLEANUP_DURATION_MS_DEFAULT =<a name="line.1257"></a> +<span class="sourceLineNo">1258</span> 600000;<a name="line.1258"></a> +<span class="sourceLineNo">1259</span><a name="line.1259"></a> +<span class="sourceLineNo">1260</span> public static final String HBASE_CLIENT_FAST_FAIL_INTERCEPTOR_IMPL =<a name="line.1260"></a> +<span class="sourceLineNo">1261</span> "hbase.client.fast.fail.interceptor.impl";<a name="line.1261"></a> <span class="sourceLineNo">1262</span><a name="line.1262"></a> -<span class="sourceLineNo">1263</span> public static final String HEAP_OCCUPANCY_LOW_WATERMARK_KEY =<a name="line.1263"></a> -<span class="sourceLineNo">1264</span> "hbase.heap.occupancy.low_water_mark";<a name="line.1264"></a> -<span class="sourceLineNo">1265</span> public static final float DEFAULT_HEAP_OCCUPANCY_LOW_WATERMARK = 0.95f;<a name="line.1265"></a> -<span class="sourceLineNo">1266</span> public static final String HEAP_OCCUPANCY_HIGH_WATERMARK_KEY =<a name="line.1266"></a> -<span class="sourceLineNo">1267</span> "hbase.heap.occupancy.high_water_mark";<a name="line.1267"></a> -<span class="sourceLineNo">1268</span> public static final float DEFAULT_HEAP_OCCUPANCY_HIGH_WATERMARK = 0.98f;<a name="line.1268"></a> -<span class="sourceLineNo">1269</span><a name="line.1269"></a> -<span class="sourceLineNo">1270</span> /**<a name="line.1270"></a> -<span class="sourceLineNo">1271</span> * The max number of threads used for splitting storefiles in parallel during<a name="line.1271"></a> -<span class="sourceLineNo">1272</span> * the region split process.<a name="line.1272"></a> -<span class="sourceLineNo">1273</span> */<a name="line.1273"></a> -<span class="sourceLineNo">1274</span> public static final String REGION_SPLIT_THREADS_MAX =<a name="line.1274"></a> -<span class="sourceLineNo">1275</span> "hbase.regionserver.region.split.threads.max";<a name="line.1275"></a> -<span class="sourceLineNo">1276</span><a name="line.1276"></a> -<span class="sourceLineNo">1277</span> /** Canary config keys */<a name="line.1277"></a> -<span class="sourceLineNo">1278</span> public static final String HBASE_CANARY_WRITE_DATA_TTL_KEY = "hbase.canary.write.data.ttl";<a name="line.1278"></a> -<span class="sourceLineNo">1279</span><a name="line.1279"></a> -<span class="sourceLineNo">1280</span> public static final String HBASE_CANARY_WRITE_PERSERVER_REGIONS_LOWERLIMIT_KEY =<a name="line.1280"></a> -<span class="sourceLineNo">1281</span> "hbase.canary.write.perserver.regions.lowerLimit";<a name="line.1281"></a> -<span class="sourceLineNo">1282</span><a name="line.1282"></a> -<span class="sourceLineNo">1283</span> public static final String HBASE_CANARY_WRITE_PERSERVER_REGIONS_UPPERLIMIT_KEY =<a name="line.1283"></a> -<span class="sourceLineNo">1284</span> "hbase.canary.write.perserver.regions.upperLimit";<a name="line.1284"></a> -<span class="sourceLineNo">1285</span><a name="line.1285"></a> -<span class="sourceLineNo">1286</span> public static final String HBASE_CANARY_WRITE_VALUE_SIZE_KEY = "hbase.canary.write.value.size";<a name="line.1286"></a> +<span class="sourceLineNo">1263</span> /** Config key for if the server should send backpressure and if the client should listen to<a name="line.1263"></a> +<span class="sourceLineNo">1264</span> * that backpressure from the server */<a name="line.1264"></a> +<span class="sourceLineNo">1265</span> public static final String ENABLE_CLIENT_BACKPRESSURE = "hbase.client.backpressure.enabled";<a name="line.1265"></a> +<span class="sourceLineNo">1266</span> public static final boolean DEFAULT_ENABLE_CLIENT_BACKPRESSURE = false;<a name="line.1266"></a> +<span class="sourceLineNo">1267</span><a name="line.1267"></a> +<span class="sourceLineNo">1268</span> public static final String HEAP_OCCUPANCY_LOW_WATERMARK_KEY =<a name="line.1268"></a> +<span class="sourceLineNo">1269</span> "hbase.heap.occupancy.low_water_mark";<a name="line.1269"></a> +<span class="sourceLineNo">1270</span> public static final float DEFAULT_HEAP_OCCUPANCY_LOW_WATERMARK = 0.95f;<a name="line.1270"></a> +<span class="sourceLineNo">1271</span> public static final String HEAP_OCCUPANCY_HIGH_WATERMARK_KEY =<a name="line.1271"></a> +<span class="sourceLineNo">1272</span> "hbase.heap.occupancy.high_water_mark";<a name="line.1272"></a> +<span class="sourceLineNo">1273</span> public static final float DEFAULT_HEAP_OCCUPANCY_HIGH_WATERMARK = 0.98f;<a name="line.1273"></a> +<span class="sourceLineNo">1274</span><a name="line.1274"></a> +<span class="sourceLineNo">1275</span> /**<a name="line.1275"></a> +<span class="sourceLineNo">1276</span> * The max number of threads used for splitting storefiles in parallel during<a name="line.1276"></a> +<span class="sourceLineNo">1277</span> * the region split process.<a name="line.1277"></a> +<span class="sourceLineNo">1278</span> */<a name="line.1278"></a> +<span class="sourceLineNo">1279</span> public static final String REGION_SPLIT_THREADS_MAX =<a name="line.1279"></a> +<span class="sourceLineNo">1280</span> "hbase.regionserver.region.split.threads.max";<a name="line.1280"></a> +<span class="sourceLineNo">1281</span><a name="line.1281"></a> +<span class="sourceLineNo">1282</span> /** Canary config keys */<a name="line.1282"></a> +<span class="sourceLineNo">1283</span> public static final String HBASE_CANARY_WRITE_DATA_TTL_KEY = "hbase.canary.write.data.ttl";<a name="line.1283"></a> +<span class="sourceLineNo">1284</span><a name="line.1284"></a> +<span class="sourceLineNo">1285</span> public static final String HBASE_CANARY_WRITE_PERSERVER_REGIONS_LOWERLIMIT_KEY =<a name="line.1285"></a> +<span class="sourceLineNo">1286</span> "hbase.canary.write.perserver.regions.lowerLimit";<a name="line.1286"></a> <span class="sourceLineNo">1287</span><a name="line.1287"></a> -<span class="sourceLineNo">1288</span> public static final String HBASE_CANARY_WRITE_TABLE_CHECK_PERIOD_KEY =<a name="line.1288"></a> -<span class="sourceLineNo">1289</span> "hbase.canary.write.table.check.period";<a name="line.1289"></a> +<span class="sourceLineNo">1288</span> public static final String HBASE_CANARY_WRITE_PERSERVER_REGIONS_UPPERLIMIT_KEY =<a name="line.1288"></a> +<span class="sourceLineNo">1289</span> "hbase.canary.write.perserver.regions.upperLimit";<a name="line.1289"></a> <span class="sourceLineNo">1290</span><a name="line.1290"></a> -<span class="sourceLineNo">1291</span> public static final String HBASE_CANARY_READ_RAW_SCAN_KEY = "hbase.canary.read.raw.enabled";<a name="line.1291"></a> +<span class="sourceLineNo">1291</span> public static final String HBASE_CANARY_WRITE_VALUE_SIZE_KEY = "hbase.canary.write.value.size";<a name="line.1291"></a> <span class="sourceLineNo">1292</span><a name="line.1292"></a> -<span class="sourceLineNo">1293</span> /**<a name="line.1293"></a> -<span class="sourceLineNo">1294</span> * Configuration keys for programmatic JAAS configuration for secured ZK interaction<a name="line.1294"></a> -<span class="sourceLineNo">1295</span> */<a name="line.1295"></a> -<span class="sourceLineNo">1296</span> public static final String ZK_CLIENT_KEYTAB_FILE = "hbase.zookeeper.client.keytab.file";<a name="line.1296"></a> -<span class="sourceLineNo">1297</span> public static final String ZK_CLIENT_KERBEROS_PRINCIPAL =<a name="line.1297"></a> -<span class="sourceLineNo">1298</span> "hbase.zookeeper.client.kerberos.principal";<a name="line.1298"></a> -<span class="sourceLineNo">1299</span> public static final String ZK_SERVER_KEYTAB_FILE = "hbase.zookeeper.server.keytab.file";<a name="line.1299"></a> -<span class="sourceLineNo">1300</span> public static final String ZK_SERVER_KERBEROS_PRINCIPAL =<a name="line.1300"></a> -<span class="sourceLineNo">1301</span> "hbase.zookeeper.server.kerberos.principal";<a name="line.1301"></a> -<span class="sourceLineNo">1302</span><a name="line.1302"></a> -<span class="sourceLineNo">1303</span> /** Config key for hbase temporary directory in hdfs */<a name="line.1303"></a> -<span class="sourceLineNo">1304</span> public static final String TEMPORARY_FS_DIRECTORY_KEY = "hbase.fs.tmp.dir";<a name="line.1304"></a> -<span class="sourceLineNo">1305</span> public static final String DEFAULT_TEMPORARY_HDFS_DIRECTORY = "/user/"<a name="line.1305"></a> -<span class="sourceLineNo">1306</span> + System.getProperty("user.name") + "/hbase-staging";<a name="line.1306"></a> +<span class="sourceLineNo">1293</span> public static final String HBASE_CANARY_WRITE_TABLE_CHECK_PERIOD_KEY =<a name="line.1293"></a> +<span class="sourceLineNo">1294</span> "hbase.canary.write.table.check.period";<a name="line.1294"></a> +<span class="sourceLineNo">1295</span><a name="line.1295"></a> +<span class="sourceLineNo">1296</span> public static final String HBASE_CANARY_READ_RAW_SCAN_KEY = "hbase.canary.read.raw.enabled";<a name="line.1296"></a> +<span class="sourceLineNo">1297</span><a name="line.1297"></a> +<span class="sourceLineNo">1298</span> /**<a name="line.1298"></a> +<span class="sourceLineNo">1299</span> * Configuration keys for programmatic JAAS configuration for secured ZK interaction<a name="line.1299"></a> +<span class="sourceLineNo">1300</span> */<a name="line.1300"></a> +<span class="sourceLineNo">1301</span> public static final String ZK_CLIENT_KEYTAB_FILE = "hbase.zookeeper.client.keytab.file";<a name="line.1301"></a> +<span class="sourceLineNo">1302</span> public static final String ZK_CLIENT_KERBEROS_PRINCIPAL =<a name="line.1302"></a> +<span class="sourceLineNo">1303</span> "hbase.zookeeper.client.kerberos.principal";<a name="line.1303"></a> +<span class="sourceLineNo">1304</span> public static final String ZK_SERVER_KEYTAB_FILE = "hbase.zookeeper.server.keytab.file";<a name="line.1304"></a> +<span class="sourceLineNo">1305</span> public static final String ZK_SERVER_KERBEROS_PRINCIPAL =<a name="line.1305"></a> +<span class="sourceLineNo">1306</span> "hbase.zookeeper.server.kerberos.principal";<a name="line.1306"></a> <span class="sourceLineNo">1307</span><a name="line.1307"></a> -<span class="sourceLineNo">1308</span> public static final String SNAPSHOT_RESTORE_TAKE_FAILSAFE_SNAPSHOT =<a name="line.1308"></a> -<span class="sourceLineNo">1309</span> "hbase.snapshot.restore.take.failsafe.snapshot";<a name="line.1309"></a> -<span class="sourceLineNo">1310</span> public static final boolean DEFAULT_SNAPSHOT_RESTORE_TAKE_FAILSAFE_SNAPSHOT = true;<a name="line.1310"></a> -<span class="sourceLineNo">1311</span><a name="line.1311"></a> -<span class="sourceLineNo">1312</span> public static final String SNAPSHOT_RESTORE_FAILSAFE_NAME =<a name="line.1312"></a> -<span class="sourceLineNo">1313</span> "hbase.snapshot.restore.failsafe.name";<a name="line.1313"></a> -<span class="sourceLineNo">1314</span> public static final String DEFAULT_SNAPSHOT_RESTORE_FAILSAFE_NAME =<a name="line.1314"></a> -<span class="sourceLineNo">1315</span> "hbase-failsafe-{snapshot.name}-{restore.timestamp}";<a name="line.1315"></a> +<span class="sourceLineNo">1308</span> /** Config key for hbase temporary directory in hdfs */<a name="line.1308"></a> +<span class="sourceLineNo">1309</span> public static final String TEMPORARY_FS_DIRECTORY_KEY = "hbase.fs.tmp.dir";<a name="line.1309"></a> +<span class="sourceLineNo">1310</span> public static final String DEFAULT_TEMPORARY_HDFS_DIRECTORY = "/user/"<a name="line.1310"></a> +<span class="sourceLineNo">1311</span> + System.getProperty("user.name") + "/hbase-staging";<a name="line.1311"></a> +<span class="sourceLineNo">1312</span><a name="line.1312"></a> +<span class="sourceLineNo">1313</span> public static final String SNAPSHOT_RESTORE_TAKE_FAILSAFE_SNAPSHOT =<a name="line.1313"></a> +<span class="sourceLineNo">1314</span> "hbase.snapshot.restore.take.failsafe.snapshot";<a name="line.1314"></a> +<span class="sourceLineNo">1315</span> public static final boolean DEFAULT_SNAPSHOT_RESTORE_TAKE_FAILSAFE_SNAPSHOT = true;<a name="line.1315"></a> <span class="sourceLineNo">1316</span><a name="line.1316"></a> -<span class="sourceLineNo">1317</span> public static final String NOT_IMPLEMENTED = "Not implemented";<a name="line.1317"></a> -<span class="sourceLineNo">1318</span><a name="line.1318"></a> -<span class="sourceLineNo">1319</span> private HConstants() {<a name="line.1319"></a> -<span class="sourceLineNo">1320</span> // Can't be instantiated with this ctor.<a name="line.1320"></a> -<span class="sourceLineNo">1321</span> }<a name="line.1321"></a> -<span class="sourceLineNo">1322</span>}<a name="line.1322"></a> +<span class="sourceLineNo">1317</span> public static final String SNAPSHOT_RESTORE_FAILSAFE_NAME =<a name="line.1317"></a> +<span class="sourceLineNo">1318</span> "hbase.snapshot.restore.failsafe.name";<a name="line.1318"></a> +<span class="sourceLineNo">1319</span> public static final String DEFAULT_SNAPSHOT_RESTORE_FAILSAFE_NAME =<a name="line.1319"></a> +<span class="sourceLineNo">1320</span> "hbase-failsafe-{snapshot.name}-{restore.timestamp}";<a name="line.1320"></a> +<span class="sourceLineNo">1321</span><a name="line.1321"></a> +<span class="sourceLineNo">1322</span> public static final String NOT_IMPLEMENTED = "Not implemented";<a name="line.1322"></a> +<span class="sourceLineNo">1323</span><a name="line.1323"></a> +<span class="sourceLineNo">1324</span> private HConstants() {<a name="line.1324"></a> +<span class="sourceLineNo">1325</span> // Can't be instantiated with this ctor.<a name="line.1325"></a> +<span class="sourceLineNo">1326</span> }<a name="line.1326"></a> +<span class="sourceLineNo">1327</span>}<a name="line.1327"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cba900e4/apidocs/src-html/org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html ---------------------------------------------------------------------- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html b/apidocs/src-html/org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html index 8d46bf3..7935692 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html @@ -27,161 +27,170 @@ <span class="sourceLineNo">019</span><a name="line.19"></a> <span class="sourceLineNo">020</span>package org.apache.hadoop.hbase.client;<a name="line.20"></a> <span class="sourceLineNo">021</span><a name="line.21"></a> -<span class="sourceLineNo">022</span>import java.io.PrintWriter;<a name="line.22"></a> -<span class="sourceLineNo">023</span>import java.io.StringWriter;<a name="line.23"></a> -<span class="sourceLineNo">024</span>import java.util.Collection;<a name="line.24"></a> -<span class="sourceLineNo">025</span>import java.util.HashMap;<a name="line.25"></a> -<span class="sourceLineNo">026</span>import java.util.HashSet;<a name="line.26"></a> -<span class="sourceLineNo">027</span>import java.util.List;<a name="line.27"></a> -<span class="sourceLineNo">028</span>import java.util.Map;<a name="line.28"></a> -<span class="sourceLineNo">029</span>import java.util.Set;<a name="line.29"></a> -<span class="sourceLineNo">030</span><a name="line.30"></a> -<span class="sourceLineNo">031</span>import org.apache.hadoop.hbase.DoNotRetryIOException;<a name="line.31"></a> -<span class="sourceLineNo">032</span>import org.apache.yetus.audience.InterfaceAudience;<a name="line.32"></a> -<span class="sourceLineNo">033</span>import org.apache.hadoop.hbase.util.Bytes;<a name="line.33"></a> -<span class="sourceLineNo">034</span><a name="line.34"></a> -<span class="sourceLineNo">035</span>/**<a name="line.35"></a> -<span class="sourceLineNo">036</span> * This subclass of {@link org.apache.hadoop.hbase.client.RetriesExhaustedException}<a name="line.36"></a> -<span class="sourceLineNo">037</span> * is thrown when we have more information about which rows were causing which<a name="line.37"></a> -<span class="sourceLineNo">038</span> * exceptions on what servers. You can call {@link #mayHaveClusterIssues()}<a name="line.38"></a> -<span class="sourceLineNo">039</span> * and if the result is false, you have input error problems, otherwise you<a name="line.39"></a> -<span class="sourceLineNo">040</span> * may have cluster issues. You can iterate over the causes, rows and last<a name="line.40"></a> -<span class="sourceLineNo">041</span> * known server addresses via {@link #getNumExceptions()} and<a name="line.41"></a> -<span class="sourceLineNo">042</span> * {@link #getCause(int)}, {@link #getRow(int)} and {@link #getHostnamePort(int)}.<a name="line.42"></a> -<span class="sourceLineNo">043</span> */<a name="line.43"></a> -<span class="sourceLineNo">044</span>@SuppressWarnings("serial")<a name="line.44"></a> -<span class="sourceLineNo">045</span>@InterfaceAudience.Public<a name="line.45"></a> -<span class="sourceLineNo">046</span>public class RetriesExhaustedWithDetailsException<a name="line.46"></a> -<span class="sourceLineNo">047</span>extends RetriesExhaustedException {<a name="line.47"></a> -<span class="sourceLineNo">048</span> List<Throwable> exceptions;<a name="line.48"></a> -<span class="sourceLineNo">049</span> List<Row> actions;<a name="line.49"></a> -<span class="sourceLineNo">050</span> List<String> hostnameAndPort;<a name="line.50"></a> -<span class="sourceLineNo">051</span><a name="line.51"></a> -<span class="sourceLineNo">052</span> public RetriesExhaustedWithDetailsException(List<Throwable> exceptions,<a name="line.52"></a> -<span class="sourceLineNo">053</span> List<Row> actions,<a name="line.53"></a> -<span class="sourceLineNo">054</span> List<String> hostnameAndPort) {<a name="line.54"></a> -<span class="sourceLineNo">055</span> super("Failed " + exceptions.size() + " action" +<a name="line.55"></a> -<span class="sourceLineNo">056</span> pluralize(exceptions) + ": " +<a name="line.56"></a> -<span class="sourceLineNo">057</span> getDesc(exceptions, actions, hostnameAndPort));<a name="line.57"></a> -<span class="sourceLineNo">058</span><a name="line.58"></a> -<span class="sourceLineNo">059</span> this.exceptions = exceptions;<a name="line.59"></a> -<span class="sourceLineNo">060</span> this.actions = actions;<a name="line.60"></a> -<span class="sourceLineNo">061</span> this.hostnameAndPort = hostnameAndPort;<a name="line.61"></a> -<span class="sourceLineNo">062</span> }<a name="line.62"></a> -<span class="sourceLineNo">063</span><a name="line.63"></a> -<span class="sourceLineNo">064</span> public List<Throwable> getCauses() {<a name="line.64"></a> -<span class="sourceLineNo">065</span> return exceptions;<a name="line.65"></a> -<span class="sourceLineNo">066</span> }<a name="line.66"></a> +<span class="sourceLineNo">022</span>import java.io.IOException;<a name="line.22"></a> +<span class="sourceLineNo">023</span>import java.io.PrintWriter;<a name="line.23"></a> +<span class="sourceLineNo">024</span>import java.io.StringWriter;<a name="line.24"></a> +<span class="sourceLineNo">025</span>import java.util.Collection;<a name="line.25"></a> +<span class="sourceLineNo">026</span>import java.util.HashMap;<a name="line.26"></a> +<span class="sourceLineNo">027</span>import java.util.HashSet;<a name="line.27"></a> +<span class="sourceLineNo">028</span>import java.util.List;<a name="line.28"></a> +<span class="sourceLineNo">029</span>import java.util.Map;<a name="line.29"></a> +<span class="sourceLineNo">030</span>import java.util.Set;<a name="line.30"></a> +<span class="sourceLineNo">031</span><a name="line.31"></a> +<span class="sourceLineNo">032</span>import org.apache.hadoop.hbase.DoNotRetryIOException;<a name="line.32"></a> +<span class="sourceLineNo">033</span>import org.apache.yetus.audience.InterfaceAudience;<a name="line.33"></a> +<span class="sourceLineNo">034</span>import org.apache.hadoop.hbase.util.Bytes;<a name="line.34"></a> +<span class="sourceLineNo">035</span><a name="line.35"></a> +<span class="sourceLineNo">036</span>/**<a name="line.36"></a> +<span class="sourceLineNo">037</span> * This subclass of {@link org.apache.hadoop.hbase.client.RetriesExhaustedException}<a name="line.37"></a> +<span class="sourceLineNo">038</span> * is thrown when we have more information about which rows were causing which<a name="line.38"></a> +<span class="sourceLineNo">039</span> * exceptions on what servers. You can call {@link #mayHaveClusterIssues()}<a name="line.39"></a> +<span class="sourceLineNo">040</span> * and if the result is false, you have input error problems, otherwise you<a name="line.40"></a> +<span class="sourceLineNo">041</span> * may have cluster issues. You can iterate over the causes, rows and last<a name="line.41"></a> +<span class="sourceLineNo">042</span> * known server addresses via {@link #getNumExceptions()} and<a name="line.42"></a> +<span class="sourceLineNo">043</span> * {@link #getCause(int)}, {@link #getRow(int)} and {@link #getHostnamePort(int)}.<a name="line.43"></a> +<span class="sourceLineNo">044</span> */<a name="line.44"></a> +<span class="sourceLineNo">045</span>@SuppressWarnings("serial")<a name="line.45"></a> +<span class="sourceLineNo">046</span>@InterfaceAudience.Public<a name="line.46"></a> +<span class="sourceLineNo">047</span>public class RetriesExhaustedWithDetailsException<a name="line.47"></a> +<span class="sourceLineNo">048</span>extends RetriesExhaustedException {<a name="line.48"></a> +<span class="sourceLineNo">049</span> List<Throwable> exceptions;<a name="line.49"></a> +<span class="sourceLineNo">050</span> List<Row> actions;<a name="line.50"></a> +<span class="sourceLineNo">051</span> List<String> hostnameAndPort;<a name="line.51"></a> +<span class="sourceLineNo">052</span><a name="line.52"></a> +<span class="sourceLineNo">053</span> public RetriesExhaustedWithDetailsException(final String msg) {<a name="line.53"></a> +<span class="sourceLineNo">054</span> super(msg);<a name="line.54"></a> +<span class="sourceLineNo">055</span> }<a name="line.55"></a> +<span class="sourceLineNo">056</span><a name="line.56"></a> +<span class="sourceLineNo">057</span> public RetriesExhaustedWithDetailsException(final String msg, final IOException e) {<a name="line.57"></a> +<span class="sourceLineNo">058</span> super(msg, e);<a name="line.58"></a> +<span class="sourceLineNo">059</span> }<a name="line.59"></a> +<span class="sourceLineNo">060</span><a name="line.60"></a> +<span class="sourceLineNo">061</span> public RetriesExhaustedWithDetailsException(List<Throwable> exceptions,<a name="line.61"></a> +<span class="sourceLineNo">062</span> List<Row> actions,<a name="line.62"></a> +<span class="sourceLineNo">063</span> List<String> hostnameAndPort) {<a name="line.63"></a> +<span class="sourceLineNo">064</span> super("Failed " + exceptions.size() + " action" +<a name="line.64"></a> +<span class="sourceLineNo">065</span> pluralize(exceptions) + ": " +<a name="line.65"></a> +<span class="sourceLineNo">066</span> getDesc(exceptions, actions, hostnameAndPort));<a name="line.66"></a> <span class="sourceLineNo">067</span><a name="line.67"></a> -<span class="sourceLineNo">068</span> public int getNumExceptions() {<a name="line.68"></a> -<span class="sourceLineNo">069</span> return exceptions.size();<a name="line.69"></a> -<span class="sourceLineNo">070</span> }<a name="line.70"></a> -<span class="sourceLineNo">071</span><a name="line.71"></a> -<span class="sourceLineNo">072</span> public Throwable getCause(int i) {<a name="line.72"></a> -<span class="sourceLineNo">073</span> return exceptions.get(i);<a name="line.73"></a> -<span class="sourceLineNo">074</span> }<a name="line.74"></a> -<span class="sourceLineNo">075</span><a name="line.75"></a> -<span class="sourceLineNo">076</span> public Row getRow(int i) {<a name="line.76"></a> -<span class="sourceLineNo">077</span> return actions.get(i);<a name="line.77"></a> -<span class="sourceLineNo">078</span> }<a name="line.78"></a> -<span class="sourceLineNo">079</span><a name="line.79"></a> -<span class="sourceLineNo">080</span> public String getHostnamePort(final int i) {<a name="line.80"></a> -<span class="sourceLineNo">081</span> return this.hostnameAndPort.get(i);<a name="line.81"></a> -<span class="sourceLineNo">082</span> }<a name="line.82"></a> -<span class="sourceLineNo">083</span><a name="line.83"></a> -<span class="sourceLineNo">084</span> public boolean mayHaveClusterIssues() {<a name="line.84"></a> -<span class="sourceLineNo">085</span> boolean res = false;<a name="line.85"></a> -<span class="sourceLineNo">086</span><a name="line.86"></a> -<span class="sourceLineNo">087</span> // If all of the exceptions are DNRIOE not exception<a name="line.87"></a> -<span class="sourceLineNo">088</span> for (Throwable t : exceptions) {<a name="line.88"></a> -<span class="sourceLineNo">089</span> if (!(t instanceof DoNotRetryIOException)) {<a name="line.89"></a> -<span class="sourceLineNo">090</span> res = true;<a name="line.90"></a> -<span class="sourceLineNo">091</span> }<a name="line.91"></a> -<span class="sourceLineNo">092</span> }<a name="line.92"></a> -<span class="sourceLineNo">093</span> return res;<a name="line.93"></a> -<span class="sourceLineNo">094</span> }<a name="line.94"></a> +<span class="sourceLineNo">068</span> this.exceptions = exceptions;<a name="line.68"></a> +<span class="sourceLineNo">069</span> this.actions = actions;<a name="line.69"></a> +<span class="sourceLineNo">070</span> this.hostnameAndPort = hostnameAndPort;<a name="line.70"></a> +<span class="sourceLineNo">071</span> }<a name="line.71"></a> +<span class="sourceLineNo">072</span><a name="line.72"></a> +<span class="sourceLineNo">073</span> public List<Throwable> getCauses() {<a name="line.73"></a> +<span class="sourceLineNo">074</span> return exceptions;<a name="line.74"></a> +<span class="sourceLineNo">075</span> }<a name="line.75"></a> +<span class="sourceLineNo">076</span><a name="line.76"></a> +<span class="sourceLineNo">077</span> public int getNumExceptions() {<a name="line.77"></a> +<span class="sourceLineNo">078</span> return exceptions.size();<a name="line.78"></a> +<span class="sourceLineNo">079</span> }<a name="line.79"></a> +<span class="sourceLineNo">080</span><a name="line.80"></a> +<span class="sourceLineNo">081</span> public Throwable getCause(int i) {<a name="line.81"></a> +<span class="sourceLineNo">082</span> return exceptions.get(i);<a name="line.82"></a> +<span class="sourceLineNo">083</span> }<a name="line.83"></a> +<span class="sourceLineNo">084</span><a name="line.84"></a> +<span class="sourceLineNo">085</span> public Row getRow(int i) {<a name="line.85"></a> +<span class="sourceLineNo">086</span> return actions.get(i);<a name="line.86"></a> +<span class="sourceLineNo">087</span> }<a name="line.87"></a> +<span class="sourceLineNo">088</span><a name="line.88"></a> +<span class="sourceLineNo">089</span> public String getHostnamePort(final int i) {<a name="line.89"></a> +<span class="sourceLineNo">090</span> return this.hostnameAndPort.get(i);<a name="line.90"></a> +<span class="sourceLineNo">091</span> }<a name="line.91"></a> +<span class="sourceLineNo">092</span><a name="line.92"></a> +<span class="sourceLineNo">093</span> public boolean mayHaveClusterIssues() {<a name="line.93"></a> +<span class="sourceLineNo">094</span> boolean res = false;<a name="line.94"></a> <span class="sourceLineNo">095</span><a name="line.95"></a> -<span class="sourceLineNo">096</span><a name="line.96"></a> -<span class="sourceLineNo">097</span> public static String pluralize(Collection<?> c) {<a name="line.97"></a> -<span class="sourceLineNo">098</span> return pluralize(c.size());<a name="line.98"></a> -<span class="sourceLineNo">099</span> }<a name="line.99"></a> -<span class="sourceLineNo">100</span><a name="line.100"></a> -<span class="sourceLineNo">101</span> public static String pluralize(int c) {<a name="line.101"></a> -<span class="sourceLineNo">102</span> return c > 1 ? "s" : "";<a name="line.102"></a> +<span class="sourceLineNo">096</span> // If all of the exceptions are DNRIOE not exception<a name="line.96"></a> +<span class="sourceLineNo">097</span> for (Throwable t : exceptions) {<a name="line.97"></a> +<span class="sourceLineNo">098</span> if (!(t instanceof DoNotRetryIOException)) {<a name="line.98"></a> +<span class="sourceLineNo">099</span> res = true;<a name="line.99"></a> +<span class="sourceLineNo">100</span> }<a name="line.100"></a> +<span class="sourceLineNo">101</span> }<a name="line.101"></a> +<span class="sourceLineNo">102</span> return res;<a name="line.102"></a> <span class="sourceLineNo">103</span> }<a name="line.103"></a> <span class="sourceLineNo">104</span><a name="line.104"></a> -<span class="sourceLineNo">105</span> public static String getDesc(List<Throwable> exceptions,<a name="line.105"></a> -<span class="sourceLineNo">106</span> List<? extends Row> actions,<a name="line.106"></a> -<span class="sourceLineNo">107</span> List<String> hostnamePort) {<a name="line.107"></a> -<span class="sourceLineNo">108</span> String s = getDesc(classifyExs(exceptions));<a name="line.108"></a> -<span class="sourceLineNo">109</span> StringBuilder addrs = new StringBuilder(s);<a name="line.109"></a> -<span class="sourceLineNo">110</span> addrs.append("servers with issues: ");<a name="line.110"></a> -<span class="sourceLineNo">111</span> Set<String> uniqAddr = new HashSet<>();<a name="line.111"></a> -<span class="sourceLineNo">112</span> uniqAddr.addAll(hostnamePort);<a name="line.112"></a> +<span class="sourceLineNo">105</span><a name="line.105"></a> +<span class="sourceLineNo">106</span> public static String pluralize(Collection<?> c) {<a name="line.106"></a> +<span class="sourceLineNo">107</span> return pluralize(c.size());<a name="line.107"></a> +<span class="sourceLineNo">108</span> }<a name="line.108"></a> +<span class="sourceLineNo">109</span><a name="line.109"></a> +<span class="sourceLineNo">110</span> public static String pluralize(int c) {<a name="line.110"></a> +<span class="sourceLineNo">111</span> return c > 1 ? "s" : "";<a name="line.111"></a> +<span class="sourceLineNo">112</span> }<a name="line.112"></a> <span class="sourceLineNo">113</span><a name="line.113"></a> -<span class="sourceLineNo">114</span> for (String addr : uniqAddr) {<a name="line.114"></a> -<span class="sourceLineNo">115</span> addrs.append(addr).append(", ");<a name="line.115"></a> -<span class="sourceLineNo">116</span> }<a name="line.116"></a> -<span class="sourceLineNo">117</span> return uniqAddr.isEmpty() ? addrs.toString() : addrs.substring(0, addrs.length() - 2);<a name="line.117"></a> -<span class="sourceLineNo">118</span> }<a name="line.118"></a> -<span class="sourceLineNo">119</span><a name="line.119"></a> -<span class="sourceLineNo">120</span> public String getExhaustiveDescription() {<a name="line.120"></a> -<span class="sourceLineNo">121</span> StringWriter errorWriter = new StringWriter();<a name="line.121"></a> -<span class="sourceLineNo">122</span> PrintWriter pw = new PrintWriter(errorWriter);<a name="line.122"></a> -<span class="sourceLineNo">123</span> for (int i = 0; i < this.exceptions.size(); ++i) {<a name="line.123"></a> -<span class="sourceLineNo">124</span> Throwable t = this.exceptions.get(i);<a name="line.124"></a> -<span class="sourceLineNo">125</span> Row action = this.actions.get(i);<a name="line.125"></a> -<span class="sourceLineNo">126</span> String server = this.hostnameAndPort.get(i);<a name="line.126"></a> -<span class="sourceLineNo">127</span> pw.append("exception");<a name="line.127"></a> -<span class="sourceLineNo">128</span> if (this.exceptions.size() > 1) {<a name="line.128"></a> -<span class="sourceLineNo">129</span> pw.append(" #" + i);<a name="line.129"></a> -<span class="sourceLineNo">130</span> }<a name="line.130"></a> -<span class="sourceLineNo">131</span> pw.append(" from " + server + " for "<a name="line.131"></a> -<span class="sourceLineNo">132</span> + ((action == null) ? "unknown key" : Bytes.toStringBinary(action.getRow())));<a name="line.132"></a> -<span class="sourceLineNo">133</span> if (t != null) {<a name="line.133"></a> -<span class="sourceLineNo">134</span> pw.println();<a name="line.134"></a> -<span class="sourceLineNo">135</span> t.printStackTrace(pw);<a name="line.135"></a> -<span class="sourceLineNo">136</span> }<a name="line.136"></a> -<span class="sourceLineNo">137</span> }<a name="line.137"></a> -<span class="sourceLineNo">138</span> pw.flush();<a name="line.138"></a> -<span class="sourceLineNo">139</span> return errorWriter.toString();<a name="line.139"></a> -<span class="sourceLineNo">140</span> }<a name="line.140"></a> -<span class="sourceLineNo">141</span><a name="line.141"></a> -<span class="sourceLineNo">142</span><a name="line.142"></a> -<span class="sourceLineNo">143</span> public static Map<String, Integer> classifyExs(List<Throwable> ths) {<a name="line.143"></a> -<span class="sourceLineNo">144</span> Map<String, Integer> cls = new HashMap<>();<a name="line.144"></a> -<span class="sourceLineNo">145</span> for (Throwable t : ths) {<a name="line.145"></a> -<span class="sourceLineNo">146</span> if (t == null) continue;<a name="line.146"></a> -<span class="sourceLineNo">147</span> String name = "";<a name="line.147"></a> -<span class="sourceLineNo">148</span> if (t instanceof DoNotRetryIOException) {<a name="line.148"></a> -<span class="sourceLineNo">149</span> name = t.getMessage();<a name="line.149"></a> -<span class="sourceLineNo">150</span> } else {<a name="line.150"></a> -<span class="sourceLineNo">151</span> name = t.getClass().getSimpleName();<a name="line.151"></a> -<span class="sourceLineNo">152</span> }<a name="line.152"></a> -<span class="sourceLineNo">153</span> Integer i = cls.get(name);<a name="line.153"></a> -<span class="sourceLineNo">154</span> if (i == null) {<a name="line.154"></a> -<span class="sourceLineNo">155</span> i = 0;<a name="line.155"></a> -<span class="sourceLineNo">156</span> }<a name="line.156"></a> -<span class="sourceLineNo">157</span> i += 1;<a name="line.157"></a> -<span class="sourceLineNo">158</span> cls.put(name, i);<a name="line.158"></a> -<span class="sourceLineNo">159</span> }<a name="line.159"></a> -<span class="sourceLineNo">160</span> return cls;<a name="line.160"></a> -<span class="sourceLineNo">161</span> }<a name="line.161"></a> -<span class="sourceLineNo">162</span><a name="line.162"></a> -<span class="sourceLineNo">163</span> public static String getDesc(Map<String,Integer> classificaton) {<a name="line.163"></a> -<span class="sourceLineNo">164</span> StringBuilder classificatons =new StringBuilder(11);<a name="line.164"></a> -<span class="sourceLineNo">165</span> for (Map.Entry<String, Integer> e : classificaton.entrySet()) {<a name="line.165"></a> -<span class="sourceLineNo">166</span> classificatons.append(e.getKey());<a name="line.166"></a> -<span class="sourceLineNo">167</span> classificatons.append(": ");<a name="line.167"></a> -<span class="sourceLineNo">168</span> classificatons.append(e.getValue());<a name="line.168"></a> -<span class="sourceLineNo">169</span> classificatons.append(" time");<a name="line.169"></a> -<span class="sourceLineNo">170</span> classificatons.append(pluralize(e.getValue()));<a name="line.170"></a> -<span class="sourceLineNo">171</span> classificatons.append(", ");<a name="line.171"></a> -<span class="sourceLineNo">172</span> }<a name="line.172"></a> -<span class="sourceLineNo">173</span> return classificatons.toString();<a name="line.173"></a> -<span class="sourceLineNo">174</span> }<a name="line.174"></a> -<span class="sourceLineNo">175</span><a name="line.175"></a> -<span class="sourceLineNo">176</span>}<a name="line.176"></a> +<span class="sourceLineNo">114</span> public static String getDesc(List<Throwable> exceptions,<a name="line.114"></a> +<span class="sourceLineNo">115</span> List<? extends Row> actions,<a name="line.115"></a> +<span class="sourceLineNo">116</span> List<String> hostnamePort) {<a name="line.116"></a> +<span class="sourceLineNo">117</span> String s = getDesc(classifyExs(exceptions));<a name="line.117"></a> +<span class="sourceLineNo">118</span> StringBuilder addrs = new StringBuilder(s);<a name="line.118"></a> +<span class="sourceLineNo">119</span> addrs.append("servers with issues: ");<a name="line.119"></a> +<span class="sourceLineNo">120</span> Set<String> uniqAddr = new HashSet<>();<a name="line.120"></a> +<span class="sourceLineNo">121</span> uniqAddr.addAll(hostnamePort);<a name="line.121"></a> +<span class="sourceLineNo">122</span><a name="line.122"></a> +<span class="sourceLineNo">123</span> for (String addr : uniqAddr) {<a name="line.123"></a> +<span class="sourceLineNo">124</span> addrs.append(addr).append(", ");<a name="line.124"></a> +<span class="sourceLineNo">125</span> }<a name="line.125"></a> +<span class="sourceLineNo">126</span> return uniqAddr.isEmpty() ? addrs.toString() : addrs.substring(0, addrs.length() - 2);<a name="line.126"></a> +<span class="sourceLineNo">127</span> }<a name="line.127"></a> +<span class="sourceLineNo">128</span><a name="line.128"></a> +<span class="sourceLineNo">129</span> public String getExhaustiveDescription() {<a name="line.129"></a> +<span class="sourceLineNo">130</span> StringWriter errorWriter = new StringWriter();<a name="line.130"></a> +<span class="sourceLineNo">131</span> PrintWriter pw = new PrintWriter(errorWriter);<a name="line.131"></a> +<span class="sourceLineNo">132</span> for (int i = 0; i < this.exceptions.size(); ++i) {<a name="line.132"></a> +<span class="sourceLineNo">133</span> Throwable t = this.exceptions.get(i);<a name="line.133"></a> +<span class="sourceLineNo">134</span> Row action = this.actions.get(i);<a name="line.134"></a> +<span class="sourceLineNo">135</span> String server = this.hostnameAndPort.get(i);<a name="line.135"></a> +<span class="sourceLineNo">136</span> pw.append("exception");<a name="line.136"></a> +<span class="sourceLineNo">137</span> if (this.exceptions.size() > 1) {<a name="line.137"></a> +<span class="sourceLineNo">138</span> pw.append(" #" + i);<a name="line.138"></a> +<span class="sourceLineNo">139</span> }<a name="line.139"></a> +<span class="sourceLineNo">140</span> pw.append(" from " + server + " for "<a name="line.140"></a> +<span class="sourceLineNo">141</span> + ((action == null) ? "unknown key" : Bytes.toStringBinary(action.getRow())));<a name="line.141"></a> +<span class="sourceLineNo">142</span> if (t != null) {<a name="line.142"></a> +<span class="sourceLineNo">143</span> pw.println();<a name="line.143"></a> +<span class="sourceLineNo">144</span> t.printStackTrace(pw);<a name="line.144"></a> +<span class="sourceLineNo">145</span> }<a name="line.145"></a> +<span class="sourceLineNo">146</span> }<a name="line.146"></a> +<span class="sourceLineNo">147</span> pw.flush();<a name="line.147"></a> +<span class="sourceLineNo">148</span> return errorWriter.toString();<a name="line.148"></a> +<span class="sourceLineNo">149</span> }<a name="line.149"></a> +<span class="sourceLineNo">150</span><a name="line.150"></a> +<span class="sourceLineNo">151</span><a name="line.151"></a> +<span class="sourceLineNo">152</span> public static Map<String, Integer> classifyExs(List<Throwable> ths) {<a name="line.152"></a> +<span class="sourceLineNo">153</span> Map<String, Integer> cls = new HashMap<>();<a name="line.153"></a> +<span class="sourceLineNo">154</span> for (Throwable t : ths) {<a name="line.154"></a> +<span class="sourceLineNo">155</span> if (t == null) continue;<a name="line.155"></a> +<span class="sourceLineNo">156</span> String name = "";<a name="line.156"></a> +<span class="sourceLineNo">157</span> if (t instanceof DoNotRetryIOException) {<a name="line.157"></a> +<span class="sourceLineNo">158</span> name = t.getMessage();<a name="line.158"></a> +<span class="sourceLineNo">159</span> } else {<a name="line.159"></a> +<span class="sourceLineNo">160</span> name = t.getClass().getSimpleName();<a name="line.160"></a> +<span class="sourceLineNo">161</span> }<a name="line.161"></a> +<span class="sourceLineNo">162</span> Integer i = cls.get(name);<a name="line.162"></a> +<span class="sourceLineNo">163</span> if (i == null) {<a name="line.163"></a> +<span class="sourceLineNo">164</span> i = 0;<a name="line.164"></a> +<span class="sourceLineNo">165</span> }<a name="line.165"></a> +<span class="sourceLineNo">166</span> i += 1;<a name="line.166"></a> +<span class="sourceLineNo">167</span> cls.put(name, i);<a name="line.167"></a> +<span class="sourceLineNo">168</span> }<a name="line.168"></a> +<span class="sourceLineNo">169</span> return cls;<a name="line.169"></a> +<span class="sourceLineNo">170</span> }<a name="line.170"></a> +<span class="sourceLineNo">171</span><a name="line.171"></a> +<span class="sourceLineNo">172</span> public static String getDesc(Map<String,Integer> classificaton) {<a name="line.172"></a> +<span class="sourceLineNo">173</span> StringBuilder classificatons =new StringBuilder(11);<a name="line.173"></a> +<span class="sourceLineNo">174</span> for (Map.Entry<String, Integer> e : classificaton.entrySet()) {<a name="line.174"></a> +<span class="sourceLineNo">175</span> classificatons.append(e.getKey());<a name="line.175"></a> +<span class="sourceLineNo">176</span> classificatons.append(": ");<a name="line.176"></a> +<span class="sourceLineNo">177</span> classificatons.append(e.getValue());<a name="line.177"></a> +<span class="sourceLineNo">178</span> classificatons.append(" time");<a name="line.178"></a> +<span class="sourceLineNo">179</span> classificatons.append(pluralize(e.getValue()));<a name="line.179"></a> +<span class="sourceLineNo">180</span> classificatons.append(", ");<a name="line.180"></a> +<span class="sourceLineNo">181</span> }<a name="line.181"></a> +<span class="sourceLineNo">182</span> return classificatons.toString();<a name="line.182"></a> +<span class="sourceLineNo">183</span> }<a name="line.183"></a> +<span class="sourceLineNo">184</span><a name="line.184"></a> +<span class="sourceLineNo">185</span>}<a name="line.185"></a>
