[1/3] hbase git commit: HBASE-16639 TestProcedureInMemoryChore#testChoreAddAndRemove occasionally fails
Repository: hbase Updated Branches: refs/heads/branch-1 76a076026 -> 08e44919c refs/heads/master e782d0bbd -> e19632a19 HBASE-16639 TestProcedureInMemoryChore#testChoreAddAndRemove occasionally fails Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/216e8473 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/216e8473 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/216e8473 Branch: refs/heads/master Commit: 216e8473668c1a2f5cfb5c5bf05284d4274c8548 Parents: e782d0b Author: Matteo BertozziAuthored: Thu Sep 15 18:25:11 2016 -0700 Committer: Matteo Bertozzi Committed: Thu Sep 15 18:25:11 2016 -0700 -- .../apache/hadoop/hbase/procedure2/Procedure.java | 7 +++ .../hbase/procedure2/ProcedureExecutor.java | 18 +++--- .../procedure2/TestProcedureInMemoryChore.java| 5 - 3 files changed, 22 insertions(+), 8 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/216e8473/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/Procedure.java -- diff --git a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/Procedure.java b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/Procedure.java index b401871..b9145e7 100644 --- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/Procedure.java +++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/Procedure.java @@ -333,6 +333,13 @@ public abstract class Procedure implements Comparable { } /** + * @return true if the procedure is in a RUNNABLE state. + */ + protected synchronized boolean isRunnable() { +return state == ProcedureState.RUNNABLE; + } + + /** * @return true if the procedure has failed. * true may mean failed but not yet rolledback or failed and rolledback. */ http://git-wip-us.apache.org/repos/asf/hbase/blob/216e8473/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java -- diff --git a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java index 1a9010d..5066fb4 100644 --- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java +++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java @@ -609,15 +609,17 @@ public class ProcedureExecutor { * @param chore the chore to add */ public void addChore(final ProcedureInMemoryChore chore) { +chore.setState(ProcedureState.RUNNABLE); waitingTimeout.add(chore); } /** * Remove a chore procedure from the executor * @param chore the chore to remove - * @return whether the chore is removed + * @return whether the chore is removed, or it will be removed later */ public boolean removeChore(final ProcedureInMemoryChore chore) { +chore.setState(ProcedureState.FINISHED); return waitingTimeout.remove(chore); } @@ -907,13 +909,15 @@ public class ProcedureExecutor { // instead of bringing the Chore class in, we reuse this timeout thread for // this special case. if (proc instanceof ProcedureInMemoryChore) { -try { - ((ProcedureInMemoryChore)proc).periodicExecute(getEnvironment()); -} catch (Throwable e) { - LOG.error("Ignoring CompletedProcedureCleaner exception: " + e.getMessage(), e); +if (proc.isRunnable()) { + try { +((ProcedureInMemoryChore)proc).periodicExecute(getEnvironment()); + } catch (Throwable e) { +LOG.error("Ignoring CompletedProcedureCleaner exception: " + e.getMessage(), e); + } + proc.setStartTime(EnvironmentEdgeManager.currentTime()); + if (proc.isRunnable()) waitingTimeout.add(proc); } -proc.setStartTime(EnvironmentEdgeManager.currentTime()); -waitingTimeout.add(proc); continue; } http://git-wip-us.apache.org/repos/asf/hbase/blob/216e8473/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/TestProcedureInMemoryChore.java -- diff --git a/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/TestProcedureInMemoryChore.java b/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/TestProcedureInMemoryChore.java index 32e3e8c..8bc8fa8 100644 --- a/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/TestProcedureInMemoryChore.java +++
[09/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/HTable.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/HTable.html b/devapidocs/org/apache/hadoop/hbase/client/HTable.html index b24068e..48b0a8e 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/HTable.html +++ b/devapidocs/org/apache/hadoop/hbase/client/HTable.html @@ -115,7 +115,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private @InterfaceStability.Stable -public class HTable +public class HTable extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements Table An implementation of Table. Used to communicate with a single HBase table. @@ -752,7 +752,7 @@ implements LOG -private static finalorg.apache.commons.logging.Log LOG +private static finalorg.apache.commons.logging.Log LOG @@ -761,7 +761,7 @@ implements connection -protectedClusterConnection connection +protectedClusterConnection connection @@ -770,7 +770,7 @@ implements tableName -private finalTableName tableName +private finalTableName tableName @@ -779,7 +779,7 @@ implements configuration -private volatileorg.apache.hadoop.conf.Configuration configuration +private volatileorg.apache.hadoop.conf.Configuration configuration @@ -788,7 +788,7 @@ implements connConfiguration -privateConnectionConfiguration connConfiguration +privateConnectionConfiguration connConfiguration @@ -797,7 +797,7 @@ implements mutator -protectedBufferedMutatorImpl mutator +protectedBufferedMutatorImpl mutator @@ -806,7 +806,7 @@ implements closed -privateboolean closed +privateboolean closed @@ -815,7 +815,7 @@ implements scannerCaching -protectedint scannerCaching +protectedint scannerCaching @@ -824,7 +824,7 @@ implements scannerMaxResultSize -protectedlong scannerMaxResultSize +protectedlong scannerMaxResultSize @@ -833,7 +833,7 @@ implements pool -privatehttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true; title="class or interface in java.util.concurrent">ExecutorService pool +privatehttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true; title="class or interface in java.util.concurrent">ExecutorService pool @@ -842,7 +842,7 @@ implements operationTimeout -privateint operationTimeout +privateint operationTimeout @@ -851,7 +851,7 @@ implements readRpcTimeout -privateint readRpcTimeout +privateint readRpcTimeout @@ -860,7 +860,7 @@ implements writeRpcTimeout -privateint writeRpcTimeout +privateint writeRpcTimeout @@ -869,7 +869,7 @@ implements cleanupPoolOnClose -private finalboolean cleanupPoolOnClose +private finalboolean cleanupPoolOnClose @@ -878,7 +878,7 @@ implements cleanupConnectionOnClose -private finalboolean cleanupConnectionOnClose +private finalboolean cleanupConnectionOnClose @@ -887,7 +887,7 @@ implements defaultConsistency -privateConsistency defaultConsistency +privateConsistency defaultConsistency @@ -896,7 +896,7 @@ implements locator -privateHRegionLocator locator +privateHRegionLocator locator @@ -905,7 +905,7 @@ implements multiAp -protectedAsyncProcess multiAp +protectedAsyncProcess multiAp The Async process for batch @@ -915,7 +915,7 @@ implements rpcCallerFactory -privateRpcRetryingCallerFactory rpcCallerFactory +privateRpcRetryingCallerFactory rpcCallerFactory @@ -924,7 +924,7 @@ implements rpcControllerFactory -privateRpcControllerFactory rpcControllerFactory +privateRpcControllerFactory rpcControllerFactory @@ -942,7 +942,7 @@ implements HTable @InterfaceAudience.Private -protectedHTable(TableNametableName, +protectedHTable(TableNametableName, ClusterConnectionconnection, ConnectionConfigurationtableConfig, RpcRetryingCallerFactoryrpcCallerFactory, @@ -968,7 +968,7 @@ protected HTable -protectedHTable(ClusterConnectionconn, +protectedHTable(ClusterConnectionconn, BufferedMutatorParamsparams) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException For internal testing. Uses Connection provided in params. @@ -993,7 +993,7 @@ protected getDefaultExecutor @InterfaceAudience.Private -public statichttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.html?is-external=true; title="class or interface in java.util.concurrent">ThreadPoolExecutorgetDefaultExecutor(org.apache.hadoop.conf.Configurationconf) +public
[30/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/HConstants.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/HConstants.html b/devapidocs/org/apache/hadoop/hbase/HConstants.html index c0b70de..e6652c7 100644 --- a/devapidocs/org/apache/hadoop/hbase/HConstants.html +++ b/devapidocs/org/apache/hadoop/hbase/HConstants.html @@ -431,439 +431,451 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? static int +DEFAULT_HBASE_CLIENT_PERSERVER_REQUESTS_THRESHOLD +Default value of HBASE_CLIENT_PERSERVER_REQUESTS_THRESHOLD. + + + +static int DEFAULT_HBASE_CLIENT_RETRIES_NUMBER Default value of HBASE_CLIENT_RETRIES_NUMBER. - + static int DEFAULT_HBASE_CLIENT_SCANNER_CACHING Default value for HBASE_CLIENT_SCANNER_CACHING - + static long DEFAULT_HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE Maximum number of bytes returned when calling a scanner's next method. - + static int DEFAULT_HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD Default value of HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD. - + static int DEFAULT_HBASE_META_BLOCK_SIZE Default value of HBASE_META_BLOCK_SIZE. - + static int DEFAULT_HBASE_META_SCANNER_CACHING Default value of HBASE_META_SCANNER_CACHING. - + static int DEFAULT_HBASE_META_VERSIONS Default value of HBASE_META_VERSIONS. - + static int DEFAULT_HBASE_RPC_SHORTOPERATION_TIMEOUT Default value of HBASE_RPC_SHORTOPERATION_TIMEOUT_KEY - + static int DEFAULT_HBASE_RPC_TIMEOUT Default value of HBASE_RPC_TIMEOUT_KEY - + static int DEFAULT_HBASE_SERVER_PAUSE Default value of HBASE_SERVER_PAUSE. - + static long DEFAULT_HBASE_SERVER_SCANNER_MAX_RESULT_SIZE Maximum number of bytes returned when calling a scanner's next method. - + static int DEFAULT_HEALTH_FAILURE_THRESHOLD - + static long DEFAULT_HEALTH_SCRIPT_TIMEOUT - + static float DEFAULT_HEAP_OCCUPANCY_HIGH_WATERMARK - + static float DEFAULT_HEAP_OCCUPANCY_LOW_WATERMARK - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_HOST default host address - + static boolean DEFAULT_HREGION_EDITS_REPLAY_SKIP_ERRORS - + static int DEFAULT_HREGION_MEMSTORE_BLOCK_MULTIPLIER Default value for hbase.hregion.memstore.block.multiplier - + static int DEFAULT_HSTORE_OPEN_AND_CLOSE_THREADS_MAX The default number for the max number of threads used for opening and closing stores or store files in parallel - + static int DEFAULT_MASTER_HANLDER_COUNT - + static int DEFAULT_MASTER_INFOPORT default port for master web api - + static int DEFAULT_MASTER_PORT default port that the master listens on - + static boolean DEFAULT_MASTER_TYPE_BACKUP by default every master is a possible primary master unless the conf explicitly overrides it - + static long DEFAULT_MAX_FILE_SIZE Default maximum file size - + static int DEFAULT_META_REPLICA_NUM - + static double DEFAULT_REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT - + static int DEFAULT_REGION_SERVER_HANDLER_COUNT - + static int DEFAULT_REGION_SERVER_HIGH_PRIORITY_HANDLER_COUNT - + static int DEFAULT_REGION_SERVER_REPLICATION_HANDLER_COUNT - + static int DEFAULT_REGIONSERVER_INFOPORT default port for region server web api - + static long DEFAULT_REGIONSERVER_METRICS_PERIOD - + static int DEFAULT_REGIONSERVER_PORT Default port region server listens on. - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_STATUS_MULTICAST_ADDRESS - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_STATUS_MULTICAST_BIND_ADDRESS - + static int DEFAULT_STATUS_MULTICAST_PORT - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_TEMPORARY_HDFS_DIRECTORY - + static int DEFAULT_THREAD_WAKE_FREQUENCY Default value for thread wake frequency - + static boolean DEFAULT_USE_META_REPLICAS - + static int DEFAULT_VERSION_FILE_WRITE_ATTEMPTS Parameter name for how often we should try to write a version file, before failing - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_WAL_STORAGE_POLICY - + static int DEFAULT_ZK_SESSION_TIMEOUT Default value for ZooKeeper session timeout - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_ZOOKEEPER_ZNODE_PARENT - + static int DEFAULT_ZOOKEPER_CLIENT_PORT Default client port that the zookeeper listens on
[48/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/HConstants.html -- diff --git a/apidocs/org/apache/hadoop/hbase/HConstants.html b/apidocs/org/apache/hadoop/hbase/HConstants.html index c094e0e..e29802c 100644 --- a/apidocs/org/apache/hadoop/hbase/HConstants.html +++ b/apidocs/org/apache/hadoop/hbase/HConstants.html @@ -404,439 +404,451 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? static int +DEFAULT_HBASE_CLIENT_PERSERVER_REQUESTS_THRESHOLD +Default value of HBASE_CLIENT_PERSERVER_REQUESTS_THRESHOLD. + + + +static int DEFAULT_HBASE_CLIENT_RETRIES_NUMBER Default value of HBASE_CLIENT_RETRIES_NUMBER. - + static int DEFAULT_HBASE_CLIENT_SCANNER_CACHING Default value for HBASE_CLIENT_SCANNER_CACHING - + static long DEFAULT_HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE Maximum number of bytes returned when calling a scanner's next method. - + static int DEFAULT_HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD Default value of HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD. - + static int DEFAULT_HBASE_META_BLOCK_SIZE Default value of HBASE_META_BLOCK_SIZE. - + static int DEFAULT_HBASE_META_SCANNER_CACHING Default value of HBASE_META_SCANNER_CACHING. - + static int DEFAULT_HBASE_META_VERSIONS Default value of HBASE_META_VERSIONS. - + static int DEFAULT_HBASE_RPC_SHORTOPERATION_TIMEOUT Default value of HBASE_RPC_SHORTOPERATION_TIMEOUT_KEY - + static int DEFAULT_HBASE_RPC_TIMEOUT Default value of HBASE_RPC_TIMEOUT_KEY - + static int DEFAULT_HBASE_SERVER_PAUSE Default value of HBASE_SERVER_PAUSE. - + static long DEFAULT_HBASE_SERVER_SCANNER_MAX_RESULT_SIZE Maximum number of bytes returned when calling a scanner's next method. - + static int DEFAULT_HEALTH_FAILURE_THRESHOLD - + static long DEFAULT_HEALTH_SCRIPT_TIMEOUT - + static float DEFAULT_HEAP_OCCUPANCY_HIGH_WATERMARK - + static float DEFAULT_HEAP_OCCUPANCY_LOW_WATERMARK - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_HOST default host address - + static boolean DEFAULT_HREGION_EDITS_REPLAY_SKIP_ERRORS - + static int DEFAULT_HREGION_MEMSTORE_BLOCK_MULTIPLIER Default value for hbase.hregion.memstore.block.multiplier - + static int DEFAULT_HSTORE_OPEN_AND_CLOSE_THREADS_MAX The default number for the max number of threads used for opening and closing stores or store files in parallel - + static int DEFAULT_MASTER_HANLDER_COUNT - + static int DEFAULT_MASTER_INFOPORT default port for master web api - + static int DEFAULT_MASTER_PORT default port that the master listens on - + static boolean DEFAULT_MASTER_TYPE_BACKUP by default every master is a possible primary master unless the conf explicitly overrides it - + static long DEFAULT_MAX_FILE_SIZE Default maximum file size - + static int DEFAULT_META_REPLICA_NUM - + static double DEFAULT_REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT - + static int DEFAULT_REGION_SERVER_HANDLER_COUNT - + static int DEFAULT_REGION_SERVER_HIGH_PRIORITY_HANDLER_COUNT - + static int DEFAULT_REGION_SERVER_REPLICATION_HANDLER_COUNT - + static int DEFAULT_REGIONSERVER_INFOPORT default port for region server web api - + static long DEFAULT_REGIONSERVER_METRICS_PERIOD - + static int DEFAULT_REGIONSERVER_PORT Default port region server listens on. - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_STATUS_MULTICAST_ADDRESS - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_STATUS_MULTICAST_BIND_ADDRESS - + static int DEFAULT_STATUS_MULTICAST_PORT - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_TEMPORARY_HDFS_DIRECTORY - + static int DEFAULT_THREAD_WAKE_FREQUENCY Default value for thread wake frequency - + static boolean DEFAULT_USE_META_REPLICAS - + static int DEFAULT_VERSION_FILE_WRITE_ATTEMPTS Parameter name for how often we should try to write a version file, before failing - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_WAL_STORAGE_POLICY - + static int DEFAULT_ZK_SESSION_TIMEOUT Default value for ZooKeeper session timeout - + static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_ZOOKEEPER_ZNODE_PARENT - + static int DEFAULT_ZOOKEPER_CLIENT_PORT Default client port that the zookeeper listens on - + static
[33/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/deprecated-list.html -- diff --git a/devapidocs/deprecated-list.html b/devapidocs/deprecated-list.html index dafaca7..433a1d7 100644 --- a/devapidocs/deprecated-list.html +++ b/devapidocs/deprecated-list.html @@ -413,13 +413,13 @@ org.apache.hadoop.hbase.mapreduce.CellCreator.create(byte[], int, int, byte[], int, int, byte[], int, int, long, byte[], int, int, String) -org.apache.hadoop.hbase.regionserver.RpcSchedulerFactory.create(Configuration, PriorityFunction) +org.apache.hadoop.hbase.regionserver.FifoRpcSchedulerFactory.create(Configuration, PriorityFunction) -org.apache.hadoop.hbase.regionserver.SimpleRpcSchedulerFactory.create(Configuration, PriorityFunction) +org.apache.hadoop.hbase.regionserver.RpcSchedulerFactory.create(Configuration, PriorityFunction) -org.apache.hadoop.hbase.regionserver.FifoRpcSchedulerFactory.create(Configuration, PriorityFunction) +org.apache.hadoop.hbase.regionserver.SimpleRpcSchedulerFactory.create(Configuration, PriorityFunction) org.apache.hadoop.hbase.coprocessor.ObserverContext.createAndPrepare(T, ObserverContextT) @@ -447,13 +447,13 @@ org.apache.hadoop.hbase.KeyValueUtil.ensureKeyValues(ListCell) -org.apache.hadoop.hbase.regionserver.SplitTransaction.execute(Server, RegionServerServices) -use #execute(Server, RegionServerServices, User); as of 1.0.2, remove in 3.0 +org.apache.hadoop.hbase.regionserver.RegionMergeTransaction.execute(Server, RegionServerServices) +use #execute(Server, RegionServerServices, User) -org.apache.hadoop.hbase.regionserver.RegionMergeTransaction.execute(Server, RegionServerServices) -use #execute(Server, RegionServerServices, User) +org.apache.hadoop.hbase.regionserver.SplitTransaction.execute(Server, RegionServerServices) +use #execute(Server, RegionServerServices, User); as of 1.0.2, remove in 3.0 @@ -465,15 +465,15 @@ org.apache.hadoop.hbase.rest.client.RemoteHTable.exists(ListGet) -org.apache.hadoop.hbase.filter.FilterBase.filterRowKey(byte[], int, int) +org.apache.hadoop.hbase.filter.Filter.filterRowKey(byte[], int, int) As of release 2.0.0, this will be removed in HBase 3.0.0. - Instead use FilterBase.filterRowKey(Cell) + Instead use Filter.filterRowKey(Cell) -org.apache.hadoop.hbase.filter.Filter.filterRowKey(byte[], int, int) +org.apache.hadoop.hbase.filter.FilterBase.filterRowKey(byte[], int, int) As of release 2.0.0, this will be removed in HBase 3.0.0. - Instead use Filter.filterRowKey(Cell) + Instead use FilterBase.filterRowKey(Cell) @@ -570,10 +570,10 @@ -org.apache.hadoop.hbase.http.InfoServer.getPort() +org.apache.hadoop.hbase.http.HttpServer.getPort() -org.apache.hadoop.hbase.http.HttpServer.getPort() +org.apache.hadoop.hbase.http.InfoServer.getPort() org.apache.hadoop.hbase.CellUtil.getQualifierBufferShallowCopy(Cell) @@ -607,13 +607,13 @@ -org.apache.hadoop.hbase.client.HTable.getRpcTimeout() - - org.apache.hadoop.hbase.client.Table.getRpcTimeout() Use getReadRpcTimeout or getWriteRpcTimeout instead + +org.apache.hadoop.hbase.client.HTable.getRpcTimeout() + org.apache.hadoop.hbase.client.HTableWrapper.getRpcTimeout() @@ -643,13 +643,13 @@ -org.apache.hadoop.hbase.io.ImmutableBytesWritable.getSize() -use ImmutableBytesWritable.getLength() instead +org.apache.hadoop.hbase.util.Bytes.getSize() +use Bytes.getLength() instead -org.apache.hadoop.hbase.util.Bytes.getSize() -use Bytes.getLength() instead +org.apache.hadoop.hbase.io.ImmutableBytesWritable.getSize() +use ImmutableBytesWritable.getLength() instead @@ -780,16 +780,6 @@ -org.apache.hadoop.hbase.coprocessor.BaseMasterAndRegionObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironment, TableName, HColumnDescriptor) - - -org.apache.hadoop.hbase.coprocessor.BaseMasterObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironment, TableName, HColumnDescriptor) -As of release 2.0.0, this will be removed in HBase 3.0.0 - (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). - Use BaseMasterObserver.postAddColumnFamily(ObserverContext, TableName, HColumnDescriptor). - - - org.apache.hadoop.hbase.coprocessor.MasterObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironment, TableName, HColumnDescriptor) As of release 2.0.0, this will be removed in HBase 3.0.0 (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). @@ -797,13 +787,13 @@ -org.apache.hadoop.hbase.coprocessor.BaseMasterAndRegionObserver.postAddColumnHandler(ObserverContextMasterCoprocessorEnvironment, TableName, HColumnDescriptor) +org.apache.hadoop.hbase.coprocessor.BaseMasterAndRegionObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironment, TableName, HColumnDescriptor)
[31/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/DoNotRetryIOException.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/DoNotRetryIOException.html b/devapidocs/org/apache/hadoop/hbase/DoNotRetryIOException.html index 14c6279..de594cf 100644 --- a/devapidocs/org/apache/hadoop/hbase/DoNotRetryIOException.html +++ b/devapidocs/org/apache/hadoop/hbase/DoNotRetryIOException.html @@ -127,7 +127,7 @@ Direct Known Subclasses: -AccessDeniedException, ConstraintException, CoprocessorException, CorruptHFileException, DoNotRetryRegionException, FailedSanityCheckException, FatalConnectionException, HBaseSnapshotException, InvalidFamilyOperationException, InvalidLabelException, InvalidQuotaSettingsException, LabelAlreadyExistsExcepti on, LeaseException, LockTimeoutException, NamespaceExistException, NamespaceNotFoundException, NoSuchColumnFamilyException, NotAllMetaRegionsOnlineException, OperationConflictException, OutOfOrderScannerNextException, QuotaExceededException, ScannerTimeoutException, TableExistsException, TableNotDisabledException, TableNotEnabledException, TableNotFoundException, UnknownProtocolException, UnknownScannerException +AccessDeniedException, ConstraintException, CoprocessorException, CorruptHFileException, DoNotRetryRegionException, FailedSanityCheckException, FatalConnectionException, HBaseSnapshotException, InvalidFamilyOperationException, InvalidLabelException, InvalidQuotaSettingsException, LabelAlreadyExistsExcepti on, LeaseException, LockTimeoutException, NamespaceExistException, NamespaceNotFoundException, NoSuchColumnFamilyException, NotAllMetaRegionsOnlineException, OperationConflictException, OutOfOrderScannerNextException, QuotaExceededException, ScannerTimeoutException, ServerTooBusyException, TableExistsException, TableNotDisabledException, TableNotEnabledException, TableNotFoundException, UnknownProtocolException, UnknownScannerException
[12/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowCheckerHost.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowCheckerHost.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowCheckerHost.html index 689c364..74bd370 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowCheckerHost.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowCheckerHost.html @@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab"; -static class AsyncProcess.RowCheckerHost +static class AsyncProcess.RowCheckerHost extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object Collect all advices from checkers and make the final decision. @@ -211,7 +211,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? checkers -private finalhttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListAsyncProcess.RowChecker checkers +private finalhttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListAsyncProcess.RowChecker checkers @@ -220,7 +220,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? isEnd -privateboolean isEnd +privateboolean isEnd @@ -237,7 +237,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? RowCheckerHost -RowCheckerHost(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListAsyncProcess.RowCheckercheckers) +RowCheckerHost(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListAsyncProcess.RowCheckercheckers) @@ -254,7 +254,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? reset -voidreset() +voidreset() throws http://docs.oracle.com/javase/8/docs/api/java/io/InterruptedIOException.html?is-external=true; title="class or interface in java.io">InterruptedIOException Throws: @@ -268,7 +268,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? canTakeOperation -AsyncProcess.RowChecker.ReturnCodecanTakeOperation(HRegionLocationloc, +AsyncProcess.RowChecker.ReturnCodecanTakeOperation(HRegionLocationloc, longrowSize) http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.SubmittedSizeChecker.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.SubmittedSizeChecker.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.SubmittedSizeChecker.html index a0931a3..ac1783b 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.SubmittedSizeChecker.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.SubmittedSizeChecker.html @@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab"; -static class AsyncProcess.SubmittedSizeChecker +static class AsyncProcess.SubmittedSizeChecker extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements AsyncProcess.RowChecker limit the heapsize of total submitted data. @@ -243,7 +243,7 @@ implements maxHeapSizeSubmit -private finallong maxHeapSizeSubmit +private finallong maxHeapSizeSubmit @@ -252,7 +252,7 @@ implements heapSize -privatelong heapSize +privatelong heapSize @@ -269,7 +269,7 @@ implements SubmittedSizeChecker -SubmittedSizeChecker(longmaxHeapSizeSubmit) +SubmittedSizeChecker(longmaxHeapSizeSubmit) @@ -286,7 +286,7 @@ implements canTakeOperation -publicAsyncProcess.RowChecker.ReturnCodecanTakeOperation(HRegionLocationloc, +publicAsyncProcess.RowChecker.ReturnCodecanTakeOperation(HRegionLocationloc, longrowSize) Specified by: @@ -300,7 +300,7 @@ implements notifyFinal -publicvoidnotifyFinal(AsyncProcess.RowChecker.ReturnCodecode, +publicvoidnotifyFinal(AsyncProcess.RowChecker.ReturnCodecode, HRegionLocationloc, longrowSize) Description copied from interface:AsyncProcess.RowChecker @@ -319,7 +319,7 @@ implements reset -publicvoidreset() +publicvoidreset() Description copied from interface:AsyncProcess.RowChecker Reset the inner state. http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.TaskCountChecker.html -- diff --git
[50/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apache_hbase_reference_guide.pdf -- diff --git a/apache_hbase_reference_guide.pdf b/apache_hbase_reference_guide.pdf index 0d629da..80f6965 100644 --- a/apache_hbase_reference_guide.pdf +++ b/apache_hbase_reference_guide.pdf @@ -5,24 +5,24 @@ /Author (Apache HBase Team) /Creator (Asciidoctor PDF 1.5.0.alpha.6, based on Prawn 1.2.1) /Producer (Apache HBase Team) -/CreationDate (D:20160912180900+00'00') -/ModDate (D:20160912180900+00'00') +/CreationDate (D:20160915144015+00'00') +/ModDate (D:20160915144015+00'00') >> endobj 2 0 obj << /Type /Catalog /Pages 3 0 R /Names 25 0 R -/Outlines 4009 0 R -/PageLabels 4213 0 R +/Outlines 4013 0 R +/PageLabels 4217 0 R /PageMode /UseOutlines /ViewerPreferences [/FitWindow] >> endobj 3 0 obj << /Type /Pages -/Count 667 -/Kids [7 0 R 13 0 R 15 0 R 17 0 R 19 0 R 21 0 R 23 0 R 39 0 R 43 0 R 47 0 R 58 0 R 62 0 R 64 0 R 66 0 R 68 0 R 75 0 R 78 0 R 80 0 R 85 0 R 88 0 R 90 0 R 92 0 R 101 0 R 107 0 R 112 0 R 114 0 R 135 0 R 141 0 R 148 0 R 150 0 R 154 0 R 157 0 R 167 0 R 174 0 R 190 0 R 194 0 R 198 0 R 200 0 R 204 0 R 210 0 R 212 0 R 214 0 R 216 0 R 218 0 R 221 0 R 227 0 R 229 0 R 231 0 R 233 0 R 235 0 R 237 0 R 239 0 R 241 0 R 245 0 R 249 0 R 251 0 R 253 0 R 255 0 R 257 0 R 259 0 R 261 0 R 263 0 R 269 0 R 272 0 R 274 0 R 276 0 R 278 0 R 283 0 R 287 0 R 290 0 R 295 0 R 298 0 R 302 0 R 317 0 R 327 0 R 333 0 R 344 0 R 354 0 R 359 0 R 361 0 R 363 0 R 374 0 R 379 0 R 383 0 R 388 0 R 392 0 R 403 0 R 415 0 R 430 0 R 436 0 R 438 0 R 440 0 R 447 0 R 458 0 R 469 0 R 480 0 R 483 0 R 486 0 R 490 0 R 494 0 R 497 0 R 500 0 R 502 0 R 505 0 R 509 0 R 511 0 R 515 0 R 519 0 R 525 0 R 529 0 R 531 0 R 537 0 R 539 0 R 543 0 R 551 0 R 553 0 R 556 0 R 559 0 R 562 0 R 565 0 R 580 0 R 587 0 R 594 0 R 605 0 R 612 0 R 621 0 R 629 0 R 632 0 R 636 0 R 639 0 R 651 0 R 659 0 R 665 0 R 670 0 R 674 0 R 676 0 R 690 0 R 702 0 R 708 0 R 714 0 R 717 0 R 725 0 R 733 0 R 738 0 R 743 0 R 749 0 R 751 0 R 753 0 R 755 0 R 763 0 R 772 0 R 776 0 R 783 0 R 791 0 R 797 0 R 801 0 R 808 0 R 812 0 R 817 0 R 825 0 R 827 0 R 831 0 R 842 0 R 847 0 R 849 0 R 852 0 R 856 0 R 862 0 R 865 0 R 877 0 R 881 0 R 886 0 R 894 0 R 899 0 R 903 0 R 907 0 R 909 0 R 912 0 R 914 0 R 918 0 R 920 0 R 923 0 R 928 0 R 932 0 R 937 0 R 941 0 R 944 0 R 946 0 R 953 0 R 957 0 R 962 0 R 975 0 R 979 0 R 983 0 R 988 0 R 990 0 R 999 0 R 1002 0 R 1007 0 R 1010 0 R 1019 0 R 1022 0 R 1028 0 R 1035 0 R 1038 0 R 1040 0 R 1049 0 R 1051 0 R 1053 0 R 1056 0 R 1058 0 R 1060 0 R 1062 0 R 1064 0 R 1066 0 R 1069 0 R 1072 0 R 1077 0 R 1080 0 R 1082 0 R 1084 0 R 1086 0 R 1091 0 R 1100 0 R 1103 0 R 1105 0 R 1107 0 R 1112 0 R 1114 0 R 1117 0 R 1119 0 R 1121 0 R 1123 0 R 1126 0 R 1131 0 R 1137 0 R 1144 0 R 1149 0 R 1163 0 R 1174 0 R 1178 0 R 1191 0 R 1200 0 R 1216 0 R 1220 0 R 12 30 0 R 1243 0 R 1246 0 R 1258 0 R 1267 0 R 1275 0 R 1279 0 R 1288 0 R 1293 0 R 1297 0 R 1303 0 R 1309 0 R 1316 0 R 1324 0 R 1326 0 R 1338 0 R 1340 0 R 1345 0 R 1349 0 R 1354 0 R 1364 0 R 1370 0 R 1376 0 R 1378 0 R 1380 0 R 1392 0 R 1399 0 R 1408 0 R 1414 0 R 1428 0 R 1436 0 R 1440 0 R 1449 0 R 1457 0 R 1465 0 R 1471 0 R 1475 0 R 1478 0 R 1480 0 R 1489 0 R 1492 0 R 1499 0 R 1503 0 R 1506 0 R 1514 0 R 1518 0 R 1521 0 R 1523 0 R 1532 0 R 1539 0 R 1545 0 R 1550 0 R 1554 0 R 1557 0 R 1563 0 R 1568 0 R 1573 0 R 1575 0 R 1577 0 R 1580 0 R 1582 0 R 1591 0 R 1594 0 R 1600 0 R 1607 0 R 1611 0 R 1617 0 R 1620 0 R 1622 0 R 1627 0 R 1630 0 R 1632 0 R 1634 0 R 1636 0 R 1643 0 R 1653 0 R 1655 0 R 1657 0 R 1659 0 R 1661 0 R 1665 0 R 1667 0 R 1669 0 R 1671 0 R 1674 0 R 1676 0 R 1678 0 R 1680 0 R 1684 0 R 1688 0 R 1697 0 R 1699 0 R 1701 0 R 1703 0 R 1705 0 R 1711 0 R 1713 0 R 1718 0 R 1720 0 R 1722 0 R 1729 0 R 1734 0 R 1738 0 R 1742 0 R 1745 0 R 1748 0 R 1753 0 R 1755 0 R 1758 0 R 1760 0 R 1762 0 R 1764 0 R 1768 0 R 1770 0 R 1774 0 R 1776 0 R 1778 0 R 1780 0 R 1782 0 R 1789 0 R 1792 0 R 1797 0 R 1799 0 R 1801 0 R 1803 0 R 1805 0 R 1813 0 R 1823 0 R 1826 0 R 1842 0 R 1857 0 R 1861 0 R 1866 0 R 1870 0 R 1873 0 R 1878 0 R 1880 0 R 1887 0 R 1889 0 R 1892 0 R 1894 0 R 1896 0 R 1898 0 R 1900 0 R 1904 0 R 1906 0 R 1914 0 R 1922 0 R 1928 0 R 1939 0 R 1953 0 R 1965 0 R 1984 0 R 1986 0 R 1988 0 R 1992 0 R 2009 0 R 2017 0 R 2024 0 R 2033 0 R 2037 0 R 2047 0 R 2058 0 R 2064 0 R 2073 0 R 2086 0 R 2103 0 R 2113 0 R 2116 0 R 2125 0 R 2140 0 R 2147 0 R 2150 0 R 2155 0 R 2160 0 R 2170 0 R 2178 0 R 2181 0 R 2183 0 R 2187 0 R 2200 0 R 2208 0 R 2214 0 R 2218 0 R 2221 0 R 2223 0 R 2225 0 R 2227 0 R 2229 0 R 2234 0 R 2236 0 R 2246 0 R 2256 0 R 2263 0 R 2275 0 R 2280 0 R 2284 0 R 2296 0 R 2303 0 R 2309 0 R 2311 0 R 2322 0 R 2329 0 R 2340 0 R 2344 0 R 2353 0 R 2360 0 R 2370 0 R 2378 0 R 2387 0 R 2393 0 R 2398 0 R 2403 0 R 2406 0 R 2408 0 R 2414 0 R 2418 0 R 2422 0 R 2428 0 R 2435 0 R 2440 0 R 2444 0 R 2453 0 R 2458 0 R 2463 0 R 2476 0 R
[34/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/coc.html -- diff --git a/coc.html b/coc.html index 1a636f7..6e3d020 100644 --- a/coc.html +++ b/coc.html @@ -7,7 +7,7 @@ - + Apache HBase Code of Conduct Policy @@ -331,7 +331,7 @@ For flagrant violations requiring a firm response the PMC may opt to skip early http://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2016-09-12 + Last Published: 2016-09-15 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/cygwin.html -- diff --git a/cygwin.html b/cygwin.html index 968e6b5..d041d6f 100644 --- a/cygwin.html +++ b/cygwin.html @@ -7,7 +7,7 @@ - + Apache HBase Installing Apache HBase (TM) on Windows using Cygwin @@ -673,7 +673,7 @@ Now your HBase server is running, start coding and build that next http://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2016-09-12 + Last Published: 2016-09-15 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/dependencies.html -- diff --git a/dependencies.html b/dependencies.html index c880b22..231c16f 100644 --- a/dependencies.html +++ b/dependencies.html @@ -7,7 +7,7 @@ - + Apache HBase Project Dependencies @@ -518,7 +518,7 @@ http://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2016-09-12 + Last Published: 2016-09-15 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/dependency-convergence.html -- diff --git a/dependency-convergence.html b/dependency-convergence.html index 4f2957e..0d0dff1 100644 --- a/dependency-convergence.html +++ b/dependency-convergence.html @@ -7,7 +7,7 @@ - + Apache HBase Reactor Dependency Convergence @@ -1729,7 +1729,7 @@ http://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2016-09-12 + Last Published: 2016-09-15 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/dependency-info.html -- diff --git a/dependency-info.html b/dependency-info.html index 0bff9f6..976edcb 100644 --- a/dependency-info.html +++ b/dependency-info.html @@ -7,7 +7,7 @@ - + Apache HBase Dependency Information @@ -312,7 +312,7 @@ http://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2016-09-12 + Last Published: 2016-09-15 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/dependency-management.html -- diff --git a/dependency-management.html b/dependency-management.html index 624488b..aec93c5 100644 --- a/dependency-management.html +++ b/dependency-management.html @@ -7,7 +7,7 @@ - + Apache HBase Project Dependency Management @@ -816,7 +816,7 @@ http://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2016-09-12 + Last Published: 2016-09-15 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/allclasses-frame.html -- diff --git a/devapidocs/allclasses-frame.html b/devapidocs/allclasses-frame.html index cb81291..5b7277c 100644 --- a/devapidocs/allclasses-frame.html +++ b/devapidocs/allclasses-frame.html @@ -31,10 +31,14 @@ AbstractPositionedByteRange AbstractProtobufLogWriter AbstractRegionServerCallable +AbstractResponse +AbstractResponse.ResponseType AbstractRpcClient AbstractRpcClient.AbstractRpcChannel AbstractRpcClient.BlockingRpcChannelImplementation AbstractRpcClient.RpcChannelImplementation +AbstractStateMachineNamespaceProcedure
[15/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/AbstractResponse.ResponseType.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AbstractResponse.ResponseType.html b/devapidocs/org/apache/hadoop/hbase/client/AbstractResponse.ResponseType.html new file mode 100644 index 000..aa98682 --- /dev/null +++ b/devapidocs/org/apache/hadoop/hbase/client/AbstractResponse.ResponseType.html @@ -0,0 +1,346 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + + +AbstractResponse.ResponseType (Apache HBase 2.0.0-SNAPSHOT API) + + + + + +var methods = {"i0":9,"i1":9}; +var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],8:["t4","Concrete Methods"]}; +var altColor = "altColor"; +var rowColor = "rowColor"; +var tableTab = "tableTab"; +var activeTableTab = "activeTableTab"; + + +JavaScript is disabled on your browser. + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +PrevClass +NextClass + + +Frames +NoFrames + + +AllClasses + + + + + + + +Summary: +Nested| +Enum Constants| +Field| +Method + + +Detail: +Enum Constants| +Field| +Method + + + + + + + + +org.apache.hadoop.hbase.client +Enum AbstractResponse.ResponseType + + + +http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">java.lang.Object + + +http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">java.lang.EnumAbstractResponse.ResponseType + + +org.apache.hadoop.hbase.client.AbstractResponse.ResponseType + + + + + + + + + +All Implemented Interfaces: +http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable, http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableAbstractResponse.ResponseType + + +Enclosing class: +AbstractResponse + + + +public static enum AbstractResponse.ResponseType +extends http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumAbstractResponse.ResponseType + + + + + + + + + + + +Enum Constant Summary + +Enum Constants + +Enum Constant and Description + + +MULTI + + +SINGLE + + + + + + + + + +Method Summary + +All MethodsStatic MethodsConcrete Methods + +Modifier and Type +Method and Description + + +static AbstractResponse.ResponseType +valueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +Returns the enum constant of this type with the specified name. + + + +static AbstractResponse.ResponseType[] +values() +Returns an array containing the constants of this enum type, in +the order they are declared. + + + + + + + +Methods inherited from classjava.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">Enum +http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true#clone--; title="class or interface in java.lang">clone, http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true#compareTo-E-; title="class or interface in java.lang">compareTo, http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true#equals-java.lang.Object-; title="class or interface in java.lang">equals, http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true#finalize--; title="class or interface in java.lang">finalize, http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true#getDeclaringClass--; title="class or interface in java.lang">getDeclaringClass, http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true#hashCode--; title="class or interface in java.lang">hashCode, http://docs.oracle.com/javase/8/docs/ api/java/lang/Enum.html?is-external=true#name--" title="class or interface in java.lang">name, http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true#ordinal--; title="class or interface in java.lang">ordinal, http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true#toString--; title="class or interface in java.lang">toString,
[46/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/class-use/HBaseIOException.html -- diff --git a/apidocs/org/apache/hadoop/hbase/class-use/HBaseIOException.html b/apidocs/org/apache/hadoop/hbase/class-use/HBaseIOException.html index 765ba4d..dbc9edd 100644 --- a/apidocs/org/apache/hadoop/hbase/class-use/HBaseIOException.html +++ b/apidocs/org/apache/hadoop/hbase/class-use/HBaseIOException.html @@ -409,18 +409,24 @@ class -StoppedRpcClientException +ServerTooBusyException +Throw this in rpc call if there are too many pending requests for one region server + class -UnsupportedCellCodecException +StoppedRpcClientException class -UnsupportedCompressionCodecException +UnsupportedCellCodecException class +UnsupportedCompressionCodecException + + +class WrongVersionException http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/class-use/NamespaceNotFoundException.html -- diff --git a/apidocs/org/apache/hadoop/hbase/class-use/NamespaceNotFoundException.html b/apidocs/org/apache/hadoop/hbase/class-use/NamespaceNotFoundException.html index 54f27ec..7eab3bc 100644 --- a/apidocs/org/apache/hadoop/hbase/class-use/NamespaceNotFoundException.html +++ b/apidocs/org/apache/hadoop/hbase/class-use/NamespaceNotFoundException.html @@ -72,7 +72,51 @@ Uses of Classorg.apache.hadoop.hbase.NamespaceNotFoundException -No usage of org.apache.hadoop.hbase.NamespaceNotFoundException + + + + +Packages that use NamespaceNotFoundException + +Package +Description + + + +org.apache.hadoop.hbase.client + +Provides HBase Client + + + + + + + + + + +Uses of NamespaceNotFoundException in org.apache.hadoop.hbase.client + +Methods in org.apache.hadoop.hbase.client that throw NamespaceNotFoundException + +Modifier and Type +Method and Description + + + +NamespaceDescriptor +Admin.getNamespaceDescriptor(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +Get a namespace descriptor by name + + + + + + + + + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/class-use/ServerName.html -- diff --git a/apidocs/org/apache/hadoop/hbase/class-use/ServerName.html b/apidocs/org/apache/hadoop/hbase/class-use/ServerName.html index 53abc29..fe99dcf 100644 --- a/apidocs/org/apache/hadoop/hbase/class-use/ServerName.html +++ b/apidocs/org/apache/hadoop/hbase/class-use/ServerName.html @@ -359,13 +359,13 @@ long -ExponentialClientBackoffPolicy.getBackoffTime(ServerNameserverName, +ClientBackoffPolicy.getBackoffTime(ServerNameserverName, byte[]region, org.apache.hadoop.hbase.client.backoff.ServerStatisticsstats) long -ClientBackoffPolicy.getBackoffTime(ServerNameserverName, +ExponentialClientBackoffPolicy.getBackoffTime(ServerNameserverName, byte[]region, org.apache.hadoop.hbase.client.backoff.ServerStatisticsstats) http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/class-use/TableName.html -- diff --git a/apidocs/org/apache/hadoop/hbase/class-use/TableName.html b/apidocs/org/apache/hadoop/hbase/class-use/TableName.html index 2d757ba..afaccdc 100644 --- a/apidocs/org/apache/hadoop/hbase/class-use/TableName.html +++ b/apidocs/org/apache/hadoop/hbase/class-use/TableName.html @@ -405,13 +405,13 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. TableName -RegionLocator.getName() +Table.getName() Gets the fully qualified table name instance of this table. TableName -Table.getName() +RegionLocator.getName() Gets the fully qualified table name instance of this table.
[22/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/HRegionLocation.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/HRegionLocation.html b/devapidocs/org/apache/hadoop/hbase/class-use/HRegionLocation.html index 4ec7cff..0d31f2f 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/HRegionLocation.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/HRegionLocation.html @@ -274,11 +274,11 @@ service. protected HRegionLocation -AbstractRegionServerCallable.location +RegionAdminServiceCallable.location protected HRegionLocation -RegionAdminServiceCallable.location +AbstractRegionServerCallable.location @@ -306,11 +306,11 @@ service. protected HRegionLocation -AbstractRegionServerCallable.getLocation() +MultiServerCallable.getLocation() protected HRegionLocation -MultiServerCallable.getLocation() +AbstractRegionServerCallable.getLocation() HRegionLocation @@ -318,26 +318,26 @@ service. HRegionLocation -RegionLocator.getRegionLocation(byte[]row) +HRegionLocator.getRegionLocation(byte[]row) Finds the region on which the given row is being served. HRegionLocation -HRegionLocator.getRegionLocation(byte[]row) +RegionLocator.getRegionLocation(byte[]row) Finds the region on which the given row is being served. HRegionLocation -RegionLocator.getRegionLocation(byte[]row, +HRegionLocator.getRegionLocation(byte[]row, booleanreload) Finds the region on which the given row is being served. HRegionLocation -HRegionLocator.getRegionLocation(byte[]row, +RegionLocator.getRegionLocation(byte[]row, booleanreload) Finds the region on which the given row is being served. @@ -407,13 +407,13 @@ service. http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListHRegionLocation -RegionLocator.getAllRegionLocations() -Retrieves all of the regions associated with this table. - +HRegionLocator.getAllRegionLocations() http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListHRegionLocation -HRegionLocator.getAllRegionLocations() +RegionLocator.getAllRegionLocations() +Retrieves all of the regions associated with this table. + private Pairhttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listbyte[],http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListHRegionLocation
[45/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/client/Admin.html -- diff --git a/apidocs/org/apache/hadoop/hbase/client/Admin.html b/apidocs/org/apache/hadoop/hbase/client/Admin.html index 2419eed..0171d60 100644 --- a/apidocs/org/apache/hadoop/hbase/client/Admin.html +++ b/apidocs/org/apache/hadoop/hbase/client/Admin.html @@ -107,7 +107,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Public @InterfaceStability.Evolving -public interface Admin +public interface Admin extends org.apache.hadoop.hbase.Abortable, http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true; title="class or interface in java.io">Closeable The administrative API for HBase. Obtain an instance from an Connection.getAdmin() and call close() afterwards. @@ -1202,7 +1202,7 @@ extends org.apache.hadoop.hbase.Abortable, http://docs.oracle.com/javas getOperationTimeout -intgetOperationTimeout() +intgetOperationTimeout() @@ -1211,7 +1211,7 @@ extends org.apache.hadoop.hbase.Abortable, http://docs.oracle.com/javas abort -voidabort(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy, +voidabort(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">Throwablee) Description copied from interface:org.apache.hadoop.hbase.Abortable Abort the server or client. @@ -1230,7 +1230,7 @@ extends org.apache.hadoop.hbase.Abortable, http://docs.oracle.com/javas isAborted -booleanisAborted() +booleanisAborted() Description copied from interface:org.apache.hadoop.hbase.Abortable Check if the server or client was aborted. @@ -1247,7 +1247,7 @@ extends org.apache.hadoop.hbase.Abortable, http://docs.oracle.com/javas getConnection -ConnectiongetConnection() +ConnectiongetConnection() Returns: Connection used by this object. @@ -1260,7 +1260,7 @@ extends org.apache.hadoop.hbase.Abortable, http://docs.oracle.com/javas tableExists -booleantableExists(TableNametableName) +booleantableExists(TableNametableName) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Parameters: @@ -1278,7 +1278,7 @@ extends org.apache.hadoop.hbase.Abortable, http://docs.oracle.com/javas listTables -HTableDescriptor[]listTables() +HTableDescriptor[]listTables() throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException List all the userspace tables. @@ -1295,7 +1295,7 @@ extends org.apache.hadoop.hbase.Abortable, http://docs.oracle.com/javas listTables -HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true; title="class or interface in java.util.regex">Patternpattern) +HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true; title="class or interface in java.util.regex">Patternpattern) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException List all the userspace tables matching the given pattern. @@ -1316,7 +1316,7 @@ extends org.apache.hadoop.hbase.Abortable, http://docs.oracle.com/javas listTables -HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringregex) +HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringregex) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException List all the userspace tables matching the given regular expression. @@ -1337,7 +1337,7 @@ extends org.apache.hadoop.hbase.Abortable, http://docs.oracle.com/javas listTables -HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true; title="class or interface in java.util.regex">Patternpattern, +HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true; title="class or interface in java.util.regex">Patternpattern, booleanincludeSysTables) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in
[11/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ModifyColumnFamilyFuture.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ModifyColumnFamilyFuture.html b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ModifyColumnFamilyFuture.html index fc34683..b69cadc 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ModifyColumnFamilyFuture.html +++ b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ModifyColumnFamilyFuture.html @@ -132,7 +132,7 @@ var activeTableTab = "activeTableTab"; -private static class HBaseAdmin.ModifyColumnFamilyFuture +private static class HBaseAdmin.ModifyColumnFamilyFuture extends HBaseAdmin.ModifyTableFuture @@ -246,7 +246,7 @@ extends ModifyColumnFamilyFuture -publicModifyColumnFamilyFuture(HBaseAdminadmin, +publicModifyColumnFamilyFuture(HBaseAdminadmin, TableNametableName, org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ModifyColumnResponseresponse) @@ -265,7 +265,7 @@ extends getOperationType -publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetOperationType() +publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetOperationType() Overrides: getOperationTypein classHBaseAdmin.ModifyTableFuture http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ModifyTableFuture.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ModifyTableFuture.html b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ModifyTableFuture.html index 38d8deb..9a1866e 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ModifyTableFuture.html +++ b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ModifyTableFuture.html @@ -131,7 +131,7 @@ var activeTableTab = "activeTableTab"; -private static class HBaseAdmin.ModifyTableFuture +private static class HBaseAdmin.ModifyTableFuture extends HBaseAdmin.TableFuturehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">Void @@ -250,7 +250,7 @@ extends ModifyTableFuture -publicModifyTableFuture(HBaseAdminadmin, +publicModifyTableFuture(HBaseAdminadmin, TableNametableName, org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ModifyTableResponseresponse) @@ -261,7 +261,7 @@ extends ModifyTableFuture -publicModifyTableFuture(HBaseAdminadmin, +publicModifyTableFuture(HBaseAdminadmin, TableNametableName, http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">LongprocId) @@ -280,7 +280,7 @@ extends getOperationType -publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetOperationType() +publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetOperationType() Specified by: getOperationTypein classHBaseAdmin.TableFuturehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">Void @@ -295,7 +295,7 @@ extends postOperationResult -protectedhttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">VoidpostOperationResult(http://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">Voidresult, +protectedhttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">VoidpostOperationResult(http://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">Voidresult, longdeadlineTs) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException, http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeoutException.html?is-external=true; title="class or interface in java.util.concurrent">TimeoutException http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.NamespaceFuture.html -- diff --git
[39/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/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 c976bc8..b222809 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html @@ -746,578 +746,590 @@ 738 public static final int DEFAULT_HBASE_CLIENT_MAX_PERREGION_TASKS = 1; 739 740 /** -741 * Parameter name for server pause value, used mostly as value to wait before -742 * running a retry of a failed operation. -743 */ -744 public static final String HBASE_SERVER_PAUSE = "hbase.server.pause"; +741 * The maximum number of concurrent pending RPC requests for one server in process level. +742 */ +743 public static final String HBASE_CLIENT_PERSERVER_REQUESTS_THRESHOLD = +744 "hbase.client.perserver.requests.threshold"; 745 746 /** -747 * Default value of {@link #HBASE_SERVER_PAUSE}. +747 * Default value of {@link #HBASE_CLIENT_PERSERVER_REQUESTS_THRESHOLD}. 748 */ -749 public static final int DEFAULT_HBASE_SERVER_PAUSE = 1000; +749 public static final int DEFAULT_HBASE_CLIENT_PERSERVER_REQUESTS_THRESHOLD = Integer.MAX_VALUE; 750 -751 /** -752 * Parameter name for maximum retries, used as maximum for all retryable -753 * operations such as fetching of the root region from root region server, -754 * getting a cell's value, starting a row update, etc. +751 +752 /** +753 * Parameter name for server pause value, used mostly as value to wait before +754 * running a retry of a failed operation. 755 */ -756 public static final String HBASE_CLIENT_RETRIES_NUMBER = "hbase.client.retries.number"; +756 public static final String HBASE_SERVER_PAUSE = "hbase.server.pause"; 757 758 /** -759 * Default value of {@link #HBASE_CLIENT_RETRIES_NUMBER}. +759 * Default value of {@link #HBASE_SERVER_PAUSE}. 760 */ -761 public static final int DEFAULT_HBASE_CLIENT_RETRIES_NUMBER = 31; +761 public static final int DEFAULT_HBASE_SERVER_PAUSE = 1000; 762 763 /** -764 * Parameter name to set the default scanner caching for all clients. -765 */ -766 public static final String HBASE_CLIENT_SCANNER_CACHING = "hbase.client.scanner.caching"; -767 -768 /** -769 * Default value for {@link #HBASE_CLIENT_SCANNER_CACHING} -770 */ -771 public static final int DEFAULT_HBASE_CLIENT_SCANNER_CACHING = Integer.MAX_VALUE; -772 -773 /** -774 * Parameter name for number of rows that will be fetched when calling next on -775 * a scanner if it is not served from memory. Higher caching values will -776 * enable faster scanners but will eat up more memory and some calls of next -777 * may take longer and longer times when the cache is empty. -778 */ -779 public static final String HBASE_META_SCANNER_CACHING = "hbase.meta.scanner.caching"; -780 -781 /** -782 * Default value of {@link #HBASE_META_SCANNER_CACHING}. -783 */ -784 public static final int DEFAULT_HBASE_META_SCANNER_CACHING = 100; -785 -786 /** -787 * Parameter name for number of versions, kept by meta table. -788 */ -789 public static final String HBASE_META_VERSIONS = "hbase.meta.versions"; -790 -791 /** -792 * Default value of {@link #HBASE_META_VERSIONS}. -793 */ -794 public static final int DEFAULT_HBASE_META_VERSIONS = 3; -795 -796 /** -797 * Parameter name for number of versions, kept by meta table. -798 */ -799 public static final String HBASE_META_BLOCK_SIZE = "hbase.meta.blocksize"; -800 -801 /** -802 * Default value of {@link #HBASE_META_BLOCK_SIZE}. -803 */ -804 public static final int DEFAULT_HBASE_META_BLOCK_SIZE = 8 * 1024; -805 -806 /** -807 * Parameter name for unique identifier for this {@link org.apache.hadoop.conf.Configuration} -808 * instance. If there are two or more {@link org.apache.hadoop.conf.Configuration} instances that, -809 * for all intents and purposes, are the same except for their instance ids, then they will not be -810 * able to share the same org.apache.hadoop.hbase.client.HConnection instance. On the other hand, -811 * even if the instance ids are the same, it could result in non-shared -812 * org.apache.hadoop.hbase.client.HConnection instances if some of the other connection parameters -813 * differ. -814 */ -815 public static final String HBASE_CLIENT_INSTANCE_ID = "hbase.client.instance.id"; -816 -817 /** -818 * The client scanner timeout period in milliseconds. -819 */ -820 public static final String HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD = -821 "hbase.client.scanner.timeout.period"; -822 -823 /** -824 * Use {@link #HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD} instead. -825 * @deprecated This config option is deprecated. Will be removed at later releases after 0.96.
[24/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/HColumnDescriptor.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/HColumnDescriptor.html b/devapidocs/org/apache/hadoop/hbase/class-use/HColumnDescriptor.html index 2dc751c..e17c67d 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/HColumnDescriptor.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/HColumnDescriptor.html @@ -593,189 +593,201 @@ service. void -BaseMasterAndRegionObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) -Deprecated. +Deprecated. +As of release 2.0.0, this will be removed in HBase 3.0.0 + (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). + Use MasterObserver.postAddColumnFamily(ObserverContext, TableName, HColumnDescriptor). + void -BaseMasterObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterAndRegionObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) -Deprecated. -As of release 2.0.0, this will be removed in HBase 3.0.0 - (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). - Use BaseMasterObserver.postAddColumnFamily(ObserverContext, TableName, HColumnDescriptor). - +Deprecated. void -MasterObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) Deprecated. As of release 2.0.0, this will be removed in HBase 3.0.0 (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). - Use MasterObserver.postAddColumnFamily(ObserverContext, TableName, HColumnDescriptor). + Use BaseMasterObserver.postAddColumnFamily(ObserverContext, TableName, HColumnDescriptor). void -BaseMasterAndRegionObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, - HColumnDescriptorcolumnFamily) + HColumnDescriptorcolumnFamily) +Called after the new column family has been created. + void -BaseMasterObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterAndRegionObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) void -MasterObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, - HColumnDescriptorcolumnFamily) -Called after the new column family has been created. - + HColumnDescriptorcolumnFamily) void -BaseMasterAndRegionObserver.postAddColumnHandler(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postAddColumnHandler(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) -Deprecated. +Deprecated. +As of release 2.0.0, this will be removed in HBase 3.0.0 + (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). Use + MasterObserver.postCompletedAddColumnFamilyAction(ObserverContext, TableName, HColumnDescriptor). + void -BaseMasterObserver.postAddColumnHandler(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterAndRegionObserver.postAddColumnHandler(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) -Deprecated. -As of release 2.0.0, this will be removed in HBase 3.0.0 - (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). Use - BaseMasterObserver.postCompletedAddColumnFamilyAction(ObserverContext, TableName, HColumnDescriptor). - +Deprecated. void -MasterObserver.postAddColumnHandler(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.postAddColumnHandler(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) Deprecated. As of release 2.0.0, this will be removed in HBase 3.0.0 (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). Use - MasterObserver.postCompletedAddColumnFamilyAction(ObserverContext, TableName, HColumnDescriptor). +
[08/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/MultiResponse.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/MultiResponse.html b/devapidocs/org/apache/hadoop/hbase/client/MultiResponse.html index a6eb8d5..3b43751 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/MultiResponse.html +++ b/devapidocs/org/apache/hadoop/hbase/client/MultiResponse.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -100,10 +100,15 @@ var activeTableTab = "activeTableTab"; http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">java.lang.Object +org.apache.hadoop.hbase.client.AbstractResponse + + org.apache.hadoop.hbase.client.MultiResponse + + @@ -111,7 +116,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private public class MultiResponse -extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object +extends AbstractResponse A container for Result objects, grouped by regionName. @@ -136,6 +141,13 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? MultiResponse.RegionResult + + + + +Nested classes/interfaces inherited from classorg.apache.hadoop.hbase.client.AbstractResponse +AbstractResponse.ResponseType + @@ -230,6 +242,10 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? int size() + +AbstractResponse.ResponseType +type() + @@ -382,12 +398,25 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? - + getResults publichttp://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">Mapbyte[],MultiResponse.RegionResultgetResults() + + + + + +type +publicAbstractResponse.ResponseTypetype() + +Specified by: +typein classAbstractResponse + + + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/Scan.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/Scan.html b/devapidocs/org/apache/hadoop/hbase/client/Scan.html index e3d23e1..73c7ec3 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/Scan.html +++ b/devapidocs/org/apache/hadoop/hbase/client/Scan.html @@ -1287,7 +1287,7 @@ public static finalhttp://docs.oracle.com/javase/8/docs/api/java/ setStartRow -publicScansetStartRow(byte[]startRow) +publicScansetStartRow(byte[]startRow) Set the start row of the scan. If the specified row does not exist, the Scanner will start from the @@ -1297,6 +1297,9 @@ public static finalhttp://docs.oracle.com/javase/8/docs/api/java/ startRow - row to start scanner at or after Returns: this +Throws: +http://docs.oracle.com/javase/8/docs/api/java/lang/IllegalArgumentException.html?is-external=true; title="class or interface in java.lang">IllegalArgumentException - if startRow does not meet criteria + for a row key (when length exceeds HConstants.MAX_ROW_LENGTH) @@ -1306,7 +1309,7 @@ public static finalhttp://docs.oracle.com/javase/8/docs/api/java/ setStopRow -publicScansetStopRow(byte[]stopRow) +publicScansetStopRow(byte[]stopRow) Set the stop row of the scan. Parameters: @@ -1319,6 +1322,9 @@ public static finalhttp://docs.oracle.com/javase/8/docs/api/java/ The 'trailing 0' will not yield the desired result. Returns: this +Throws: +http://docs.oracle.com/javase/8/docs/api/java/lang/IllegalArgumentException.html?is-external=true; title="class or interface in java.lang">IllegalArgumentException - if stopRow does not meet criteria + for a row key (when length exceeds HConstants.MAX_ROW_LENGTH) @@ -1328,7 +1334,7 @@ public static finalhttp://docs.oracle.com/javase/8/docs/api/java/ setRowPrefixFilter -publicScansetRowPrefixFilter(byte[]rowPrefix) +publicScansetRowPrefixFilter(byte[]rowPrefix) Set a filter (using stopRow and startRow) so the result set only contains rows where the rowKey starts with the specified prefix. This is a utility method that converts the desired rowPrefix into the appropriate values @@ -1350,7 +1356,7 @@ public static finalhttp://docs.oracle.com/javase/8/docs/api/java/ calculateTheClosestNextRowKeyForPrefix -privatebyte[]calculateTheClosestNextRowKeyForPrefix(byte[]rowKeyPrefix) +privatebyte[]calculateTheClosestNextRowKeyForPrefix(byte[]rowKeyPrefix) When scanning for a prefix the scan should stop immediately after
[16/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/TableNotDisabledException.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/TableNotDisabledException.html b/devapidocs/org/apache/hadoop/hbase/class-use/TableNotDisabledException.html index 7ae190c..1eec2af 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/TableNotDisabledException.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/TableNotDisabledException.html @@ -104,14 +104,14 @@ void -HMaster.checkTableModifiable(TableNametableName) - - -void MasterServices.checkTableModifiable(TableNametableName) Check table is modifiable; i.e. + +void +HMaster.checkTableModifiable(TableNametableName) + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/TableNotFoundException.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/TableNotFoundException.html b/devapidocs/org/apache/hadoop/hbase/class-use/TableNotFoundException.html index 431b080..1395885 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/TableNotFoundException.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/TableNotFoundException.html @@ -178,14 +178,14 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -HMaster.checkTableModifiable(TableNametableName) - - -void MasterServices.checkTableModifiable(TableNametableName) Check table is modifiable; i.e. + +void +HMaster.checkTableModifiable(TableNametableName) + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/Tag.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/Tag.html b/devapidocs/org/apache/hadoop/hbase/class-use/Tag.html index 0bef2ef..9568cc5 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/Tag.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/Tag.html @@ -780,18 +780,18 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTag -DefaultVisibilityLabelServiceImpl.createVisibilityExpTags(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringvisExpression, - booleanwithSerializationFormat, - booleancheckAuths) - - -http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTag VisibilityLabelService.createVisibilityExpTags(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringvisExpression, booleanwithSerializationFormat, booleancheckAuths) Creates tags corresponding to given visibility expression. + +http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTag +DefaultVisibilityLabelServiceImpl.createVisibilityExpTags(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringvisExpression, + booleanwithSerializationFormat, + booleancheckAuths) + static http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTag VisibilityUtils.createVisibilityExpTags(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringvisExpression, @@ -836,11 +836,6 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. byte[] -DefaultVisibilityLabelServiceImpl.encodeVisibilityForReplication(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTagtags, - http://docs.oracle.com/javase/8/docs/api/java/lang/Byte.html?is-external=true; title="class or interface in java.lang">ByteserializationFormat) - - -byte[] VisibilityLabelService.encodeVisibilityForReplication(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTagvisTags, http://docs.oracle.com/javase/8/docs/api/java/lang/Byte.html?is-external=true; title="class or interface in java.lang">ByteserializationFormat) Provides a way to modify the visibility tags of type TagType @@ -850,6 +845,11 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. .replicate(). +
[23/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html b/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html index cb9e249..b71a4ff 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html @@ -877,7 +877,7 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. HRegionInfo -AbstractRegionServerCallable.getHRegionInfo() +ScannerCallableWithReplicas.getHRegionInfo() HRegionInfo @@ -885,7 +885,7 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. HRegionInfo -ScannerCallableWithReplicas.getHRegionInfo() +AbstractRegionServerCallable.getHRegionInfo() private HRegionInfo @@ -1115,16 +1115,6 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -BaseMasterAndRegionObserver.postAssign(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInforegionInfo) - - -void -BaseMasterObserver.postAssign(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInforegionInfo) - - -void MasterObserver.postAssign(ObserverContextMasterCoprocessorEnvironmentctx, HRegionInforegionInfo) Called after the region assignment has been requested. @@ -1132,15 +1122,13 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -BaseMasterAndRegionObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, - HTableDescriptordesc, - HRegionInfo[]regions) +BaseMasterAndRegionObserver.postAssign(ObserverContextMasterCoprocessorEnvironmentctx, + HRegionInforegionInfo) void -BaseMasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, - HTableDescriptordesc, - HRegionInfo[]regions) +BaseMasterObserver.postAssign(ObserverContextMasterCoprocessorEnvironmentctx, + HRegionInforegionInfo) void @@ -1152,15 +1140,15 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -BaseMasterAndRegionObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, - HTableDescriptordesc, - HRegionInfo[]regions) +BaseMasterAndRegionObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, + HTableDescriptordesc, + HRegionInfo[]regions) void -BaseMasterObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, - HTableDescriptordesc, - HRegionInfo[]regions) +BaseMasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, + HTableDescriptordesc, + HRegionInfo[]regions) void @@ -1172,95 +1160,107 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -BaseMasterAndRegionObserver.postCreateTableHandler(ObserverContextMasterCoprocessorEnvironmentctx, - HTableDescriptordesc, - HRegionInfo[]regions) -Deprecated. - +BaseMasterAndRegionObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, + HTableDescriptordesc, + HRegionInfo[]regions) void -BaseMasterObserver.postCreateTableHandler(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, + HTableDescriptordesc, + HRegionInfo[]regions) + + +void +MasterObserver.postCreateTableHandler(ObserverContextMasterCoprocessorEnvironmentctx, HTableDescriptordesc, HRegionInfo[]regions) Deprecated. As of release 2.0.0, this will be removed in HBase 3.0.0 (https://issues.apache.org/jira/browse/HBASE-15575;>HBASE-15575). - Use BaseMasterObserver.postCompletedCreateTableAction(ObserverContext, HTableDescriptor, HRegionInfo[]) + Use MasterObserver.postCompletedCreateTableAction(ObserverContext, HTableDescriptor, HRegionInfo[]) + +void +BaseMasterAndRegionObserver.postCreateTableHandler(ObserverContextMasterCoprocessorEnvironmentctx, + HTableDescriptordesc, + HRegionInfo[]regions) +Deprecated. + + void -MasterObserver.postCreateTableHandler(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.postCreateTableHandler(ObserverContextMasterCoprocessorEnvironmentctx, HTableDescriptordesc, HRegionInfo[]regions) Deprecated. As of release 2.0.0, this will be removed in HBase
[10/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.html b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.html index b6ca09f..1fedb35 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.html +++ b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.html @@ -115,7 +115,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private @InterfaceStability.Evolving -public class HBaseAdmin +public class HBaseAdmin extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements Admin HBaseAdmin is no longer a client API. It is marked InterfaceAudience.Private indicating that @@ -1543,7 +1543,7 @@ implements LOG -private static finalorg.apache.commons.logging.Log LOG +private static finalorg.apache.commons.logging.Log LOG @@ -1552,7 +1552,7 @@ implements ZK_IDENTIFIER_PREFIX -private static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ZK_IDENTIFIER_PREFIX +private static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ZK_IDENTIFIER_PREFIX See Also: Constant Field Values @@ -1565,7 +1565,7 @@ implements connection -privateClusterConnection connection +privateClusterConnection connection @@ -1574,7 +1574,7 @@ implements conf -private volatileorg.apache.hadoop.conf.Configuration conf +private volatileorg.apache.hadoop.conf.Configuration conf @@ -1583,7 +1583,7 @@ implements pause -private finallong pause +private finallong pause @@ -1592,7 +1592,7 @@ implements numRetries -private finalint numRetries +private finalint numRetries @@ -1601,7 +1601,7 @@ implements syncWaitTimeout -private finalint syncWaitTimeout +private finalint syncWaitTimeout @@ -1610,7 +1610,7 @@ implements aborted -privateboolean aborted +privateboolean aborted @@ -1619,7 +1619,7 @@ implements operationTimeout -privateint operationTimeout +privateint operationTimeout @@ -1628,7 +1628,7 @@ implements rpcTimeout -privateint rpcTimeout +privateint rpcTimeout @@ -1637,7 +1637,7 @@ implements rpcCallerFactory -privateRpcRetryingCallerFactory rpcCallerFactory +privateRpcRetryingCallerFactory rpcCallerFactory @@ -1646,7 +1646,7 @@ implements rpcControllerFactory -privateRpcControllerFactory rpcControllerFactory +privateRpcControllerFactory rpcControllerFactory @@ -1655,7 +1655,7 @@ implements ng -privateNonceGenerator ng +privateNonceGenerator ng @@ -1672,7 +1672,7 @@ implements HBaseAdmin -HBaseAdmin(ClusterConnectionconnection) +HBaseAdmin(ClusterConnectionconnection) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: @@ -1694,7 +1694,7 @@ implements getOperationTimeout -publicintgetOperationTimeout() +publicintgetOperationTimeout() Specified by: getOperationTimeoutin interfaceAdmin @@ -1707,7 +1707,7 @@ implements abort -publicvoidabort(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy, +publicvoidabort(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">Throwablee) Description copied from interface:Abortable Abort the server or client. @@ -1728,7 +1728,7 @@ implements isAborted -publicbooleanisAborted() +publicbooleanisAborted() Description copied from interface:Abortable Check if the server or client was aborted. @@ -1747,7 +1747,7 @@ implements abortProcedure -publicbooleanabortProcedure(longprocId, +publicbooleanabortProcedure(longprocId, booleanmayInterruptIfRunning) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from interface:Admin @@ -1771,7 +1771,7 @@ implements abortProcedureAsync -publichttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Future.html?is-external=true; title="class or interface in java.util.concurrent">Futurehttp://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true; title="class or interface in java.lang">BooleanabortProcedureAsync(longprocId, +publichttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Future.html?is-external=true; title="class or
[40/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/overview-tree.html -- diff --git a/apidocs/overview-tree.html b/apidocs/overview-tree.html index 1455fb8..de55f6d 100644 --- a/apidocs/overview-tree.html +++ b/apidocs/overview-tree.html @@ -587,6 +587,7 @@ org.apache.hadoop.hbase.client.ScannerTimeoutException +org.apache.hadoop.hbase.ipc.ServerTooBusyException org.apache.hadoop.hbase.TableExistsException org.apache.hadoop.hbase.TableNotDisabledException org.apache.hadoop.hbase.TableNotEnabledException @@ -848,23 +849,23 @@ org.apache.hadoop.hbase.ProcedureState org.apache.hadoop.hbase.io.encoding.DataBlockEncoding org.apache.hadoop.hbase.filter.BitComparator.BitwiseOp -org.apache.hadoop.hbase.filter.FilterList.Operator +org.apache.hadoop.hbase.filter.CompareFilter.CompareOp org.apache.hadoop.hbase.filter.RegexStringComparator.EngineType +org.apache.hadoop.hbase.filter.FilterList.Operator org.apache.hadoop.hbase.filter.Filter.ReturnCode -org.apache.hadoop.hbase.filter.CompareFilter.CompareOp -org.apache.hadoop.hbase.regionserver.BloomType -org.apache.hadoop.hbase.quotas.QuotaScope -org.apache.hadoop.hbase.quotas.ThrottleType -org.apache.hadoop.hbase.quotas.ThrottlingException.Type -org.apache.hadoop.hbase.quotas.QuotaType -org.apache.hadoop.hbase.client.IsolationLevel org.apache.hadoop.hbase.client.CompactType -org.apache.hadoop.hbase.client.Consistency +org.apache.hadoop.hbase.client.IsolationLevel +org.apache.hadoop.hbase.client.SnapshotType org.apache.hadoop.hbase.client.MasterSwitchType org.apache.hadoop.hbase.client.CompactionState -org.apache.hadoop.hbase.client.SnapshotType org.apache.hadoop.hbase.client.Durability +org.apache.hadoop.hbase.client.Consistency org.apache.hadoop.hbase.client.security.SecurityCapability +org.apache.hadoop.hbase.quotas.ThrottlingException.Type +org.apache.hadoop.hbase.quotas.ThrottleType +org.apache.hadoop.hbase.quotas.QuotaType +org.apache.hadoop.hbase.quotas.QuotaScope +org.apache.hadoop.hbase.regionserver.BloomType http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/serialized-form.html -- diff --git a/apidocs/serialized-form.html b/apidocs/serialized-form.html index ba1d111..f15fafa 100644 --- a/apidocs/serialized-form.html +++ b/apidocs/serialized-form.html @@ -692,6 +692,11 @@ Class org.apache.hadoop.hbase.ipc.ServerNotRunningYetException extends http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException implements Serializable + + + +Class org.apache.hadoop.hbase.ipc.ServerTooBusyException extends DoNotRetryIOException implements Serializable +
[13/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html index 3b44e25..a84c620 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html @@ -500,7 +500,7 @@ implements callback -private finalBatch.CallbackCResult callback +private finalBatch.CallbackCResult callback @@ -509,7 +509,7 @@ implements errors -private finalAsyncProcess.BatchErrors errors +private finalAsyncProcess.BatchErrors errors @@ -518,7 +518,7 @@ implements errorsByServer -private finalConnectionImplementation.ServerErrorTracker errorsByServer +private finalConnectionImplementation.ServerErrorTracker errorsByServer @@ -527,7 +527,7 @@ implements pool -private finalhttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true; title="class or interface in java.util.concurrent">ExecutorService pool +private finalhttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true; title="class or interface in java.util.concurrent">ExecutorService pool @@ -536,7 +536,7 @@ implements callsInProgress -private finalhttp://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true; title="class or interface in java.util">SetCancellableRegionServerCallable callsInProgress +private finalhttp://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true; title="class or interface in java.util">SetCancellableRegionServerCallable callsInProgress @@ -545,7 +545,7 @@ implements tableName -private finalTableName tableName +private finalTableName tableName @@ -554,7 +554,7 @@ implements actionsInProgress -private finalhttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicLong actionsInProgress +private finalhttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicLong actionsInProgress @@ -563,7 +563,7 @@ implements replicaResultLock -private finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object replicaResultLock +private finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object replicaResultLock The lock controls access to results. It is only held when populating results where there might be several callers (eventual consistency gets). For other requests, there's one unique call going on per result index. @@ -575,7 +575,7 @@ implements results -private finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object[] results +private finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object[] results Result array. Null if results are not needed. Otherwise, each index corresponds to the action index in initial actions submitted. For most request types, has null-s for requests that are not done, and result/exception for those that are done. @@ -591,7 +591,7 @@ implements replicaGetIndices -private finalint[] replicaGetIndices +private finalint[] replicaGetIndices Indices of replica gets in results. If null, all or no actions are replica-gets. @@ -601,7 +601,7 @@ implements hasAnyReplicaGets -private finalboolean hasAnyReplicaGets +private finalboolean hasAnyReplicaGets @@ -610,7 +610,7 @@ implements nonceGroup -private finallong nonceGroup +private finallong nonceGroup @@ -619,7 +619,7 @@ implements currentCallable -privateCancellableRegionServerCallable currentCallable +privateCancellableRegionServerCallable currentCallable @@ -628,7 +628,7 @@ implements currentCallTotalTimeout -privateint currentCallTotalTimeout +privateint currentCallTotalTimeout @@ -637,7 +637,7 @@ implements heapSizesByServer -private finalhttp://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">MapServerName,http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listhttp://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">Long heapSizesByServer +private
[36/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/src-html/org/apache/hadoop/hbase/ipc/ServerTooBusyException.html -- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/ipc/ServerTooBusyException.html b/apidocs/src-html/org/apache/hadoop/hbase/ipc/ServerTooBusyException.html new file mode 100644 index 000..9e5d16d --- /dev/null +++ b/apidocs/src-html/org/apache/hadoop/hbase/ipc/ServerTooBusyException.html @@ -0,0 +1,110 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + +Source code + + + + +001/* +002 * +003 * Licensed to the Apache Software Foundation (ASF) under one +004 * or more contributor license agreements. See the NOTICE file +005 * distributed with this work for additional information +006 * regarding copyright ownership. The ASF licenses this file +007 * to you under the Apache License, Version 2.0 (the +008 * "License"); you may not use this file except in compliance +009 * with the License. You may obtain a copy of the License at +010 * +011 * http://www.apache.org/licenses/LICENSE-2.0 +012 * +013 * Unless required by applicable law or agreed to in writing, software +014 * distributed under the License is distributed on an "AS IS" BASIS, +015 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +016 * See the License for the specific language governing permissions and +017 * limitations under the License. +018 */ +019package org.apache.hadoop.hbase.ipc; +020 +021import java.net.InetSocketAddress; +022 +023import org.apache.hadoop.hbase.DoNotRetryIOException; +024import org.apache.hadoop.hbase.classification.InterfaceAudience; +025import org.apache.hadoop.hbase.classification.InterfaceStability; +026 +027/** +028 * Throw this in rpc call if there are too many pending requests for one region server +029 */ +030@InterfaceAudience.Public +031@InterfaceStability.Evolving +032public class ServerTooBusyException extends DoNotRetryIOException { +033 +034 public ServerTooBusyException(InetSocketAddress address, long count) { +035super("There are " + count + " concurrent rpc requests for " + address); +036 } +037 +038} + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/src-html/org/apache/hadoop/hbase/util/Counter.html -- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/util/Counter.html b/apidocs/src-html/org/apache/hadoop/hbase/util/Counter.html index 4af5985..01ae315 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/util/Counter.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/util/Counter.html @@ -189,29 +189,33 @@ 181return sum; 182 } 183 -184 @Override -185 public String toString() { -186Cell[] cells = containerRef.get().cells; +184 public void destroy() { +185indexHolderThreadLocal.remove(); +186 } 187 -188long min = Long.MAX_VALUE; -189long max = Long.MIN_VALUE; -190long sum = 0; +188 @Override +189 public String toString() { +190Cell[] cells = containerRef.get().cells; 191 -192for(Cell cell : cells) { -193 long value = cell.get(); -194 sum += value; -195 if(min value) { min = value; } -196 if(max value) { max = value; } -197} -198 -199return new StringBuilder(100) -200.append("[value=").append(sum) -201.append(", cells=[length=").append(cells.length) -202.append(", min=").append(min) -203.append(", max=").append(max) -204.append("]]").toString(); -205 } -206} +192long min = Long.MAX_VALUE; +193long max = Long.MIN_VALUE; +194long sum = 0; +195 +196for(Cell cell : cells) { +197 long value = cell.get(); +198 sum += value; +199 if(min value) { min = value; } +200 if(max value) { max = value; } +201} +202 +203return new StringBuilder(100) +204.append("[value=").append(sum) +205.append(", cells=[length=").append(cells.length) +206.append(", min=").append(min) +207.append(", max=").append(max) +208.append("]]").toString(); +209 } +210} http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/book.html -- diff --git a/book.html b/book.html index aebc5b4..450800a 100644 --- a/book.html +++ b/book.html @@ -2932,7 +2932,7 @@ Configuration that it is thought rare anyone would change can exist only in code Description -The maximum number of concurrent tasks a single HTable instance will send to the cluster. +The maximum number of concurrent mutation tasks a single HTable instance will send to the cluster. Default @@ -2947,7 +2947,7 @@ Configuration that it is thought rare anyone would change can exist only in code Description -The maximum number of concurrent tasks a
[19/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/Server.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/Server.html b/devapidocs/org/apache/hadoop/hbase/class-use/Server.html index e162915..6f82fe2 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/Server.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/Server.html @@ -170,13 +170,13 @@ -protected Server -ZkCoordinatedStateManager.server - - private Server ZKSplitLogManagerCoordination.server + +protected Server +ZkCoordinatedStateManager.server + @@ -188,11 +188,11 @@ Server -ZkCoordinatedStateManager.getServer() +BaseCoordinatedStateManager.getServer() Server -BaseCoordinatedStateManager.getServer() +ZkCoordinatedStateManager.getServer() @@ -205,11 +205,11 @@ void -ZkCoordinatedStateManager.initialize(Serverserver) +BaseCoordinatedStateManager.initialize(Serverserver) void -BaseCoordinatedStateManager.initialize(Serverserver) +ZkCoordinatedStateManager.initialize(Serverserver) @@ -337,11 +337,11 @@ private Server -SplitLogManager.server +CatalogJanitor.server private Server -CatalogJanitor.server +SplitLogManager.server @@ -439,19 +439,19 @@ private Server -HeapMemoryManager.server +SplitTransactionImpl.server private Server -LogRoller.server +SplitTransactionImpl.DaughterOpener.server private Server -SplitTransactionImpl.server +LogRoller.server private Server -SplitTransactionImpl.DaughterOpener.server +HeapMemoryManager.server @@ -464,23 +464,23 @@ Server -RegionMergeTransactionImpl.getServer() +RegionMergeTransaction.getServer() +Get the Server running the transaction or rollback + Server -SplitTransaction.getServer() -Get the Server running the transaction or rollback - +RegionMergeTransactionImpl.getServer() Server -RegionMergeTransaction.getServer() -Get the Server running the transaction or rollback - +SplitTransactionImpl.getServer() Server -SplitTransactionImpl.getServer() +SplitTransaction.getServer() +Get the Server running the transaction or rollback + @@ -516,20 +516,6 @@ Region -RegionMergeTransactionImpl.execute(Serverserver, - RegionServerServicesservices) - - -PairOfSameTypeRegion -SplitTransaction.execute(Serverserver, - RegionServerServicesservices) -Deprecated. -use #execute(Server, RegionServerServices, User); as of 1.0.2, remove in 3.0 - - - - -Region RegionMergeTransaction.execute(Serverserver, RegionServerServicesservices) Deprecated. @@ -538,22 +524,22 @@ -PairOfSameTypeRegion -SplitTransactionImpl.execute(Serverserver, +Region +RegionMergeTransactionImpl.execute(Serverserver, RegionServerServicesservices) -Region -RegionMergeTransactionImpl.execute(Serverserver, - RegionServerServicesservices, - Useruser) +PairOfSameTypeRegion +SplitTransactionImpl.execute(Serverserver, + RegionServerServicesservices) PairOfSameTypeRegion -SplitTransaction.execute(Serverserver, - RegionServerServicesservices, - Useruser) -Run the transaction. +SplitTransaction.execute(Serverserver, + RegionServerServicesservices) +Deprecated. +use #execute(Server, RegionServerServices, User); as of 1.0.2, remove in 3.0 + @@ -565,11 +551,25 @@ +Region +RegionMergeTransactionImpl.execute(Serverserver, + RegionServerServicesservices, + Useruser) + + PairOfSameTypeRegion SplitTransactionImpl.execute(Serverserver, RegionServerServicesservices, Useruser) + +PairOfSameTypeRegion +SplitTransaction.execute(Serverserver, + RegionServerServicesservices, + Useruser) +Run the transaction. + + void ReplicationService.initialize(Serverrs, @@ -605,20 +605,6 @@ boolean -RegionMergeTransactionImpl.rollback(Serverserver, -RegionServerServicesservices) - - -boolean -SplitTransaction.rollback(Serverserver, -RegionServerServicesservices) -Deprecated. -use #rollback(Server, RegionServerServices, User); as of 1.0.2, remove in 3.0 - - - - -boolean RegionMergeTransaction.rollback(Serverserver, RegionServerServicesservices) Deprecated. @@ -628,21 +614,21 @@ boolean -SplitTransactionImpl.rollback(Serverserver, +RegionMergeTransactionImpl.rollback(Serverserver, RegionServerServicesservices) boolean -RegionMergeTransactionImpl.rollback(Serverserver, -RegionServerServicesservices, -Useruser) +SplitTransactionImpl.rollback(Serverserver, +RegionServerServicesservices) boolean -SplitTransaction.rollback(Serverserver, -RegionServerServicesservices, -Useruser) -Roll back a failed transaction +SplitTransaction.rollback(Serverserver, +RegionServerServicesservices) +Deprecated. +use #rollback(Server, RegionServerServices, User); as of 1.0.2, remove in 3.0 + @@ -655,10
[14/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/Admin.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/Admin.html b/devapidocs/org/apache/hadoop/hbase/client/Admin.html index a16b942..136f4fe 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/Admin.html +++ b/devapidocs/org/apache/hadoop/hbase/client/Admin.html @@ -111,7 +111,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Public @InterfaceStability.Evolving -public interface Admin +public interface Admin extends Abortable, http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true; title="class or interface in java.io">Closeable The administrative API for HBase. Obtain an instance from an Connection.getAdmin() and call close() afterwards. @@ -1206,7 +1206,7 @@ extends getOperationTimeout -intgetOperationTimeout() +intgetOperationTimeout() @@ -1215,7 +1215,7 @@ extends abort -voidabort(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy, +voidabort(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">Throwablee) Description copied from interface:Abortable Abort the server or client. @@ -1234,7 +1234,7 @@ extends isAborted -booleanisAborted() +booleanisAborted() Description copied from interface:Abortable Check if the server or client was aborted. @@ -1251,7 +1251,7 @@ extends getConnection -ConnectiongetConnection() +ConnectiongetConnection() Returns: Connection used by this object. @@ -1264,7 +1264,7 @@ extends tableExists -booleantableExists(TableNametableName) +booleantableExists(TableNametableName) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Parameters: @@ -1282,7 +1282,7 @@ extends listTables -HTableDescriptor[]listTables() +HTableDescriptor[]listTables() throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException List all the userspace tables. @@ -1299,7 +1299,7 @@ extends listTables -HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true; title="class or interface in java.util.regex">Patternpattern) +HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true; title="class or interface in java.util.regex">Patternpattern) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException List all the userspace tables matching the given pattern. @@ -1320,7 +1320,7 @@ extends listTables -HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringregex) +HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringregex) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException List all the userspace tables matching the given regular expression. @@ -1341,7 +1341,7 @@ extends listTables -HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true; title="class or interface in java.util.regex">Patternpattern, +HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true; title="class or interface in java.util.regex">Patternpattern, booleanincludeSysTables) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException List all the tables matching the given pattern. @@ -1364,7 +1364,7 @@ extends listTables -HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringregex, +HTableDescriptor[]listTables(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringregex, booleanincludeSysTables) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in
[05/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/class-use/Result.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/class-use/Result.html b/devapidocs/org/apache/hadoop/hbase/client/class-use/Result.html index a9ed4f2..45c6c97 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/class-use/Result.html +++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/Result.html @@ -359,6 +359,10 @@ service. private Result ScannerCallableWithReplicas.lastResult + +private Result +SingleResponse.Entry.result + @@ -389,13 +393,13 @@ service. Result -HTable.append(Appendappend) +Table.append(Appendappend) Appends values to one or more columns within a single row. Result -Table.append(Appendappend) +HTable.append(Appendappend) Appends values to one or more columns within a single row. @@ -476,13 +480,13 @@ service. Result -HTable.get(Getget) +Table.get(Getget) Extracts certain cells from a given row. Result -Table.get(Getget) +HTable.get(Getget) Extracts certain cells from a given row. @@ -497,13 +501,13 @@ service. Result[] -HTable.get(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListGetgets) +Table.get(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListGetgets) Extracts certain cells from the given rows, in batch. Result[] -Table.get(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListGetgets) +HTable.get(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListGetgets) Extracts certain cells from the given rows, in batch. @@ -513,9 +517,7 @@ service. Result -HTable.increment(Incrementincrement) -Increments one or more columns within a single row. - +SingleResponse.Entry.getResult() Result @@ -525,17 +527,17 @@ service. Result -HTableWrapper.increment(Incrementincrement) +HTable.increment(Incrementincrement) +Increments one or more columns within a single row. + Result -ClientAsyncPrefetchScanner.next() +HTableWrapper.increment(Incrementincrement) Result -ResultScanner.next() -Grab the next row's worth of values. - +ClientAsyncPrefetchScanner.next() Result @@ -543,23 +545,25 @@ service. Result -ClientSimpleScanner.next() +ClientSmallScanner.next() Result -ClientSmallScanner.next() +ClientSimpleScanner.next() Result -TableSnapshotScanner.next() +ResultScanner.next() +Grab the next row's worth of values. + Result ClientSideRegionScanner.next() -Result[] -ResultScanner.next(intnbRows) +Result +TableSnapshotScanner.next() Result[] @@ -568,17 +572,17 @@ service. +Result[] +ResultScanner.next(intnbRows) + + protected Result ClientScanner.nextWithSyncCache() - + private Result ClientAsyncPrefetchScanner.pollCache() - -protected Result[] -ScannerCallable.rpcCall() - protected Result RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable.rpcCall() @@ -587,6 +591,10 @@ service. protected Result[] ClientSmallScanner.SmallScannerCallable.rpcCall() + +protected Result[] +ScannerCallable.rpcCall() + @@ -666,17 +674,21 @@ service. +void +SingleResponse.Entry.setResult(Resultresult) + + private void ScannerCallableWithReplicas.updateCurrentlyServingReplica(ScannerCallablescanner, Result[]result, http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicBoolean.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicBooleandone, http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true; title="class or interface in java.util.concurrent">ExecutorServicepool) - + protected void ClientScanner.updateLastCellLoadedToCache(Resultresult) - + protected void ScannerCallable.updateResultsMetrics(Result[]rrs) @@ -922,9 +934,11 @@ service. org.apache.hadoop.mapred.RecordReaderImmutableBytesWritable,Result -MultiTableSnapshotInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplitsplit, +TableInputFormatBase.getRecordReader(org.apache.hadoop.mapred.InputSplitsplit, org.apache.hadoop.mapred.JobConfjob, - org.apache.hadoop.mapred.Reporterreporter) + org.apache.hadoop.mapred.Reporterreporter) +Builds a TableRecordReader. + org.apache.hadoop.mapred.RecordReaderImmutableBytesWritable,Result @@ -934,11 +948,9 @@ service. org.apache.hadoop.mapred.RecordReaderImmutableBytesWritable,Result -TableInputFormatBase.getRecordReader(org.apache.hadoop.mapred.InputSplitsplit,
[20/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/InterProcessLock.MetadataHandler.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/InterProcessLock.MetadataHandler.html b/devapidocs/org/apache/hadoop/hbase/class-use/InterProcessLock.MetadataHandler.html index b8ad182..49237f5 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/InterProcessLock.MetadataHandler.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/InterProcessLock.MetadataHandler.html @@ -174,13 +174,13 @@ -private InterProcessLock.MetadataHandler -ZKInterProcessReadWriteLock.handler - - protected InterProcessLock.MetadataHandler ZKInterProcessLockBase.handler + +private InterProcessLock.MetadataHandler +ZKInterProcessReadWriteLock.handler + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.Type.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.Type.html b/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.Type.html index 88484ad..86f4132 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.Type.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.Type.html @@ -103,6 +103,19 @@ Uses of KeyValue.Type in org.apache.hadoop.hbase + +Fields in org.apache.hadoop.hbase declared as KeyValue.Type + +Modifier and Type +Field and Description + + + +private static KeyValue.Type[] +KeyValue.Type.codeArray + + + Methods in org.apache.hadoop.hbase that return KeyValue.Type http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.html b/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.html index 5806075..5e297d2 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.html @@ -819,28 +819,22 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. http://docs.oracle.com/javase/8/docs/api/java/util/Iterator.html?is-external=true; title="class or interface in java.util">IteratorStoreFile -DefaultStoreFileManager.getCandidateFilesForRowKeyBefore(KeyValuetargetKey) - - -http://docs.oracle.com/javase/8/docs/api/java/util/Iterator.html?is-external=true; title="class or interface in java.util">IteratorStoreFile StoreFileManager.getCandidateFilesForRowKeyBefore(KeyValuetargetKey) Gets initial, full list of candidate store files to check for row-key-before. - + http://docs.oracle.com/javase/8/docs/api/java/util/Iterator.html?is-external=true; title="class or interface in java.util">IteratorStoreFile StripeStoreFileManager.getCandidateFilesForRowKeyBefore(KeyValuetargetKey) See StoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue) for details on this methods. - + http://docs.oracle.com/javase/8/docs/api/java/util/Iterator.html?is-external=true; title="class or interface in java.util">IteratorStoreFile -DefaultStoreFileManager.updateCandidateFilesForRowKeyBefore(http://docs.oracle.com/javase/8/docs/api/java/util/Iterator.html?is-external=true; title="class or interface in java.util">IteratorStoreFilecandidateFiles, - KeyValuetargetKey, - Cellcandidate) +DefaultStoreFileManager.getCandidateFilesForRowKeyBefore(KeyValuetargetKey) - + http://docs.oracle.com/javase/8/docs/api/java/util/Iterator.html?is-external=true; title="class or interface in java.util">IteratorStoreFile StoreFileManager.updateCandidateFilesForRowKeyBefore(http://docs.oracle.com/javase/8/docs/api/java/util/Iterator.html?is-external=true; title="class or interface in java.util">IteratorStoreFilecandidateFiles, KeyValuetargetKey, @@ -848,7 +842,7 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. Updates the candidate list for finding row key before. - + http://docs.oracle.com/javase/8/docs/api/java/util/Iterator.html?is-external=true; title="class or interface in java.util">IteratorStoreFile StripeStoreFileManager.updateCandidateFilesForRowKeyBefore(http://docs.oracle.com/javase/8/docs/api/java/util/Iterator.html?is-external=true; title="class or interface in java.util">IteratorStoreFilecandidateFiles, KeyValuetargetKey, @@ -858,6 +852,12 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. for details on this methods. + +http://docs.oracle.com/javase/8/docs/api/java/util/Iterator.html?is-external=true; title="class or interface in java.util">IteratorStoreFile
[43/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/client/package-tree.html -- diff --git a/apidocs/org/apache/hadoop/hbase/client/package-tree.html b/apidocs/org/apache/hadoop/hbase/client/package-tree.html index 3581851..fc7f54f 100644 --- a/apidocs/org/apache/hadoop/hbase/client/package-tree.html +++ b/apidocs/org/apache/hadoop/hbase/client/package-tree.html @@ -204,13 +204,13 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.client.IsolationLevel org.apache.hadoop.hbase.client.CompactType -org.apache.hadoop.hbase.client.Consistency +org.apache.hadoop.hbase.client.IsolationLevel +org.apache.hadoop.hbase.client.SnapshotType org.apache.hadoop.hbase.client.MasterSwitchType org.apache.hadoop.hbase.client.CompactionState -org.apache.hadoop.hbase.client.SnapshotType org.apache.hadoop.hbase.client.Durability +org.apache.hadoop.hbase.client.Consistency http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/filter/CompareFilter.CompareOp.html -- diff --git a/apidocs/org/apache/hadoop/hbase/filter/CompareFilter.CompareOp.html b/apidocs/org/apache/hadoop/hbase/filter/CompareFilter.CompareOp.html index ed5a540..6adce77 100644 --- a/apidocs/org/apache/hadoop/hbase/filter/CompareFilter.CompareOp.html +++ b/apidocs/org/apache/hadoop/hbase/filter/CompareFilter.CompareOp.html @@ -320,7 +320,7 @@ the order they are declared. values -public staticCompareFilter.CompareOp[]values() +public staticCompareFilter.CompareOp[]values() Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -340,7 +340,7 @@ for (CompareFilter.CompareOp c : CompareFilter.CompareOp.values()) valueOf -public staticCompareFilter.CompareOpvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +public staticCompareFilter.CompareOpvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/filter/class-use/Filter.ReturnCode.html -- diff --git a/apidocs/org/apache/hadoop/hbase/filter/class-use/Filter.ReturnCode.html b/apidocs/org/apache/hadoop/hbase/filter/class-use/Filter.ReturnCode.html index 9cecc2f..dc62d4b 100644 --- a/apidocs/org/apache/hadoop/hbase/filter/class-use/Filter.ReturnCode.html +++ b/apidocs/org/apache/hadoop/hbase/filter/class-use/Filter.ReturnCode.html @@ -115,107 +115,107 @@ Filter.ReturnCode -FirstKeyOnlyFilter.filterKeyValue(Cellv) +MultiRowRangeFilter.filterKeyValue(Cellignored) Filter.ReturnCode -FirstKeyValueMatchingQualifiersFilter.filterKeyValue(Cellv) -Deprecated. - +DependentColumnFilter.filterKeyValue(Cellc) Filter.ReturnCode -PrefixFilter.filterKeyValue(Cellv) +RandomRowFilter.filterKeyValue(Cellv) Filter.ReturnCode -TimestampsFilter.filterKeyValue(Cellv) +ColumnPrefixFilter.filterKeyValue(Cellcell) Filter.ReturnCode -QualifierFilter.filterKeyValue(Cellv) +SkipFilter.filterKeyValue(Cellv) Filter.ReturnCode -PageFilter.filterKeyValue(Cellignored) +InclusiveStopFilter.filterKeyValue(Cellv) Filter.ReturnCode -FilterList.filterKeyValue(Cellc) +WhileMatchFilter.filterKeyValue(Cellv) -abstract Filter.ReturnCode -Filter.filterKeyValue(Cellv) -A way to filter based on the column family, column qualifier and/or the column value. - +Filter.ReturnCode +SingleColumnValueFilter.filterKeyValue(Cellc) Filter.ReturnCode -ColumnPrefixFilter.filterKeyValue(Cellcell) +QualifierFilter.filterKeyValue(Cellv) Filter.ReturnCode -SingleColumnValueFilter.filterKeyValue(Cellc) +FuzzyRowFilter.filterKeyValue(Cellc) Filter.ReturnCode -ColumnCountGetFilter.filterKeyValue(Cellv) +KeyOnlyFilter.filterKeyValue(Cellignored) Filter.ReturnCode -MultipleColumnPrefixFilter.filterKeyValue(Cellkv) +PrefixFilter.filterKeyValue(Cellv) Filter.ReturnCode -FamilyFilter.filterKeyValue(Cellv)
[18/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html b/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html index 5b6ae97..10b1dad 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html @@ -256,11 +256,11 @@ ServerName -SplitLogTask.getServerName() +Server.getServerName() ServerName -Server.getServerName() +SplitLogTask.getServerName() static ServerName @@ -601,11 +601,11 @@ private ServerName -AsyncProcess.AsyncRequestFutureImpl.SingleServerRequestRunnable.server +FastFailInterceptorContext.server private ServerName -FastFailInterceptorContext.server +AsyncProcess.AsyncRequestFutureImpl.SingleServerRequestRunnable.server private ServerName @@ -946,15 +946,9 @@ boolean -ClusterStatusListener.isDeadServer(ServerNamesn) -Check if we know if a server is dead. - - - -boolean ConnectionImplementation.isDeadServer(ServerNamesn) - + boolean ClusterConnection.isDeadServer(ServerNameserverName) Deprecated. @@ -962,6 +956,12 @@ + +boolean +ClusterStatusListener.isDeadServer(ServerNamesn) +Check if we know if a server is dead. + + protected boolean PreemptiveFastFailInterceptor.isServerInFailureMap(ServerNameserverName) @@ -1041,15 +1041,15 @@ HBaseAdmin.rollWALWriterImpl(ServerNamesn) +(package private) void +RegionServerCallable.setClientByServiceName(ServerNameservice) + + (package private) abstract void AbstractRegionServerCallable.setClientByServiceName(ServerNameserviceName) Set the Rpc client for Client services - -(package private) void -RegionServerCallable.setClientByServiceName(ServerNameservice) - private void AsyncProcess.AsyncRequestFutureImpl.setError(intindex, @@ -1285,13 +1285,13 @@ long -ExponentialClientBackoffPolicy.getBackoffTime(ServerNameserverName, +ClientBackoffPolicyFactory.NoBackoffPolicy.getBackoffTime(ServerNameserverName, byte[]region, ServerStatisticsstats) long -ClientBackoffPolicyFactory.NoBackoffPolicy.getBackoffTime(ServerNameserverName, +ExponentialClientBackoffPolicy.getBackoffTime(ServerNameserverName, byte[]region, ServerStatisticsstats) @@ -1422,49 +1422,49 @@ void -BaseMasterAndRegionObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, HRegionInforegion, ServerNamesrcServer, -ServerNamedestServer) +ServerNamedestServer) +Called after the region move has been requested. + void -BaseMasterObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterAndRegionObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, HRegionInforegion, ServerNamesrcServer, ServerNamedestServer) void -MasterObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, HRegionInforegion, ServerNamesrcServer, -ServerNamedestServer) -Called after the region move has been requested. - +ServerNamedestServer) void -BaseMasterAndRegionObserver.preMove(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.preMove(ObserverContextMasterCoprocessorEnvironmentctx, HRegionInforegion, ServerNamesrcServer, - ServerNamedestServer) + ServerNamedestServer) +Called prior to moving a given region from one region server to another. + void -BaseMasterObserver.preMove(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterAndRegionObserver.preMove(ObserverContextMasterCoprocessorEnvironmentctx, HRegionInforegion, ServerNamesrcServer, ServerNamedestServer) void -MasterObserver.preMove(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.preMove(ObserverContextMasterCoprocessorEnvironmentctx, HRegionInforegion, ServerNamesrcServer, - ServerNamedestServer) -Called prior to moving a given region from one region server to another. - + ServerNamedestServer) @@ -2441,11 +2441,9 @@ -(package private) void -AssignmentManager.regionOnline(HRegionInforegionInfo, -ServerNamesn) -Marks the region as online. - +void +RegionStates.regionOnline(HRegionInfohri, +ServerNameserverName) void @@ -2455,17 +2453,13 @@ -void -RegionStates.regionOnline(HRegionInfohri, -ServerNameserverName) - - (package private) void -AssignmentManager.regionOnline(HRegionInforegionInfo, -ServerNamesn, -longopenSeqNum) +AssignmentManager.regionOnline(HRegionInforegionInfo, +ServerNamesn) +Marks the region
[52/52] hbase-site git commit: Empty commit
Empty commit Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/e947fdc2 Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/e947fdc2 Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/e947fdc2 Branch: refs/heads/asf-site Commit: e947fdc2558bc54a2b7c735af6d6b53a4ce8ad5f Parents: f55baeb Author: Dima SpivakAuthored: Thu Sep 15 18:56:38 2016 -0700 Committer: Dima Spivak Committed: Thu Sep 15 18:56:38 2016 -0700 -- --
[02/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/codec/class-use/Codec.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/codec/class-use/Codec.html b/devapidocs/org/apache/hadoop/hbase/codec/class-use/Codec.html index 8189115..2745cb0 100644 --- a/devapidocs/org/apache/hadoop/hbase/codec/class-use/Codec.html +++ b/devapidocs/org/apache/hadoop/hbase/codec/class-use/Codec.html @@ -161,13 +161,13 @@ AbstractRpcClient.codec -protected Codec -RpcConnection.codec - - private Codec NettyRpcDuplexHandler.codec + +protected Codec +RpcConnection.codec + private Codec RpcServer.Connection.codec http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/class-use/PrefixTreeBlockMeta.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/class-use/PrefixTreeBlockMeta.html b/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/class-use/PrefixTreeBlockMeta.html index 9db866a..5cafbf7 100644 --- a/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/class-use/PrefixTreeBlockMeta.html +++ b/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/class-use/PrefixTreeBlockMeta.html @@ -325,11 +325,11 @@ protected PrefixTreeBlockMeta -MvccVersionDecoder.blockMeta +TimestampDecoder.blockMeta protected PrefixTreeBlockMeta -TimestampDecoder.blockMeta +MvccVersionDecoder.blockMeta @@ -342,12 +342,12 @@ void -MvccVersionDecoder.initOnBlock(PrefixTreeBlockMetablockMeta, +TimestampDecoder.initOnBlock(PrefixTreeBlockMetablockMeta, ByteBuffblock) void -TimestampDecoder.initOnBlock(PrefixTreeBlockMetablockMeta, +MvccVersionDecoder.initOnBlock(PrefixTreeBlockMetablockMeta, ByteBuffblock) @@ -398,15 +398,15 @@ -protected PrefixTreeBlockMeta -ColumnNodeWriter.blockMeta - - private PrefixTreeBlockMeta ColumnSectionWriter.blockMeta fields + +protected PrefixTreeBlockMeta +ColumnNodeWriter.blockMeta + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/encode/class-use/PrefixTreeEncoder.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/encode/class-use/PrefixTreeEncoder.html b/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/encode/class-use/PrefixTreeEncoder.html index 0c99165..1b2191c 100644 --- a/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/encode/class-use/PrefixTreeEncoder.html +++ b/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/encode/class-use/PrefixTreeEncoder.html @@ -147,13 +147,13 @@ booleanincludeMvccVersion) -static PrefixTreeEncoder -EncoderFactory.checkOut(http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true; title="class or interface in java.io">OutputStreamoutputStream, +PrefixTreeEncoder +EncoderPool.checkOut(http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true; title="class or interface in java.io">OutputStreamoutputStream, booleanincludeMvccVersion) -PrefixTreeEncoder -EncoderPool.checkOut(http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true; title="class or interface in java.io">OutputStreamoutputStream, +static PrefixTreeEncoder +EncoderFactory.checkOut(http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true; title="class or interface in java.io">OutputStreamoutputStream, booleanincludeMvccVersion) @@ -178,13 +178,13 @@ EncoderPoolImpl.checkIn(PrefixTreeEncoderencoder) -static void -EncoderFactory.checkIn(PrefixTreeEncoderencoder) - - void EncoderPool.checkIn(PrefixTreeEncoderencoder) + +static void +EncoderFactory.checkIn(PrefixTreeEncoderencoder) + protected static PrefixTreeEncoder EncoderFactory.prepareEncoder(PrefixTreeEncoderencoder, http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/encode/other/class-use/ColumnNodeType.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/encode/other/class-use/ColumnNodeType.html b/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/encode/other/class-use/ColumnNodeType.html index 4d99b4d..6a172f0 100644 --- a/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/encode/other/class-use/ColumnNodeType.html +++ b/devapidocs/org/apache/hadoop/hbase/codec/prefixtree/encode/other/class-use/ColumnNodeType.html @@ -153,13 +153,13 @@ -protected ColumnNodeType -ColumnNodeWriter.nodeType - - private ColumnNodeType ColumnSectionWriter.nodeType + +protected ColumnNodeType +ColumnNodeWriter.nodeType +
[29/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/HealthChecker.HealthCheckerExitStatus.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/HealthChecker.HealthCheckerExitStatus.html b/devapidocs/org/apache/hadoop/hbase/HealthChecker.HealthCheckerExitStatus.html index 0a5c25e..50d2b7b 100644 --- a/devapidocs/org/apache/hadoop/hbase/HealthChecker.HealthCheckerExitStatus.html +++ b/devapidocs/org/apache/hadoop/hbase/HealthChecker.HealthCheckerExitStatus.html @@ -272,7 +272,7 @@ the order they are declared. values -public staticHealthChecker.HealthCheckerExitStatus[]values() +public staticHealthChecker.HealthCheckerExitStatus[]values() Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -292,7 +292,7 @@ for (HealthChecker.HealthCheckerExitStatus c : HealthChecker.HealthCheckerExitSt valueOf -public staticHealthChecker.HealthCheckerExitStatusvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +public staticHealthChecker.HealthCheckerExitStatusvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/KeepDeletedCells.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/KeepDeletedCells.html b/devapidocs/org/apache/hadoop/hbase/KeepDeletedCells.html index abc228f..965a0e1 100644 --- a/devapidocs/org/apache/hadoop/hbase/KeepDeletedCells.html +++ b/devapidocs/org/apache/hadoop/hbase/KeepDeletedCells.html @@ -263,7 +263,7 @@ the order they are declared. values -public staticKeepDeletedCells[]values() +public staticKeepDeletedCells[]values() Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -283,7 +283,7 @@ for (KeepDeletedCells c : KeepDeletedCells.values()) valueOf -public staticKeepDeletedCellsvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +public staticKeepDeletedCellsvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/KeyValue.KVComparator.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/KeyValue.KVComparator.html b/devapidocs/org/apache/hadoop/hbase/KeyValue.KVComparator.html index b4317ba..f1f6b99 100644 --- a/devapidocs/org/apache/hadoop/hbase/KeyValue.KVComparator.html +++ b/devapidocs/org/apache/hadoop/hbase/KeyValue.KVComparator.html @@ -125,7 +125,7 @@ var activeTableTab = "activeTableTab"; http://docs.oracle.com/javase/8/docs/api/java/lang/Deprecated.html?is-external=true; title="class or interface in java.lang">@Deprecated -public static class KeyValue.KVComparator +public static class KeyValue.KVComparator extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements org.apache.hadoop.io.RawComparatorCell, KeyValue.SamePrefixComparatorbyte[] Compare KeyValues. When we compare KeyValues, we only compare the Key @@ -446,7 +446,7 @@ implements org.apache.hadoop.io.RawComparator KVComparator -publicKVComparator() +publicKVComparator() Deprecated. @@ -464,7 +464,7 @@ implements org.apache.hadoop.io.RawComparator getLegacyKeyComparatorName -publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetLegacyKeyComparatorName() +publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetLegacyKeyComparatorName() Deprecated. The HFileV2 file format's trailer contains this class name. We reinterpret this and instantiate the appropriate comparator. @@ -481,7 +481,7 @@ implements org.apache.hadoop.io.RawComparator compare -publicintcompare(byte[]l, +publicintcompare(byte[]l,
[21/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/HTableDescriptor.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/HTableDescriptor.html b/devapidocs/org/apache/hadoop/hbase/class-use/HTableDescriptor.html index f90e5fa..d3abc30 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/HTableDescriptor.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/HTableDescriptor.html @@ -576,23 +576,23 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. HTableDescriptor -HTable.getTableDescriptor() +Table.getTableDescriptor() Gets the table descriptor for this table. -protected HTableDescriptor -HBaseAdmin.CreateTableFuture.getTableDescriptor() +HTableDescriptor +HTable.getTableDescriptor() +Gets the table descriptor for this table. + protected HTableDescriptor -HBaseAdmin.TableFuture.getTableDescriptor() +HBaseAdmin.CreateTableFuture.getTableDescriptor() -HTableDescriptor -Table.getTableDescriptor() -Gets the table descriptor for this table. - +protected HTableDescriptor +HBaseAdmin.TableFuture.getTableDescriptor() HTableDescriptor @@ -1005,182 +1005,170 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -BaseMasterAndRegionObserver.postCloneSnapshot(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postCloneSnapshot(ObserverContextMasterCoprocessorEnvironmentctx, org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.SnapshotDescriptionsnapshot, - HTableDescriptorhTableDescriptor) + HTableDescriptorhTableDescriptor) +Called after a snapshot clone operation has been requested. + void -BaseMasterObserver.postCloneSnapshot(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterAndRegionObserver.postCloneSnapshot(ObserverContextMasterCoprocessorEnvironmentctx, org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.SnapshotDescriptionsnapshot, HTableDescriptorhTableDescriptor) void -MasterObserver.postCloneSnapshot(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.postCloneSnapshot(ObserverContextMasterCoprocessorEnvironmentctx, org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.SnapshotDescriptionsnapshot, - HTableDescriptorhTableDescriptor) -Called after a snapshot clone operation has been requested. - + HTableDescriptorhTableDescriptor) void -BaseMasterAndRegionObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, HTableDescriptordesc, - HRegionInfo[]regions) + HRegionInfo[]regions) +Called after the createTable operation has been requested. + void -BaseMasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterAndRegionObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, HTableDescriptordesc, HRegionInfo[]regions) void -MasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, HTableDescriptordesc, - HRegionInfo[]regions) -Called after the createTable operation has been requested. - + HRegionInfo[]regions) void -BaseMasterAndRegionObserver.postCompletedModifyTableAction(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postCompletedModifyTableAction(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, - HTableDescriptorhtd) + HTableDescriptorhtd) +Called after to modifying a table's properties. + void -BaseMasterObserver.postCompletedModifyTableAction(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterAndRegionObserver.postCompletedModifyTableAction(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HTableDescriptorhtd) void -MasterObserver.postCompletedModifyTableAction(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.postCompletedModifyTableAction(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, - HTableDescriptorhtd) -Called after to modifying a table's properties. - + HTableDescriptorhtd) void
[41/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/util/class-use/PositionedByteRange.html -- diff --git a/apidocs/org/apache/hadoop/hbase/util/class-use/PositionedByteRange.html b/apidocs/org/apache/hadoop/hbase/util/class-use/PositionedByteRange.html index 806d631..ef54c71 100644 --- a/apidocs/org/apache/hadoop/hbase/util/class-use/PositionedByteRange.html +++ b/apidocs/org/apache/hadoop/hbase/util/class-use/PositionedByteRange.html @@ -124,105 +124,105 @@ -T -FixedLengthWrapper.decode(PositionedByteRangesrc) +T +DataType.decode(PositionedByteRangesrc) +Read an instance of T from the buffer src. + -http://docs.oracle.com/javase/8/docs/api/java/lang/Short.html?is-external=true; title="class or interface in java.lang">Short -OrderedInt16.decode(PositionedByteRangesrc) +http://docs.oracle.com/javase/8/docs/api/java/lang/Number.html?is-external=true; title="class or interface in java.lang">Number +OrderedNumeric.decode(PositionedByteRangesrc) -byte[] -OrderedBlob.decode(PositionedByteRangesrc) +http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">Long +RawLong.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">Long -OrderedInt64.decode(PositionedByteRangesrc) +http://docs.oracle.com/javase/8/docs/api/java/lang/Short.html?is-external=true; title="class or interface in java.lang">Short +RawShort.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/Number.html?is-external=true; title="class or interface in java.lang">Number -OrderedNumeric.decode(PositionedByteRangesrc) +http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object[] +Struct.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String -OrderedString.decode(PositionedByteRangesrc) +T +FixedLengthWrapper.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/Short.html?is-external=true; title="class or interface in java.lang">Short -RawShort.decode(PositionedByteRangesrc) +http://docs.oracle.com/javase/8/docs/api/java/lang/Byte.html?is-external=true; title="class or interface in java.lang">Byte +RawByte.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">Long -RawLong.decode(PositionedByteRangesrc) +http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String +RawString.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true; title="class or interface in java.lang">Integer -RawInteger.decode(PositionedByteRangesrc) +http://docs.oracle.com/javase/8/docs/api/java/lang/Byte.html?is-external=true; title="class or interface in java.lang">Byte +OrderedInt8.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/Double.html?is-external=true; title="class or interface in java.lang">Double -RawDouble.decode(PositionedByteRangesrc) +byte[] +RawBytes.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String -RawString.decode(PositionedByteRangesrc) +T +TerminatedWrapper.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true; title="class or interface in java.lang">Integer -OrderedInt32.decode(PositionedByteRangesrc) +http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String +OrderedString.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/Double.html?is-external=true; title="class or interface in java.lang">Double -OrderedFloat64.decode(PositionedByteRangesrc) +http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">Long +OrderedInt64.decode(PositionedByteRangesrc) -byte[] -RawBytes.decode(PositionedByteRangesrc) +http://docs.oracle.com/javase/8/docs/api/java/lang/Short.html?is-external=true; title="class or interface in java.lang">Short +OrderedInt16.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/Float.html?is-external=true; title="class or interface in java.lang">Float -OrderedFloat32.decode(PositionedByteRangesrc) +byte[] +OrderedBlobVar.decode(PositionedByteRangesrc) -http://docs.oracle.com/javase/8/docs/api/java/lang/Byte.html?is-external=true; title="class or interface
[26/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/CellComparator.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/CellComparator.html b/devapidocs/org/apache/hadoop/hbase/class-use/CellComparator.html index cd64938..5cd629d 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/CellComparator.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/CellComparator.html @@ -251,47 +251,47 @@ int -RowIndexSeekerV1.compareKey(CellComparatorcomparator, - Cellkey) - - -int DataBlockEncoder.EncodedSeeker.compareKey(CellComparatorcomparator, Cellkey) Compare the given key against the current key + +int +RowIndexSeekerV1.compareKey(CellComparatorcomparator, + Cellkey) + DataBlockEncoder.EncodedSeeker -RowIndexCodecV1.createSeeker(CellComparatorcomparator, +CopyKeyDataBlockEncoder.createSeeker(CellComparatorcomparator, HFileBlockDecodingContextdecodingCtx) DataBlockEncoder.EncodedSeeker -DiffKeyDeltaEncoder.createSeeker(CellComparatorcomparator, +RowIndexCodecV1.createSeeker(CellComparatorcomparator, HFileBlockDecodingContextdecodingCtx) DataBlockEncoder.EncodedSeeker -PrefixKeyDeltaEncoder.createSeeker(CellComparatorcomparator, -HFileBlockDecodingContextdecodingCtx) +DataBlockEncoder.createSeeker(CellComparatorcomparator, +HFileBlockDecodingContextdecodingCtx) +Create a HFileBlock seeker which find KeyValues within a block. + DataBlockEncoder.EncodedSeeker -CopyKeyDataBlockEncoder.createSeeker(CellComparatorcomparator, +FastDiffDeltaEncoder.createSeeker(CellComparatorcomparator, HFileBlockDecodingContextdecodingCtx) DataBlockEncoder.EncodedSeeker -FastDiffDeltaEncoder.createSeeker(CellComparatorcomparator, +PrefixKeyDeltaEncoder.createSeeker(CellComparatorcomparator, HFileBlockDecodingContextdecodingCtx) DataBlockEncoder.EncodedSeeker -DataBlockEncoder.createSeeker(CellComparatorcomparator, -HFileBlockDecodingContextdecodingCtx) -Create a HFileBlock seeker which find KeyValues within a block. - +DiffKeyDeltaEncoder.createSeeker(CellComparatorcomparator, +HFileBlockDecodingContextdecodingCtx) @@ -329,30 +329,30 @@ protected CellComparator -HFile.WriterFactory.comparator +HFileWriterImpl.comparator +Key comparator. + -private CellComparator -HFileReaderImpl.comparator -Key comparator - +protected CellComparator +HFile.WriterFactory.comparator -protected CellComparator -CompoundBloomFilterBase.comparator -Comparator used to compare Bloom filter keys +private CellComparator +HFileBlockIndex.CellBasedKeyBlockIndexReader.comparator +Needed doing lookup on blocks. protected CellComparator -HFileWriterImpl.comparator -Key comparator. +CompoundBloomFilterBase.comparator +Comparator used to compare Bloom filter keys private CellComparator -HFileBlockIndex.CellBasedKeyBlockIndexReader.comparator -Needed doing lookup on blocks. +HFileReaderImpl.comparator +Key comparator @@ -531,48 +531,48 @@ private CellComparator -HStore.comparator +MemStoreScanner.comparator private CellComparator -Segment.comparator +StoreFileWriter.Builder.comparator private CellComparator AbstractMemStore.comparator -private CellComparator -StoreFileWriter.Builder.comparator - - protected CellComparator StripeMultiFileWriter.comparator + +private CellComparator +Segment.comparator + private CellComparator -MemStoreScanner.comparator +ScanInfo.comparator private CellComparator -ScanInfo.comparator +HStore.comparator protected CellComparator -StripeStoreFlusher.StripeFlushRequest.comparator +HRegion.RegionScannerImpl.comparator protected CellComparator -HRegion.RegionScannerImpl.comparator +StripeStoreFlusher.StripeFlushRequest.comparator -private CellComparator -DefaultStoreFileManager.kvComparator - - protected CellComparator KeyValueHeap.KVScannerComparator.kvComparator + +private CellComparator +DefaultStoreFileManager.kvComparator + @@ -594,25 +594,17 @@ CellComparator -HStore.getComparator() +StoreFileReader.getComparator() protected CellComparator -Segment.getComparator() -Returns the Cell comparator used by this segment - - - -CellComparator -KeyValueHeap.KVScannerComparator.getComparator() - - -CellComparator -StoreFileReader.getComparator() +AbstractMemStore.getComparator() protected CellComparator -AbstractMemStore.getComparator() +Segment.getComparator() +Returns the Cell comparator used by this segment + CellComparator @@ -623,9 +615,17 @@ Store.getComparator() +CellComparator +KeyValueHeap.KVScannerComparator.getComparator() + + (package private) CellComparator StoreFileScanner.getComparator() + +CellComparator +HStore.getComparator() + @@ -658,6 +658,12 @@ +protected void
[07/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/SingleResponse.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/SingleResponse.html b/devapidocs/org/apache/hadoop/hbase/client/SingleResponse.html new file mode 100644 index 000..f9c14c9 --- /dev/null +++ b/devapidocs/org/apache/hadoop/hbase/client/SingleResponse.html @@ -0,0 +1,371 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + + +SingleResponse (Apache HBase 2.0.0-SNAPSHOT API) + + + + + +var methods = {"i0":10,"i1":10,"i2":10}; +var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; +var altColor = "altColor"; +var rowColor = "rowColor"; +var tableTab = "tableTab"; +var activeTableTab = "activeTableTab"; + + +JavaScript is disabled on your browser. + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +PrevClass +NextClass + + +Frames +NoFrames + + +AllClasses + + + + + + + +Summary: +Nested| +Field| +Constr| +Method + + +Detail: +Field| +Constr| +Method + + + + + + + + +org.apache.hadoop.hbase.client +Class SingleResponse + + + +http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">java.lang.Object + + +org.apache.hadoop.hbase.client.AbstractResponse + + +org.apache.hadoop.hbase.client.SingleResponse + + + + + + + + + + +@InterfaceAudience.Private +public class SingleResponse +extends AbstractResponse +Class for single action response + + + + + + + + + + + +Nested Class Summary + +Nested Classes + +Modifier and Type +Class and Description + + +static class +SingleResponse.Entry + + + + + + +Nested classes/interfaces inherited from classorg.apache.hadoop.hbase.client.AbstractResponse +AbstractResponse.ResponseType + + + + + + + + +Field Summary + +Fields + +Modifier and Type +Field and Description + + +private SingleResponse.Entry +entry + + + + + + + + + +Constructor Summary + +Constructors + +Constructor and Description + + +SingleResponse() + + + + + + + + + +Method Summary + +All MethodsInstance MethodsConcrete Methods + +Modifier and Type +Method and Description + + +SingleResponse.Entry +getEntry() + + +void +setEntry(SingleResponse.Entryentry) + + +AbstractResponse.ResponseType +type() + + + + + + +Methods inherited from classjava.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object +http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--; title="class or interface in java.lang">clone, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-; title="class or interface in java.lang">equals, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--; title="class or interface in java.lang">finalize, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--; title="class or interface in java.lang">getClass, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--; title="class or interface in java.lang">hashCode, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--; title="class or interface in java.lang">notify, http://docs.oracle.com/javase/8/docs/api/java/lang /Object.html?is-external=true#notifyAll--" title="class or interface in java.lang">notifyAll, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#toString--; title="class or interface in java.lang">toString, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait--; title="class or interface in java.lang">wait, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-; title="class or interface in java.lang">wait, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-int-; title="class or interface in java.lang">wait + + + + + + + + + + + + + + +Field Detail + + + + + +entry +privateSingleResponse.Entry entry + + + + + + + + + +Constructor Detail + + + + + +SingleResponse +publicSingleResponse() + + + + + + + + + +Method Detail + + + + + +getEntry +publicSingleResponse.EntrygetEntry() + + + + + + + +setEntry +publicvoidsetEntry(SingleResponse.Entryentry) + + + + + + + +type +publicAbstractResponse.ResponseTypetype() + +Specified by:
[42/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/ipc/ServerTooBusyException.html -- diff --git a/apidocs/org/apache/hadoop/hbase/ipc/ServerTooBusyException.html b/apidocs/org/apache/hadoop/hbase/ipc/ServerTooBusyException.html new file mode 100644 index 000..1abf095 --- /dev/null +++ b/apidocs/org/apache/hadoop/hbase/ipc/ServerTooBusyException.html @@ -0,0 +1,283 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + + +ServerTooBusyException (Apache HBase 2.0.0-SNAPSHOT API) + + + + + + + +JavaScript is disabled on your browser. + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +PrevClass +NextClass + + +Frames +NoFrames + + +AllClasses + + + + + + + +Summary: +Nested| +Field| +Constr| +Method + + +Detail: +Field| +Constr| +Method + + + + + + + + +org.apache.hadoop.hbase.ipc +Class ServerTooBusyException + + + +http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">java.lang.Object + + +http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">java.lang.Throwable + + +http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true; title="class or interface in java.lang">java.lang.Exception + + +http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">java.io.IOException + + +org.apache.hadoop.hbase.HBaseIOException + + +org.apache.hadoop.hbase.DoNotRetryIOException + + +org.apache.hadoop.hbase.ipc.ServerTooBusyException + + + + + + + + + + + + + + + + + +All Implemented Interfaces: +http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable + + + +@InterfaceAudience.Public + @InterfaceStability.Evolving +public class ServerTooBusyException +extends DoNotRetryIOException +Throw this in rpc call if there are too many pending requests for one region server + +See Also: +Serialized Form + + + + + + + + + + + + +Constructor Summary + +Constructors + +Constructor and Description + + +ServerTooBusyException(http://docs.oracle.com/javase/8/docs/api/java/net/InetSocketAddress.html?is-external=true; title="class or interface in java.net">InetSocketAddressaddress, + longcount) + + + + + + + + + +Method Summary + + + + +Methods inherited from classjava.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">Throwable +http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#addSuppressed-java.lang.Throwable-; title="class or interface in java.lang">addSuppressed, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#fillInStackTrace--; title="class or interface in java.lang">fillInStackTrace, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#getCause--; title="class or interface in java.lang">getCause, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#getLocalizedMessage--; title="class or interface in java.lang">getLocalizedMessage, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#getMessage--; title="class or interface in java.lang">getMessage, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#getStackTrace--; title="class or inter face in java.lang">getStackTrace, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#getSuppressed--; title="class or interface in java.lang">getSuppressed, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#initCause-java.lang.Throwable-; title="class or interface in java.lang">initCause, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#printStackTrace--; title="class or interface in java.lang">printStackTrace, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#printStackTrace-java.io.PrintStream-; title="class or interface in java.lang">printStackTrace, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#printStackTrace-java.io.PrintWriter-; title="class or interface in java.lang">printStackTrace,
[04/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/class-use/Row.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/class-use/Row.html b/devapidocs/org/apache/hadoop/hbase/client/class-use/Row.html index 2020a7f..17d1a84 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/class-use/Row.html +++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/Row.html @@ -263,11 +263,11 @@ int -RowMutations.compareTo(Rowi) +RegionCoprocessorServiceExec.compareTo(Rowo) int -RegionCoprocessorServiceExec.compareTo(Rowo) +Get.compareTo(Rowother) int @@ -275,11 +275,11 @@ int -Get.compareTo(Rowother) +Increment.compareTo(Rowi) int -Increment.compareTo(Rowi) +RowMutations.compareTo(Rowi) private boolean @@ -385,14 +385,14 @@ void -HTable.batch(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends Rowactions, +Table.batch(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends Rowactions, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object[]results) Method that does a batch call on Deletes, Gets, Puts, Increments and Appends. void -Table.batch(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends Rowactions, +HTable.batch(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends Rowactions, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object[]results) Method that does a batch call on Deletes, Gets, Puts, Increments and Appends. @@ -410,7 +410,7 @@ Rvoid -HTable.batchCallback(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends Rowactions, +Table.batchCallback(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends Rowactions, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object[]results, Batch.CallbackRcallback) Same as Table.batch(List, Object[]), but with a callback. @@ -418,7 +418,7 @@ Rvoid -Table.batchCallback(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends Rowactions, +HTable.batchCallback(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends Rowactions, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object[]results, Batch.CallbackRcallback) Same as Table.batch(List, Object[]), but with a callback. http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/class-use/RowMutations.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/class-use/RowMutations.html b/devapidocs/org/apache/hadoop/hbase/client/class-use/RowMutations.html index 6e47f74..e17b86d 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/class-use/RowMutations.html +++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/RowMutations.html @@ -127,23 +127,23 @@ service. boolean -HTable.checkAndMutate(byte[]row, +Table.checkAndMutate(byte[]row, byte[]family, byte[]qualifier, CompareFilter.CompareOpcompareOp, byte[]value, - RowMutationsrm) + RowMutationsmutation) Atomically checks if a row/family/qualifier value matches the expected value. boolean -Table.checkAndMutate(byte[]row, +HTable.checkAndMutate(byte[]row, byte[]family, byte[]qualifier, CompareFilter.CompareOpcompareOp, byte[]value, - RowMutationsmutation) + RowMutationsrm) Atomically checks if a row/family/qualifier value matches the expected value. @@ -158,13 +158,13 @@ service. void -HTable.mutateRow(RowMutationsrm) +Table.mutateRow(RowMutationsrm) Performs multiple mutations atomically on a single row. void -Table.mutateRow(RowMutationsrm) +HTable.mutateRow(RowMutationsrm) Performs multiple mutations atomically on a single row. http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/class-use/RpcRetryingCaller.html
[17/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/TableName.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/TableName.html b/devapidocs/org/apache/hadoop/hbase/class-use/TableName.html index be0d9df..e740553 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/TableName.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/TableName.html @@ -758,52 +758,52 @@ service. -protected TableName -AbstractRegionServerCallable.tableName - - private TableName -BufferedMutatorParams.tableName +HRegionLocator.tableName - + protected TableName RpcRetryingCallerWithReadReplicas.tableName + +private TableName +BufferedMutatorImpl.tableName + private TableName -AsyncProcess.AsyncRequestFutureImpl.tableName +TableState.tableName -protected TableName -RegionAdminServiceCallable.tableName +private TableName +BufferedMutatorParams.tableName -private TableName -HRegionLocator.tableName +protected TableName +RegionAdminServiceCallable.tableName private TableName -HTable.tableName +AsyncProcess.AsyncRequestFutureImpl.tableName private TableName -ClientScanner.tableName +HTable.tableName private TableName -TableState.tableName +ClientScanner.tableName private TableName -HBaseAdmin.TableFuture.tableName +ScannerCallableWithReplicas.tableName private TableName -ScannerCallableWithReplicas.tableName +HBaseAdmin.TableFuture.tableName -private TableName -BufferedMutatorImpl.tableName +protected TableName +AbstractRegionServerCallable.tableName @@ -837,31 +837,31 @@ service. TableName -RegionLocator.getName() -Gets the fully qualified table name instance of this table. - +HRegionLocator.getName() TableName -HRegionLocator.getName() +BufferedMutatorImpl.getName() TableName -HTable.getName() +BufferedMutator.getName() +Gets the fully qualified table name instance of the table that this BufferedMutator writes to. + TableName -BufferedMutator.getName() -Gets the fully qualified table name instance of the table that this BufferedMutator writes to. +Table.getName() +Gets the fully qualified table name instance of this table. TableName -BufferedMutatorImpl.getName() +HTable.getName() TableName -Table.getName() +RegionLocator.getName() Gets the fully qualified table name instance of this table. @@ -875,22 +875,22 @@ service. TableName -AbstractRegionServerCallable.getTableName() +TableState.getTableName() +Table name for state + TableName BufferedMutatorParams.getTableName() -TableName -TableState.getTableName() -Table name for state - - - protected TableName HBaseAdmin.TableFuture.getTableName() + +TableName +AbstractRegionServerCallable.getTableName() + private TableName HBaseAdmin.getTableNameBeforeRestoreSnapshot(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringsnapshotName) @@ -1023,16 +1023,16 @@ service. void +ClusterConnection.cacheLocation(TableNametableName, + RegionLocationslocation) + + +void MetaCache.cacheLocation(TableNametableName, RegionLocationslocations) Put a newly discovered HRegionLocation into the cache. - -void -ClusterConnection.cacheLocation(TableNametableName, - RegionLocationslocation) - private void ConnectionImplementation.cacheLocation(TableNametableName, @@ -1366,15 +1366,15 @@ service. BufferedMutator +ConnectionImplementation.getBufferedMutator(TableNametableName) + + +BufferedMutator Connection.getBufferedMutator(TableNametableName) Retrieve a BufferedMutator for performing client-side buffering of writes. - -BufferedMutator -ConnectionImplementation.getBufferedMutator(TableNametableName) - (package private) RegionLocations ConnectionImplementation.getCachedLocation(TableNametableName, @@ -1488,36 +1488,36 @@ service. RegionLocator -Connection.getRegionLocator(TableNametableName) -Retrieve a RegionLocator implementation to inspect region information on a table. - +ConnectionImplementation.getRegionLocator(TableNametableName) RegionLocator -ConnectionImplementation.getRegionLocator(TableNametableName) +Connection.getRegionLocator(TableNametableName) +Retrieve a RegionLocator implementation to inspect region information on a table. + Table +ConnectionImplementation.getTable(TableNametableName) + + +Table Connection.getTable(TableNametableName) Retrieve a Table implementation for accessing a table. - + Table -ConnectionImplementation.getTable(TableNametableName) +ConnectionImplementation.getTable(TableNametableName, +http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true; title="class or interface in java.util.concurrent">ExecutorServicepool) - + Table Connection.getTable(TableNametableName,
[32/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/index-all.html -- diff --git a/devapidocs/index-all.html b/devapidocs/index-all.html index 057f153..7524c9b 100644 --- a/devapidocs/index-all.html +++ b/devapidocs/index-all.html @@ -392,6 +392,14 @@ AbstractRegionServerCallable(Connection, TableName, byte[]) - Constructor for class org.apache.hadoop.hbase.client.AbstractRegionServerCallable +AbstractResponse - Class in org.apache.hadoop.hbase.client + +This class is used to extend AP to process single action request, like delete, get etc. + +AbstractResponse() - Constructor for class org.apache.hadoop.hbase.client.AbstractResponse + +AbstractResponse.ResponseType - Enum in org.apache.hadoop.hbase.client + AbstractRpcChannel(AbstractRpcClient?, InetSocketAddress, User, int) - Constructor for class org.apache.hadoop.hbase.ipc.AbstractRpcClient.AbstractRpcChannel AbstractRpcClientT extends RpcConnection - Class in org.apache.hadoop.hbase.ipc @@ -412,6 +420,24 @@ Async rpc channel that goes via hbase rpc. +AbstractStateMachineNamespaceProcedureTState - Class in org.apache.hadoop.hbase.master.procedure + +Base class for all the Namespace procedures that want to use a StateMachineProcedure. + +AbstractStateMachineNamespaceProcedure() - Constructor for class org.apache.hadoop.hbase.master.procedure.AbstractStateMachineNamespaceProcedure + +AbstractStateMachineNamespaceProcedure(MasterProcedureEnv) - Constructor for class org.apache.hadoop.hbase.master.procedure.AbstractStateMachineNamespaceProcedure + +AbstractStateMachineTableProcedureTState - Class in org.apache.hadoop.hbase.master.procedure + +Base class for all the Table procedures that want to use a StateMachineProcedure. + +AbstractStateMachineTableProcedure() - Constructor for class org.apache.hadoop.hbase.master.procedure.AbstractStateMachineTableProcedure + +AbstractStateMachineTableProcedure(MasterProcedureEnv) - Constructor for class org.apache.hadoop.hbase.master.procedure.AbstractStateMachineTableProcedure + +AbstractStateMachineTableProcedure(MasterProcedureEnv, ProcedurePrepareLatch) - Constructor for class org.apache.hadoop.hbase.master.procedure.AbstractStateMachineTableProcedure + accept(Class?) - Method in class org.apache.hadoop.hbase.mapreduce.KeyValueSerialization accept(Class?) - Method in class org.apache.hadoop.hbase.mapreduce.MutationSerialization @@ -647,38 +673,18 @@ acquiredZnode - Variable in class org.apache.hadoop.hbase.procedure.ZKProcedureUtil -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.AddColumnFamilyProcedure +acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.AbstractStateMachineNamespaceProcedure -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.CloneSnapshotProcedure +acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.AbstractStateMachineTableProcedure acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.CreateNamespaceProcedure acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.CreateTableProcedure -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.DeleteColumnFamilyProcedure - -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.DeleteNamespaceProcedure - -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.DeleteTableProcedure - -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.DisableTableProcedure - acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.DispatchMergingRegionsProcedure -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.EnableTableProcedure - -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.ModifyColumnFamilyProcedure - -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.ModifyNamespaceProcedure - -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.ModifyTableProcedure - -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.RestoreSnapshotProcedure - acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.ServerCrashProcedure -acquireLock(MasterProcedureEnv) - Method in class org.apache.hadoop.hbase.master.procedure.TruncateTableProcedure - acquireLock(TEnvironment) - Method in class org.apache.hadoop.hbase.procedure2.Procedure The user should override this method, and try to take a lock if necessary. @@ -3528,6 +3534,10 @@ Overhead for AtomicLong
[28/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/KeyValue.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/KeyValue.html b/devapidocs/org/apache/hadoop/hbase/KeyValue.html index ee92d96..b2c45db 100644 --- a/devapidocs/org/apache/hadoop/hbase/KeyValue.html +++ b/devapidocs/org/apache/hadoop/hbase/KeyValue.html @@ -1450,7 +1450,7 @@ public static final LOWESTKEY -public static finalKeyValue LOWESTKEY +public static finalKeyValue LOWESTKEY Lowest possible key. Makes a Key with highest possible Timestamp, empty row and column. No key can be equal or lower than this one in memstore or in store file. @@ -1462,7 +1462,7 @@ public static final bytes -protectedbyte[] bytes +protectedbyte[] bytes @@ -1471,7 +1471,7 @@ public static final offset -protectedint offset +protectedint offset @@ -1480,7 +1480,7 @@ public static final length -protectedint length +protectedint length @@ -1489,7 +1489,7 @@ public static final seqId -privatelong seqId +privatelong seqId @@ -1506,7 +1506,7 @@ public static final KeyValue -publicKeyValue() +publicKeyValue() Writable Constructor -- DO NOT USE @@ -1516,7 +1516,7 @@ public static final KeyValue -publicKeyValue(byte[]bytes) +publicKeyValue(byte[]bytes) Creates a KeyValue from the start of the specified byte array. Presumes bytes content is formatted as a KeyValue blob. @@ -1531,7 +1531,7 @@ public static final KeyValue -publicKeyValue(byte[]bytes, +publicKeyValue(byte[]bytes, intoffset) Creates a KeyValue from the specified byte array and offset. Presumes bytes content starting at offset is @@ -1549,7 +1549,7 @@ public static final KeyValue -publicKeyValue(byte[]bytes, +publicKeyValue(byte[]bytes, intoffset, intlength) Creates a KeyValue from the specified byte array, starting at offset, and @@ -1568,7 +1568,7 @@ public static final KeyValue -publicKeyValue(byte[]bytes, +publicKeyValue(byte[]bytes, intoffset, intlength, longts) @@ -1589,7 +1589,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, longtimestamp) Constructs KeyValue structure filled with null value. Sets type to KeyValue.Type.Maximum @@ -1606,7 +1606,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, longtimestamp, KeyValue.Typetype) Constructs KeyValue structure filled with null value. @@ -1623,7 +1623,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, byte[]family, byte[]qualifier) Constructs KeyValue structure filled with null value. @@ -1642,7 +1642,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, byte[]family, byte[]qualifier, byte[]value) @@ -1662,7 +1662,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, byte[]family, byte[]qualifier, longtimestamp, @@ -1686,7 +1686,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, byte[]family, byte[]qualifier, longtimestamp, @@ -1710,7 +1710,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, byte[]family, byte[]qualifier, longtimestamp, @@ -1736,7 +1736,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, byte[]family, byte[]qualifier, longtimestamp, @@ -1762,7 +1762,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, byte[]family, byte[]qualifier, longtimestamp, @@ -1788,7 +1788,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, byte[]family, byte[]qualifier, longtimestamp, @@ -1817,7 +1817,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, byte[]family, byte[]qualifier, longtimestamp, @@ -1844,7 +1844,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, byte[]family, byte[]qualifier, intqoffset, @@ -1879,7 +1879,7 @@ public static final KeyValue -publicKeyValue(byte[]row, +publicKeyValue(byte[]row, byte[]family, byte[]qualifier, intqoffset, @@ -1912,7 +1912,7 @@ public static final KeyValue
[44/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/client/CompactionState.html -- diff --git a/apidocs/org/apache/hadoop/hbase/client/CompactionState.html b/apidocs/org/apache/hadoop/hbase/client/CompactionState.html index ffea9b5..0dae31a 100644 --- a/apidocs/org/apache/hadoop/hbase/client/CompactionState.html +++ b/apidocs/org/apache/hadoop/hbase/client/CompactionState.html @@ -259,7 +259,7 @@ the order they are declared. values -public staticCompactionState[]values() +public staticCompactionState[]values() Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -279,7 +279,7 @@ for (CompactionState c : CompactionState.values()) valueOf -public staticCompactionStatevalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +public staticCompactionStatevalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/client/Durability.html -- diff --git a/apidocs/org/apache/hadoop/hbase/client/Durability.html b/apidocs/org/apache/hadoop/hbase/client/Durability.html index 79e88f1..b50dd2b 100644 --- a/apidocs/org/apache/hadoop/hbase/client/Durability.html +++ b/apidocs/org/apache/hadoop/hbase/client/Durability.html @@ -294,7 +294,7 @@ the order they are declared. values -public staticDurability[]values() +public staticDurability[]values() Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -314,7 +314,7 @@ for (Durability c : Durability.values()) valueOf -public staticDurabilityvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +public staticDurabilityvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/client/IsolationLevel.html -- diff --git a/apidocs/org/apache/hadoop/hbase/client/IsolationLevel.html b/apidocs/org/apache/hadoop/hbase/client/IsolationLevel.html index 326d86e..7cc1a9e 100644 --- a/apidocs/org/apache/hadoop/hbase/client/IsolationLevel.html +++ b/apidocs/org/apache/hadoop/hbase/client/IsolationLevel.html @@ -257,7 +257,7 @@ the order they are declared. values -public staticIsolationLevel[]values() +public staticIsolationLevel[]values() Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -277,7 +277,7 @@ for (IsolationLevel c : IsolationLevel.values()) valueOf -public staticIsolationLevelvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +public staticIsolationLevelvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/org/apache/hadoop/hbase/client/Scan.html -- diff --git a/apidocs/org/apache/hadoop/hbase/client/Scan.html b/apidocs/org/apache/hadoop/hbase/client/Scan.html index 820ae9b..92fb615 100644 --- a/apidocs/org/apache/hadoop/hbase/client/Scan.html +++ b/apidocs/org/apache/hadoop/hbase/client/Scan.html @@ -972,7 +972,7 @@ public static finalhttp://docs.oracle.com/javase/8/docs/api/java/ setStartRow -publicScansetStartRow(byte[]startRow) +publicScansetStartRow(byte[]startRow) Set the start row of the scan. If the specified row does not exist, the Scanner will start from the @@ -982,6 +982,9 @@ public static
[51/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a. Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/f55baeba Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/f55baeba Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/f55baeba Branch: refs/heads/asf-site Commit: f55baebae470765dbb4766f7e40fb9502462e135 Parents: eae3345 Author: jenkinsAuthored: Thu Sep 15 14:50:46 2016 + Committer: Dima Spivak Committed: Thu Sep 15 18:56:08 2016 -0700 -- acid-semantics.html | 4 +- apache_hbase_reference_guide.pdf| 29033 + apache_hbase_reference_guide.pdfmarks | 4 +- apidocs/allclasses-frame.html | 1 + apidocs/allclasses-noframe.html | 1 + apidocs/constant-values.html| 166 +- apidocs/index-all.html |16 + .../hadoop/hbase/DoNotRetryIOException.html | 2 +- apidocs/org/apache/hadoop/hbase/HConstants.html | 512 +- .../apache/hadoop/hbase/KeepDeletedCells.html | 4 +- .../org/apache/hadoop/hbase/class-use/Cell.html | 246 +- .../hbase/class-use/DoNotRetryIOException.html |10 +- .../hbase/class-use/HBaseIOException.html |12 +- .../class-use/NamespaceNotFoundException.html |46 +- .../hadoop/hbase/class-use/ServerName.html | 4 +- .../hadoop/hbase/class-use/TableName.html | 4 +- .../org/apache/hadoop/hbase/client/Admin.html | 326 +- .../hadoop/hbase/client/CompactionState.html| 4 +- .../apache/hadoop/hbase/client/Durability.html | 4 +- .../hadoop/hbase/client/IsolationLevel.html | 4 +- .../org/apache/hadoop/hbase/client/Scan.html| 116 +- .../hadoop/hbase/client/SnapshotType.html | 4 +- .../hbase/client/class-use/Durability.html |18 +- .../hadoop/hbase/client/class-use/Mutation.html | 8 +- .../hadoop/hbase/client/class-use/Result.html |30 +- .../hadoop/hbase/client/class-use/Row.html | 4 +- .../hadoop/hbase/client/class-use/Scan.html |12 +- .../hadoop/hbase/client/package-tree.html | 6 +- .../hbase/filter/CompareFilter.CompareOp.html | 4 +- .../filter/class-use/Filter.ReturnCode.html |62 +- .../hadoop/hbase/filter/class-use/Filter.html |42 +- .../hadoop/hbase/filter/package-tree.html | 4 +- .../io/class-use/ImmutableBytesWritable.html|30 +- .../hadoop/hbase/io/class-use/TimeRange.html| 8 +- .../hbase/io/encoding/DataBlockEncoding.html| 4 +- .../hbase/ipc/ServerNotRunningYetException.html | 4 +- .../hbase/ipc/ServerTooBusyException.html | 283 + .../hbase/ipc/StoppedRpcClientException.html| 4 +- .../ipc/class-use/ServerTooBusyException.html | 125 + .../apache/hadoop/hbase/ipc/package-frame.html | 1 + .../hadoop/hbase/ipc/package-summary.html |12 +- .../apache/hadoop/hbase/ipc/package-tree.html | 1 + .../mapreduce/class-use/TableRecordReader.html | 4 +- .../org/apache/hadoop/hbase/package-use.html|15 +- .../apache/hadoop/hbase/quotas/QuotaType.html | 4 +- .../hbase/quotas/ThrottlingException.Type.html | 4 +- .../hadoop/hbase/quotas/package-tree.html | 4 +- .../hadoop/hbase/regionserver/BloomType.html| 4 +- .../org/apache/hadoop/hbase/util/Counter.html |23 +- .../hadoop/hbase/util/class-use/Order.html |42 +- .../util/class-use/PositionedByteRange.html | 386 +- apidocs/overview-tree.html |21 +- apidocs/serialized-form.html| 5 + .../org/apache/hadoop/hbase/HConstants.html | 1104 +- .../org/apache/hadoop/hbase/client/Admin.html | 3507 +- .../org/apache/hadoop/hbase/client/Scan.html| 1226 +- .../hbase/ipc/ServerTooBusyException.html | 110 + .../org/apache/hadoop/hbase/util/Counter.html |46 +- book.html |93 +- bulk-loads.html | 4 +- checkstyle-aggregate.html | 23576 ++--- coc.html| 4 +- cygwin.html | 4 +- dependencies.html | 4 +- dependency-convergence.html | 4 +- dependency-info.html| 4 +- dependency-management.html | 4 +- devapidocs/allclasses-frame.html| 7 + devapidocs/allclasses-noframe.html | 7 + devapidocs/constant-values.html | 176 +- devapidocs/deprecated-list.html | 376 +- devapidocs/index-all.html |
[49/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apache_hbase_reference_guide.pdfmarks -- diff --git a/apache_hbase_reference_guide.pdfmarks b/apache_hbase_reference_guide.pdfmarks index 735465b..00dcd99 100644 --- a/apache_hbase_reference_guide.pdfmarks +++ b/apache_hbase_reference_guide.pdfmarks @@ -2,8 +2,8 @@ /Author (Apache HBase Team) /Subject () /Keywords () - /ModDate (D:20160912181033) - /CreationDate (D:20160912181033) + /ModDate (D:20160915144153) + /CreationDate (D:20160915144153) /Creator (Asciidoctor PDF 1.5.0.alpha.6, based on Prawn 1.2.1) /Producer () /DOCINFO pdfmark http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/allclasses-frame.html -- diff --git a/apidocs/allclasses-frame.html b/apidocs/allclasses-frame.html index f44b3b4..14631ff 100644 --- a/apidocs/allclasses-frame.html +++ b/apidocs/allclasses-frame.html @@ -284,6 +284,7 @@ ServerLoad ServerName ServerNotRunningYetException +ServerTooBusyException SimpleByteRange SimpleMutableByteRange SimplePositionedByteRange http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/allclasses-noframe.html -- diff --git a/apidocs/allclasses-noframe.html b/apidocs/allclasses-noframe.html index f716f57..0597dcd 100644 --- a/apidocs/allclasses-noframe.html +++ b/apidocs/allclasses-noframe.html @@ -284,6 +284,7 @@ ServerLoad ServerName ServerNotRunningYetException +ServerTooBusyException SimpleByteRange SimpleMutableByteRange SimplePositionedByteRange http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/constant-values.html -- diff --git a/apidocs/constant-values.html b/apidocs/constant-values.html index 01054ee..4c60407 100644 --- a/apidocs/constant-values.html +++ b/apidocs/constant-values.html @@ -759,544 +759,558 @@ 100L + + +publicstaticfinalint +DEFAULT_HBASE_CLIENT_PERSERVER_REQUESTS_THRESHOLD +2147483647 + + publicstaticfinalint DEFAULT_HBASE_CLIENT_RETRIES_NUMBER 31 - + publicstaticfinalint DEFAULT_HBASE_CLIENT_SCANNER_CACHING 2147483647 - + publicstaticfinallong DEFAULT_HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE 2097152L - + publicstaticfinalint DEFAULT_HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD 6 - + publicstaticfinalint DEFAULT_HBASE_META_BLOCK_SIZE 8192 - + publicstaticfinalint DEFAULT_HBASE_META_SCANNER_CACHING 100 - + publicstaticfinalint DEFAULT_HBASE_META_VERSIONS 3 - + publicstaticfinalint DEFAULT_HBASE_RPC_SHORTOPERATION_TIMEOUT 1 - + publicstaticfinalint DEFAULT_HBASE_RPC_TIMEOUT 6 - + publicstaticfinalint DEFAULT_HBASE_SERVER_PAUSE 1000 - + publicstaticfinallong DEFAULT_HBASE_SERVER_SCANNER_MAX_RESULT_SIZE 104857600L - + publicstaticfinalint DEFAULT_HEALTH_FAILURE_THRESHOLD 3 - + publicstaticfinallong DEFAULT_HEALTH_SCRIPT_TIMEOUT 6L - + publicstaticfinalfloat DEFAULT_HEAP_OCCUPANCY_HIGH_WATERMARK 0.980190734863f - + publicstaticfinalfloat DEFAULT_HEAP_OCCUPANCY_LOW_WATERMARK 0.94988079071f - + publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_HOST "0.0.0.0" - + publicstaticfinalboolean DEFAULT_HREGION_EDITS_REPLAY_SKIP_ERRORS false - + publicstaticfinalint DEFAULT_HREGION_MEMSTORE_BLOCK_MULTIPLIER 4 - + publicstaticfinalint DEFAULT_HSTORE_OPEN_AND_CLOSE_THREADS_MAX 1 - + publicstaticfinalint DEFAULT_MASTER_HANLDER_COUNT 25 - + publicstaticfinalint DEFAULT_MASTER_INFOPORT 16010 - + publicstaticfinalint DEFAULT_MASTER_PORT 16000 - + publicstaticfinalboolean DEFAULT_MASTER_TYPE_BACKUP false - + publicstaticfinallong DEFAULT_MAX_FILE_SIZE 10737418240L - + publicstaticfinalint DEFAULT_META_REPLICA_NUM 1 - + publicstaticfinaldouble DEFAULT_REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT 0.5 - + publicstaticfinalint DEFAULT_REGION_SERVER_HANDLER_COUNT 30 - + publicstaticfinalint DEFAULT_REGION_SERVER_HIGH_PRIORITY_HANDLER_COUNT 20 - + publicstaticfinalint DEFAULT_REGION_SERVER_REPLICATION_HANDLER_COUNT 3 - + publicstaticfinalint DEFAULT_REGIONSERVER_INFOPORT 16030 - + publicstaticfinallong DEFAULT_REGIONSERVER_METRICS_PERIOD 5000L - + publicstaticfinalint DEFAULT_REGIONSERVER_PORT 16020 - + publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_STATUS_MULTICAST_ADDRESS "226.1.1.3" - +
[38/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/apidocs/src-html/org/apache/hadoop/hbase/client/Admin.html -- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/client/Admin.html b/apidocs/src-html/org/apache/hadoop/hbase/client/Admin.html index 0437841..ba4fef3 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/client/Admin.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/client/Admin.html @@ -40,1762 +40,1765 @@ 032import org.apache.hadoop.hbase.HRegionInfo; 033import org.apache.hadoop.hbase.HTableDescriptor; 034import org.apache.hadoop.hbase.NamespaceDescriptor; -035import org.apache.hadoop.hbase.ProcedureInfo; -036import org.apache.hadoop.hbase.ServerName; -037import org.apache.hadoop.hbase.TableExistsException; -038import org.apache.hadoop.hbase.TableName; -039import org.apache.hadoop.hbase.TableNotFoundException; -040import org.apache.hadoop.hbase.classification.InterfaceAudience; -041import org.apache.hadoop.hbase.classification.InterfaceStability; -042import org.apache.hadoop.hbase.client.security.SecurityCapability; -043import org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel; -044import org.apache.hadoop.hbase.quotas.QuotaFilter; -045import org.apache.hadoop.hbase.quotas.QuotaRetriever; -046import org.apache.hadoop.hbase.quotas.QuotaSettings; -047import org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException; -048import org.apache.hadoop.hbase.snapshot.HBaseSnapshotException; -049import org.apache.hadoop.hbase.snapshot.RestoreSnapshotException; -050import org.apache.hadoop.hbase.snapshot.SnapshotCreationException; -051import org.apache.hadoop.hbase.snapshot.UnknownSnapshotException; -052import org.apache.hadoop.hbase.util.Pair; -053 -054/** -055 * The administrative API for HBase. Obtain an instance from an {@link Connection#getAdmin()} and -056 * call {@link #close()} afterwards. -057 * pAdmin can be used to create, drop, list, enable and disable tables, add and drop table -058 * column families and other administrative operations. -059 * -060 * @see ConnectionFactory -061 * @see Connection -062 * @see Table -063 * @since 0.99.0 -064 */ -065@InterfaceAudience.Public -066@InterfaceStability.Evolving -067public interface Admin extends Abortable, Closeable { -068 int getOperationTimeout(); -069 -070 @Override -071 void abort(String why, Throwable e); -072 -073 @Override -074 boolean isAborted(); -075 -076 /** -077 * @return Connection used by this object. -078 */ -079 Connection getConnection(); -080 -081 /** -082 * @param tableName Table to check. -083 * @return True if table exists already. -084 * @throws IOException -085 */ -086 boolean tableExists(final TableName tableName) throws IOException; -087 -088 /** -089 * List all the userspace tables. -090 * -091 * @return - returns an array of HTableDescriptors -092 * @throws IOException if a remote or network exception occurs -093 */ -094 HTableDescriptor[] listTables() throws IOException; -095 -096 /** -097 * List all the userspace tables matching the given pattern. -098 * -099 * @param pattern The compiled regular expression to match against -100 * @return - returns an array of HTableDescriptors -101 * @throws IOException if a remote or network exception occurs -102 * @see #listTables() -103 */ -104 HTableDescriptor[] listTables(Pattern pattern) throws IOException; -105 -106 /** -107 * List all the userspace tables matching the given regular expression. -108 * -109 * @param regex The regular expression to match against -110 * @return - returns an array of HTableDescriptors -111 * @throws IOException if a remote or network exception occurs -112 * @see #listTables(java.util.regex.Pattern) -113 */ -114 HTableDescriptor[] listTables(String regex) throws IOException; -115 -116 /** -117 * List all the tables matching the given pattern. -118 * -119 * @param pattern The compiled regular expression to match against -120 * @param includeSysTables False to match only against userspace tables -121 * @return - returns an array of HTableDescriptors -122 * @throws IOException if a remote or network exception occurs -123 * @see #listTables() -124 */ -125 HTableDescriptor[] listTables(Pattern pattern, boolean includeSysTables) -126 throws IOException; -127 -128 /** -129 * List all the tables matching the given pattern. -130 * -131 * @param regex The regular expression to match against -132 * @param includeSysTables False to match only against userspace tables -133 * @return - returns an array of HTableDescriptors -134 * @throws IOException if a remote or network exception occurs -135 * @see #listTables(java.util.regex.Pattern, boolean) -136 */ -137 HTableDescriptor[] listTables(String regex, boolean includeSysTables) -138 throws IOException; -139 -140 /** -141 * List all of the names of
[03/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/package-frame.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/package-frame.html b/devapidocs/org/apache/hadoop/hbase/client/package-frame.html index 33c9c1d..6818aed 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/package-frame.html +++ b/devapidocs/org/apache/hadoop/hbase/client/package-frame.html @@ -44,6 +44,7 @@ AbstractClientScanner AbstractRegionServerCallable +AbstractResponse Action Append AsyncProcess @@ -157,6 +158,8 @@ ScannerCallableWithReplicas SecureBulkLoadClient ServerStatisticTracker +SingleResponse +SingleResponse.Entry SnapshotDescription TableSnapshotScanner TableState @@ -168,6 +171,7 @@ Enums +AbstractResponse.ResponseType AsyncProcess.Retry AsyncProcess.RowChecker.ReturnCode CompactionState http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/package-summary.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/package-summary.html b/devapidocs/org/apache/hadoop/hbase/client/package-summary.html index f8040c6..0aaf9be 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/package-summary.html +++ b/devapidocs/org/apache/hadoop/hbase/client/package-summary.html @@ -264,62 +264,68 @@ +AbstractResponse + +This class is used to extend AP to process single action request, like delete, get etc. + + + ActionR A Get, Put, Increment, Append, or Delete associated with it's region. - + Append Performs Append operations on a single row. - + AsyncProcess This class allows a continuous flow of requests. - + AsyncProcess.BatchErrors - + AsyncProcess.ListRowAccessT - + AsyncProcess.ReplicaResultState Sync point for calls to multiple replicas for the same user request (Get). - + AsyncProcess.RequestSizeChecker limit the request size for each regionserver. - + AsyncProcess.RowCheckerHost Collect all advices from checkers and make the final decision. - + AsyncProcess.SubmittedSizeChecker limit the heapsize of total submitted data. - + AsyncProcess.TaskCountChecker limit the max number of tasks in an AsyncProcess. - + BufferedMutatorImpl @@ -327,489 +333,489 @@ but meant for batched, potentially asynchronous puts. - + BufferedMutatorParams Parameters for instantiating a BufferedMutator. - + CancellableRegionServerCallableT This class is used to unify HTable calls with AsyncProcess Framework. - + ClientAsyncPrefetchScanner ClientAsyncPrefetchScanner implements async scanner behaviour. - + ClientIdGenerator The class that is able to determine some unique strings for the client, such as an IP address, PID, and composite deterministic ID. - + ClientScanner Implements the scanner interface for the HBase client. - + ClientSideRegionScanner A client scanner for a region opened for read-only on the client side. - + ClientSimpleScanner ClientSimpleScanner implements a sync scanner behaviour. - + ClientSmallReversedScanner Client scanner for small reversed scan. - + ClientSmallScanner Client scanner for small scan. - + ClientSmallScanner.SmallScannerCallable - + ClientSmallScanner.SmallScannerCallableFactory - + ClusterStatusListener A class that receives the cluster status, and provide it as a set of service to the client. - + ConnectionConfiguration Configuration parameters for the connection. - + ConnectionFactory A non-instantiable class that manages creation of Connections. - + ConnectionImplementation Main implementation of Connection and ClusterConnection interfaces. - + ConnectionImplementation.MasterServiceState State of the MasterService connection/setup. - + ConnectionImplementation.NoNonceGenerator Dummy nonce generator for disabled nonces. - + ConnectionImplementation.ServerErrorTracker The record of errors for servers. - + ConnectionImplementation.ServerErrorTracker.ServerErrors The record of errors for a server. - + ConnectionUtils Utility used by client connections. - + ConnectionUtils.MasterlessConnection Some tests shut down the master. - + CoprocessorHConnection Connection to an HTable from within a Coprocessor. - + DelayingRunnerT A wrapper for a runnable for a group of actions for a single regionserver. - + DelegatingRetryingCallableT,D extends RetryingCallableT Helper callable for internal use when you just want to override a single method of a RetryingCallable. - + Delete Used to perform Delete operations on a single row. - + FailureInfo Keeps track of repeated failures to any region server. - + FastFailInterceptorContext - +
[27/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html b/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html index 4353442..5a6bfa3 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html @@ -1322,32 +1322,32 @@ service. -static boolean -CellUtil.matchingRowColumn(Cellleft, +boolean +KeyValue.KVComparator.matchingRowColumn(Cellleft, Cellright) +Deprecated. Compares the row and column of two keyvalues for equality -boolean -KeyValue.KVComparator.matchingRowColumn(Cellleft, +static boolean +CellUtil.matchingRowColumn(Cellleft, Cellright) -Deprecated. Compares the row and column of two keyvalues for equality -static boolean -CellUtil.matchingRows(Cellleft, +boolean +KeyValue.KVComparator.matchingRows(Cellleft, Cellright) +Deprecated. Compares the row of two keyvalues for equality -boolean -KeyValue.KVComparator.matchingRows(Cellleft, +static boolean +CellUtil.matchingRows(Cellleft, Cellright) -Deprecated. Compares the row of two keyvalues for equality @@ -1711,23 +1711,23 @@ service. -Increment -Increment.add(Cellcell) -Add the specified KeyValue to this operation. - - - Put Put.add(Cellkv) Add the specified KeyValue to this Put operation. - + Append Append.add(Cellcell) Add column and value to this Append operation. + +Increment +Increment.add(Cellcell) +Add the specified KeyValue to this operation. + + Delete Delete.addDeleteMarker(Cellkv) @@ -1820,23 +1820,23 @@ service. Delete.setFamilyCellMap(http://docs.oracle.com/javase/8/docs/api/java/util/NavigableMap.html?is-external=true; title="class or interface in java.util">NavigableMapbyte[],http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCellmap) +Put +Put.setFamilyCellMap(http://docs.oracle.com/javase/8/docs/api/java/util/NavigableMap.html?is-external=true; title="class or interface in java.util">NavigableMapbyte[],http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCellmap) + + Mutation Mutation.setFamilyCellMap(http://docs.oracle.com/javase/8/docs/api/java/util/NavigableMap.html?is-external=true; title="class or interface in java.util">NavigableMapbyte[],http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCellmap) Method for setting the put's familyMap - -Increment -Increment.setFamilyCellMap(http://docs.oracle.com/javase/8/docs/api/java/util/NavigableMap.html?is-external=true; title="class or interface in java.util">NavigableMapbyte[],http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCellmap) - -Put -Put.setFamilyCellMap(http://docs.oracle.com/javase/8/docs/api/java/util/NavigableMap.html?is-external=true; title="class or interface in java.util">NavigableMapbyte[],http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCellmap) - - Append Append.setFamilyCellMap(http://docs.oracle.com/javase/8/docs/api/java/util/NavigableMap.html?is-external=true; title="class or interface in java.util">NavigableMapbyte[],http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCellmap) + +Increment +Increment.setFamilyCellMap(http://docs.oracle.com/javase/8/docs/api/java/util/NavigableMap.html?is-external=true; title="class or interface in java.util">NavigableMapbyte[],http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCellmap) + @@ -1868,23 +1868,23 @@ service. -http://docs.oracle.com/javase/8/docs/api/java/math/BigDecimal.html?is-external=true; title="class or interface in java.math">BigDecimal -BigDecimalColumnInterpreter.getValue(byte[]colFamily, -byte[]colQualifier, -Cellkv) - - http://docs.oracle.com/javase/8/docs/api/java/lang/Double.html?is-external=true; title="class or interface in java.lang">Double DoubleColumnInterpreter.getValue(byte[]colFamily, byte[]colQualifier, Cellc) - + http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">Long LongColumnInterpreter.getValue(byte[]colFamily, byte[]colQualifier, Cellkv) + +http://docs.oracle.com/javase/8/docs/api/java/math/BigDecimal.html?is-external=true; title="class or interface in java.math">BigDecimal +BigDecimalColumnInterpreter.getValue(byte[]colFamily, +
[06/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/class-use/Connection.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/class-use/Connection.html b/devapidocs/org/apache/hadoop/hbase/client/class-use/Connection.html index e8a3fc1..23549e2 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/class-use/Connection.html +++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/Connection.html @@ -767,13 +767,13 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. -protected Connection -AbstractRegionServerCallable.connection - - (package private) Connection ConnectionImplementation.MasterServiceState.connection + +protected Connection +AbstractRegionServerCallable.connection + @@ -1040,11 +1040,11 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. private Connection -HRegionPartitioner.connection +TableInputFormatBase.connection private Connection -TableInputFormatBase.connection +HRegionPartitioner.connection @@ -1078,18 +1078,18 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. private Connection -HRegionPartitioner.connection - - -private Connection TableOutputFormat.TableRecordWriter.connection - + private Connection TableInputFormatBase.connection The underlying Connection of the table. + +private Connection +HRegionPartitioner.connection + (package private) Connection MultiTableOutputFormat.MultiTableRecordWriter.connection @@ -1202,11 +1202,11 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. private Connection -CatalogJanitor.connection +RegionPlacementMaintainer.connection private Connection -RegionPlacementMaintainer.connection +CatalogJanitor.connection private Connection http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/class-use/Consistency.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/class-use/Consistency.html b/devapidocs/org/apache/hadoop/hbase/client/class-use/Consistency.html index f7b1abb..79bd322 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/class-use/Consistency.html +++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/Consistency.html @@ -150,19 +150,19 @@ the order they are declared. -Query -Query.setConsistency(Consistencyconsistency) -Sets the consistency level for this operation - - - Scan Scan.setConsistency(Consistencyconsistency) - + Get Get.setConsistency(Consistencyconsistency) + +Query +Query.setConsistency(Consistencyconsistency) +Sets the consistency level for this operation + + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/class-use/Delete.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/class-use/Delete.html b/devapidocs/org/apache/hadoop/hbase/client/class-use/Delete.html index 786dde6..0afb414 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/class-use/Delete.html +++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/Delete.html @@ -335,7 +335,7 @@ service. boolean -HTable.checkAndDelete(byte[]row, +Table.checkAndDelete(byte[]row, byte[]family, byte[]qualifier, byte[]value, @@ -346,7 +346,7 @@ service. boolean -Table.checkAndDelete(byte[]row, +HTable.checkAndDelete(byte[]row, byte[]family, byte[]qualifier, byte[]value, @@ -365,7 +365,7 @@ service. boolean -HTable.checkAndDelete(byte[]row, +Table.checkAndDelete(byte[]row, byte[]family, byte[]qualifier, CompareFilter.CompareOpcompareOp, @@ -377,7 +377,7 @@ service. boolean -Table.checkAndDelete(byte[]row, +HTable.checkAndDelete(byte[]row, byte[]family, byte[]qualifier, CompareFilter.CompareOpcompareOp, @@ -398,13 +398,13 @@ service. void -HTable.delete(Deletedelete) +Table.delete(Deletedelete) Deletes the specified cells/row. void -Table.delete(Deletedelete) +HTable.delete(Deletedelete) Deletes the specified cells/row. @@ -423,13 +423,13 @@ service. void -HTable.delete(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListDeletedeletes) +Table.delete(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListDeletedeletes) Deletes the specified cells/rows in bulk. void -Table.delete(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListDeletedeletes)
[01/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a.
Repository: hbase-site Updated Branches: refs/heads/asf-site eae3345d7 -> e947fdc25 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/MasterCoprocessorEnvironment.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/MasterCoprocessorEnvironment.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/MasterCoprocessorEnvironment.html index d37c023..4e68b24 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/MasterCoprocessorEnvironment.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/MasterCoprocessorEnvironment.html @@ -122,114 +122,104 @@ void -BaseMasterAndRegionObserver.postAbortProcedure(ObserverContextMasterCoprocessorEnvironmentctx) +MasterObserver.postAbortProcedure(ObserverContextMasterCoprocessorEnvironmentctx) +Called after a abortProcedure request has been processed. + void -BaseMasterObserver.postAbortProcedure(ObserverContextMasterCoprocessorEnvironmentctx) +BaseMasterAndRegionObserver.postAbortProcedure(ObserverContextMasterCoprocessorEnvironmentctx) void -MasterObserver.postAbortProcedure(ObserverContextMasterCoprocessorEnvironmentctx) -Called after a abortProcedure request has been processed. - +BaseMasterObserver.postAbortProcedure(ObserverContextMasterCoprocessorEnvironmentctx) void -BaseMasterAndRegionObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) -Deprecated. +Deprecated. +As of release 2.0.0, this will be removed in HBase 3.0.0 + (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). + Use MasterObserver.postAddColumnFamily(ObserverContext, TableName, HColumnDescriptor). + void -BaseMasterObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterAndRegionObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) -Deprecated. -As of release 2.0.0, this will be removed in HBase 3.0.0 - (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). - Use BaseMasterObserver.postAddColumnFamily(ObserverContext, TableName, HColumnDescriptor). - +Deprecated. void -MasterObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.postAddColumn(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) Deprecated. As of release 2.0.0, this will be removed in HBase 3.0.0 (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). - Use MasterObserver.postAddColumnFamily(ObserverContext, TableName, HColumnDescriptor). + Use BaseMasterObserver.postAddColumnFamily(ObserverContext, TableName, HColumnDescriptor). void -BaseMasterAndRegionObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, - HColumnDescriptorcolumnFamily) + HColumnDescriptorcolumnFamily) +Called after the new column family has been created. + void -BaseMasterObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterAndRegionObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) void -MasterObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterObserver.postAddColumnFamily(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, - HColumnDescriptorcolumnFamily) -Called after the new column family has been created. - + HColumnDescriptorcolumnFamily) void -BaseMasterAndRegionObserver.postAddColumnHandler(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postAddColumnHandler(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName, HColumnDescriptorcolumnFamily) -Deprecated. +Deprecated. +As of release 2.0.0, this will be removed in HBase 3.0.0 + (https://issues.apache.org/jira/browse/HBASE-13645;>HBASE-13645). Use + MasterObserver.postCompletedAddColumnFamilyAction(ObserverContext, TableName, HColumnDescriptor). + void -BaseMasterObserver.postAddColumnHandler(ObserverContextMasterCoprocessorEnvironmentctx, +BaseMasterAndRegionObserver.postAddColumnHandler(ObserverContextMasterCoprocessorEnvironmentctx, TableNametableName,
hbase git commit: HBASE-16640 TimeoutBlockingQueue#remove() should return whether the entry is removed
Repository: hbase Updated Branches: refs/heads/branch-1 069d1f73f -> 76a076026 HBASE-16640 TimeoutBlockingQueue#remove() should return whether the entry is removed Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/76a07602 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/76a07602 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/76a07602 Branch: refs/heads/branch-1 Commit: 76a07602691fd5b63390b9dbde0a84672602c0be Parents: 069d1f7 Author: tedyuAuthored: Thu Sep 15 17:35:59 2016 -0700 Committer: tedyu Committed: Thu Sep 15 17:35:59 2016 -0700 -- .../hadoop/hbase/procedure2/ProcedureExecutor.java | 5 +++-- .../hbase/procedure2/util/TimeoutBlockingQueue.java| 8 +--- .../procedure2/util/TestTimeoutBlockingQueue.java | 13 - 3 files changed, 16 insertions(+), 10 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/76a07602/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java -- diff --git a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java index ee70dd1..4eb2796 100644 --- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java +++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java @@ -601,9 +601,10 @@ public class ProcedureExecutor { /** * Remove a chore procedure from the executor * @param chore the chore to remove + * @return whether the chore is removed */ - public void removeChore(final ProcedureInMemoryChore chore) { -waitingTimeout.remove(chore); + public boolean removeChore(final ProcedureInMemoryChore chore) { +return waitingTimeout.remove(chore); } /** http://git-wip-us.apache.org/repos/asf/hbase/blob/76a07602/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/util/TimeoutBlockingQueue.java -- diff --git a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/util/TimeoutBlockingQueue.java b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/util/TimeoutBlockingQueue.java index fceabb1..2292e63 100644 --- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/util/TimeoutBlockingQueue.java +++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/util/TimeoutBlockingQueue.java @@ -92,15 +92,17 @@ public class TimeoutBlockingQueue { } } - public void remove(E e) { + public boolean remove(E e) { +if (e == null) return false; lock.lock(); try { for (int i = 0; i < objects.length; ++i) { -if (objects[i] == e) { +if (e.equals(objects[i])) { objects[i] = null; - return; + return true; } } + return false; } finally { lock.unlock(); } http://git-wip-us.apache.org/repos/asf/hbase/blob/76a07602/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/util/TestTimeoutBlockingQueue.java -- diff --git a/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/util/TestTimeoutBlockingQueue.java b/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/util/TestTimeoutBlockingQueue.java index 5750650..3c52ea1 100644 --- a/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/util/TestTimeoutBlockingQueue.java +++ b/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/util/TestTimeoutBlockingQueue.java @@ -139,18 +139,21 @@ public class TestTimeoutBlockingQueue { TimeoutBlockingQueue queue = new TimeoutBlockingQueue(2, new TestObjectTimeoutRetriever()); -TestObject[] objs = new TestObject[5]; -for (int i = 0; i < objs.length; ++i) { +final int effectiveLen = 5; +TestObject[] objs = new TestObject[6]; +for (int i = 0; i < effectiveLen; ++i) { objs[i] = new TestObject(0, i * 10); queue.add(objs[i]); } +objs[effectiveLen] = new TestObject(0, effectiveLen * 10); queue.dump(); -for (int i = 0; i < objs.length; i += 2) { - queue.remove(objs[i]); +for (int i = 0; i < effectiveLen; i += 2) { + assertTrue(queue.remove(objs[i])); } +assertTrue(!queue.remove(objs[effectiveLen])); -for (int i = 0; i < objs.length; ++i) { +for (int i = 0; i < effectiveLen; ++i) { TestObject x = queue.poll(); assertEquals((i % 2) == 0 ? null : objs[i], x); }
hbase git commit: HBASE-16640 TimeoutBlockingQueue#remove() should return whether the entry is removed
Repository: hbase Updated Branches: refs/heads/master 8c4b09dfb -> e782d0bbd HBASE-16640 TimeoutBlockingQueue#remove() should return whether the entry is removed Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e782d0bb Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e782d0bb Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e782d0bb Branch: refs/heads/master Commit: e782d0bbdf265fddfcce5754cf2e2dbcc4ea Parents: 8c4b09d Author: tedyuAuthored: Thu Sep 15 17:34:23 2016 -0700 Committer: tedyu Committed: Thu Sep 15 17:34:23 2016 -0700 -- .../hadoop/hbase/procedure2/ProcedureExecutor.java | 5 +++-- .../hbase/procedure2/util/TimeoutBlockingQueue.java| 8 +--- .../procedure2/util/TestTimeoutBlockingQueue.java | 13 - 3 files changed, 16 insertions(+), 10 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/e782d0bb/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java -- diff --git a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java index 5042329..1a9010d 100644 --- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java +++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java @@ -615,9 +615,10 @@ public class ProcedureExecutor { /** * Remove a chore procedure from the executor * @param chore the chore to remove + * @return whether the chore is removed */ - public void removeChore(final ProcedureInMemoryChore chore) { -waitingTimeout.remove(chore); + public boolean removeChore(final ProcedureInMemoryChore chore) { +return waitingTimeout.remove(chore); } /** http://git-wip-us.apache.org/repos/asf/hbase/blob/e782d0bb/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/util/TimeoutBlockingQueue.java -- diff --git a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/util/TimeoutBlockingQueue.java b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/util/TimeoutBlockingQueue.java index fceabb1..2292e63 100644 --- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/util/TimeoutBlockingQueue.java +++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/util/TimeoutBlockingQueue.java @@ -92,15 +92,17 @@ public class TimeoutBlockingQueue { } } - public void remove(E e) { + public boolean remove(E e) { +if (e == null) return false; lock.lock(); try { for (int i = 0; i < objects.length; ++i) { -if (objects[i] == e) { +if (e.equals(objects[i])) { objects[i] = null; - return; + return true; } } + return false; } finally { lock.unlock(); } http://git-wip-us.apache.org/repos/asf/hbase/blob/e782d0bb/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/util/TestTimeoutBlockingQueue.java -- diff --git a/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/util/TestTimeoutBlockingQueue.java b/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/util/TestTimeoutBlockingQueue.java index 209d1c5..1f901b5 100644 --- a/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/util/TestTimeoutBlockingQueue.java +++ b/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/util/TestTimeoutBlockingQueue.java @@ -137,18 +137,21 @@ public class TestTimeoutBlockingQueue { TimeoutBlockingQueue queue = new TimeoutBlockingQueue(2, new TestObjectTimeoutRetriever()); -TestObject[] objs = new TestObject[5]; -for (int i = 0; i < objs.length; ++i) { +final int effectiveLen = 5; +TestObject[] objs = new TestObject[6]; +for (int i = 0; i < effectiveLen; ++i) { objs[i] = new TestObject(0, i * 10); queue.add(objs[i]); } +objs[effectiveLen] = new TestObject(0, effectiveLen * 10); queue.dump(); -for (int i = 0; i < objs.length; i += 2) { - queue.remove(objs[i]); +for (int i = 0; i < effectiveLen; i += 2) { + assertTrue(queue.remove(objs[i])); } +assertTrue(!queue.remove(objs[effectiveLen])); -for (int i = 0; i < objs.length; ++i) { +for (int i = 0; i < effectiveLen; ++i) { TestObject x = queue.poll(); assertEquals((i % 2) == 0 ? null : objs[i], x); }
hbase git commit: HBASE-16620 Fix backup command-line tool usability issues - addendum 4 adds more tests for command line
Repository: hbase Updated Branches: refs/heads/HBASE-7912 7650f6059 -> 759a2c17a HBASE-16620 Fix backup command-line tool usability issues - addendum 4 adds more tests for command line Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/759a2c17 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/759a2c17 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/759a2c17 Branch: refs/heads/HBASE-7912 Commit: 759a2c17a99b2392fb73bbfac5659e2837e9bba3 Parents: 7650f60 Author: tedyuAuthored: Thu Sep 15 11:49:12 2016 -0700 Committer: tedyu Committed: Thu Sep 15 11:49:12 2016 -0700 -- .../hbase/backup/impl/BackupCommands.java | 59 +++--- .../hbase/backup/TestBackupCommandLineTool.java | 194 +-- 2 files changed, 209 insertions(+), 44 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/759a2c17/hbase-client/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupCommands.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupCommands.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupCommands.java index 8f08094..1884788 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupCommands.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupCommands.java @@ -50,7 +50,7 @@ import com.google.common.collect.Lists; @InterfaceStability.Evolving public final class BackupCommands { - public final static String IGNORE = "ignore"; + public final static String INCORRECT_USAGE = "Incorrect usage"; public static final String USAGE = "Usage: hbase backup COMMAND [command-specific arguments]\n" + "where COMMAND is one of:\n" @@ -60,7 +60,7 @@ public final class BackupCommands { + " historyshow history of all successful backups\n" + " progress show the progress of the latest backup request\n" + " setbackup set management\n" - + "Run \'hbase backup help COMMAND\' to see help message for each command\n"; + + "Run \'hbase backup COMMAND -h\' to see help message for each command\n"; public static final String CREATE_CMD_USAGE = "Usage: hbase backup create [tables] [-set name] " @@ -118,7 +118,7 @@ public final class BackupCommands { { if (cmdline.hasOption("h") || cmdline.hasOption("help")) { printUsage(); -throw new IOException(IGNORE); +throw new IOException(INCORRECT_USAGE); } } @@ -179,20 +179,20 @@ public final class BackupCommands { if (cmdline == null || cmdline.getArgs() == null) { System.err.println("ERROR: missing arguments"); printUsage(); -System.exit(-1); +throw new IOException(INCORRECT_USAGE); } String[] args = cmdline.getArgs(); if (args.length < 3 || args.length > 4) { System.err.println("ERROR: wrong number of arguments: "+ args.length); printUsage(); -System.exit(-1); +throw new IOException(INCORRECT_USAGE); } if (!BackupType.FULL.toString().equalsIgnoreCase(args[1]) && !BackupType.INCREMENTAL.toString().equalsIgnoreCase(args[1])) { System.err.println("ERROR: invalid backup type: "+ args[1]); printUsage(); -System.exit(-1); +throw new IOException(INCORRECT_USAGE); } String tables = null; @@ -206,7 +206,7 @@ public final class BackupCommands { if (tables == null) { System.err.println("ERROR: Backup set '" + setName+ "' is either empty or does not exist"); printUsage(); - throw new IOException(IGNORE); + throw new IOException(INCORRECT_USAGE); } } else { tables = (args.length == 4) ? args[3] : null; @@ -224,7 +224,7 @@ public final class BackupCommands { String backupId = backupAdmin.backupTables(request); System.out.println("Backup session "+ backupId+" finished. Status: SUCCESS"); } catch (IOException e) { -System.out.println("Backup session finished. Status: FAILURE"); +System.err.println("Backup session finished. Status: FAILURE"); throw e; } } @@ -256,19 +256,19 @@ public final class BackupCommands { super.execute(); if (cmdline == null) { printUsage(); -System.exit(-1); +throw new IOException(INCORRECT_USAGE); } String[] args = cmdline.getArgs(); if (args == null || args.length == 0) { printUsage(); -System.exit(-1); +throw new IOException(INCORRECT_USAGE); } if (args.length != 2)
hbase git commit: HBASE-16624 Fix MVCC DeSerialization bug in the HFileScannerImpl
Repository: hbase Updated Branches: refs/heads/master 56be3ac7c -> 8c4b09dfb HBASE-16624 Fix MVCC DeSerialization bug in the HFileScannerImpl Change-Id: Ia970619ac7369d24ed432e827319dfdca16143c2 Signed-off-by: stackProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8c4b09df Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8c4b09df Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8c4b09df Branch: refs/heads/master Commit: 8c4b09dfbaf53fd770fe3963df6095fc690f2ef5 Parents: 56be3ac Author: Nitin Aggarwal Authored: Mon Sep 12 22:50:07 2016 -0700 Committer: stack Committed: Thu Sep 15 11:01:51 2016 -0700 -- .../java/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.java| 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/8c4b09df/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.java index fc1c04e..c9e6aea 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.java @@ -662,7 +662,8 @@ public class HFileReaderImpl implements HFile.Reader, Configurable { long i = 0; offsetFromPos++; if (remaining >= Bytes.SIZEOF_INT) { - i = blockBuffer.getIntAfterPosition(offsetFromPos); + // The int read has to be converted to unsigned long so the & op + i = (blockBuffer.getIntAfterPosition(offsetFromPos) & 0xL); remaining -= Bytes.SIZEOF_INT; offsetFromPos += Bytes.SIZEOF_INT; }
[6/7] hbase git commit: Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/hbase
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/hbase Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e6f8f6db Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e6f8f6db Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e6f8f6db Branch: refs/heads/master Commit: e6f8f6dbd0f7e801fd0fbafbe8cb35492bf08285 Parents: 156a8b2 1d6c90b Author: anoopsamjohnAuthored: Thu Sep 15 18:07:12 2016 +0530 Committer: anoopsamjohn Committed: Thu Sep 15 18:07:12 2016 +0530 -- .../org/apache/hadoop/hbase/client/Admin.java | 5 +- .../hadoop/hbase/client/AsyncProcess.java | 4 +- .../apache/hadoop/hbase/client/HBaseAdmin.java | 6 +- .../hadoop/hbase/ipc/AbstractRpcClient.java | 22 .../hbase/ipc/ServerTooBusyException.java | 38 ++ .../org/apache/hadoop/hbase/HConstants.java | 12 ++ .../java/org/apache/hadoop/hbase/KeyValue.java | 15 ++- .../src/main/resources/hbase-default.xml| 16 ++- .../AbstractStateMachineNamespaceProcedure.java | 70 +++ .../AbstractStateMachineTableProcedure.java | 111 + .../procedure/AddColumnFamilyProcedure.java | 38 ++ .../procedure/CloneSnapshotProcedure.java | 30 + .../procedure/CreateNamespaceProcedure.java | 28 + .../master/procedure/CreateTableProcedure.java | 43 ++- .../procedure/DeleteColumnFamilyProcedure.java | 38 ++ .../procedure/DeleteNamespaceProcedure.java | 34 +- .../master/procedure/DeleteTableProcedure.java | 49 ++-- .../master/procedure/DisableTableProcedure.java | 55 ++--- .../DispatchMergingRegionsProcedure.java| 16 +-- .../master/procedure/EnableTableProcedure.java | 55 ++--- .../procedure/MasterDDLOperationHelper.java | 16 --- .../procedure/ModifyColumnFamilyProcedure.java | 38 ++ .../procedure/ModifyNamespaceProcedure.java | 34 +- .../master/procedure/ModifyTableProcedure.java | 44 ++- .../procedure/RestoreSnapshotProcedure.java | 27 + .../procedure/TruncateTableProcedure.java | 36 ++ .../org/apache/hadoop/hbase/client/TestHCM.java | 119 ++- .../TestScannerHeartbeatMessages.java | 105 +++- hbase-shell/src/main/ruby/hbase/security.rb | 9 +- hbase-shell/src/main/ruby/hbase/table.rb| 81 + .../src/main/ruby/shell/commands/deleteall.rb | 17 ++- hbase-shell/src/test/ruby/hbase/table_test.rb | 12 ++ src/main/asciidoc/_chapters/developer.adoc | 60 ++ 33 files changed, 677 insertions(+), 606 deletions(-) --
[7/7] hbase git commit: HBASE-16626 User customized RegionScanner from 1.X is incompatible with 2.0.0's off-heap part. (Charlie Qiangeng Xu)
HBASE-16626 User customized RegionScanner from 1.X is incompatible with 2.0.0's off-heap part. (Charlie Qiangeng Xu) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/56be3ac7 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/56be3ac7 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/56be3ac7 Branch: refs/heads/master Commit: 56be3ac7c8d203710f844cd799f2fa3496f0515a Parents: e6f8f6d Author: anoopsamjohnAuthored: Thu Sep 15 18:07:43 2016 +0530 Committer: anoopsamjohn Committed: Thu Sep 15 18:07:43 2016 +0530 -- .../org/apache/hadoop/hbase/regionserver/RegionScanner.java | 9 + 1 file changed, 9 insertions(+) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/56be3ac7/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionScanner.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionScanner.java index 5b33db4..4f9732d 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionScanner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionScanner.java @@ -115,4 +115,13 @@ public interface RegionScanner extends InternalScanner, Shipper { */ boolean nextRaw(List result, ScannerContext scannerContext) throws IOException; + + /** + * Empty implementation to provide compatibility for user migrating from 1.X + * @see https://issues.apache.org/jira/browse/HBASE-16626;>HBASE-16626 + */ + @Override + default void shipped() throws IOException { +// do nothing + } }
[3/7] hbase git commit: HBASE-16229 Cleaning up size and heapSize calculation.
http://git-wip-us.apache.org/repos/asf/hbase/blob/2ab33846/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestWalAndCompactingMemStoreFlush.java -- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestWalAndCompactingMemStoreFlush.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestWalAndCompactingMemStoreFlush.java index a6c7912..74826b0 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestWalAndCompactingMemStoreFlush.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestWalAndCompactingMemStoreFlush.java @@ -19,10 +19,7 @@ package org.apache.hadoop.hbase.regionserver; import java.io.IOException; import java.util.Arrays; -import java.util.List; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.HBaseConfiguration; @@ -31,19 +28,14 @@ import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.HRegionInfo; import org.apache.hadoop.hbase.HTableDescriptor; -import org.apache.hadoop.hbase.MiniHBaseCluster; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.Table; -import org.apache.hadoop.hbase.regionserver.wal.FSHLog; import org.apache.hadoop.hbase.testclassification.LargeTests; import org.apache.hadoop.hbase.testclassification.RegionServerTests; import org.apache.hadoop.hbase.util.Bytes; -import org.apache.hadoop.hbase.util.JVMClusterUtil; -import org.apache.hadoop.hbase.util.Pair; -import org.apache.hadoop.hbase.util.Threads; import org.apache.hadoop.hbase.wal.WAL; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -59,7 +51,6 @@ import static org.junit.Assert.assertTrue; @Category({ RegionServerTests.class, LargeTests.class }) public class TestWalAndCompactingMemStoreFlush { - private static final Log LOG = LogFactory.getLog(TestWalAndCompactingMemStoreFlush.class); private static final HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(); private static final Path DIR = TEST_UTIL.getDataTestDir("TestHRegion"); public static final TableName TABLENAME = TableName.valueOf("TestWalAndCompactingMemStoreFlush", @@ -201,12 +192,13 @@ public class TestWalAndCompactingMemStoreFlush { // memstores of CF1, CF2 and CF3. String msg = "totalMemstoreSize="+totalMemstoreSize + " DefaultMemStore.DEEP_OVERHEAD="+DefaultMemStore.DEEP_OVERHEAD + -" DEEP_OVERHEAD_PER_PIPELINE_SKIPLIST_ITEM="+CompactingMemStore.DEEP_OVERHEAD_PER_PIPELINE_SKIPLIST_ITEM -+ +" CompactingMemStore.DEEP_OVERHEAD="+CompactingMemStore.DEEP_OVERHEAD + " cf1MemstoreSizePhaseI="+cf1MemstoreSizePhaseI + " cf2MemstoreSizePhaseI="+cf2MemstoreSizePhaseI + " cf3MemstoreSizePhaseI="+cf3MemstoreSizePhaseI ; -assertEquals(msg,totalMemstoreSize + 3 * DefaultMemStore.DEEP_OVERHEAD, +assertEquals(msg, +totalMemstoreSize + 2 * (CompactingMemStore.DEEP_OVERHEAD + MutableSegment.DEEP_OVERHEAD) ++ (DefaultMemStore.DEEP_OVERHEAD + MutableSegment.DEEP_OVERHEAD), cf1MemstoreSizePhaseI + cf2MemstoreSizePhaseI + cf3MemstoreSizePhaseI); // Flush!! @@ -220,11 +212,6 @@ public class TestWalAndCompactingMemStoreFlush { ((CompactingMemStore) region.getStore(FAMILY3).getMemStore()).flushInMemory(); region.flush(false); -// CF3 should be compacted so wait here to be sure the compaction is done -while (((CompactingMemStore) region.getStore(FAMILY3).getMemStore()) -.isMemStoreFlushingInMemory()) - Threads.sleep(10); - // Recalculate everything long cf1MemstoreSizePhaseII = region.getStore(FAMILY1).getMemStoreSize(); long cf2MemstoreSizePhaseII = region.getStore(FAMILY2).getMemStoreSize(); @@ -239,8 +226,6 @@ public class TestWalAndCompactingMemStoreFlush { s = s + "DefaultMemStore DEEP_OVERHEAD is:" + DefaultMemStore.DEEP_OVERHEAD + ", CompactingMemStore DEEP_OVERHEAD is:" + CompactingMemStore.DEEP_OVERHEAD -+ ", CompactingMemStore DEEP_OVERHEAD_PER_PIPELINE_SKIPLIST_ITEM is:" + CompactingMemStore -.DEEP_OVERHEAD_PER_PIPELINE_SKIPLIST_ITEM + "\nAfter first flush! CF1 should be flushed to memory, but not compacted.---\n" + "Size of CF1 is:" + cf1MemstoreSizePhaseII + ", size of CF2 is:" + cf2MemstoreSizePhaseII + ", size of CF3 is:" + cf3MemstoreSizePhaseII + "\n"; @@ -249,12 +234,13 @@ public class TestWalAndCompactingMemStoreFlush { assertTrue(cf1MemstoreSizePhaseII < cf1MemstoreSizePhaseI); //
[2/7] hbase git commit: HBASE-16592 Unify Delete request with AP
HBASE-16592 Unify Delete request with AP Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/831fb3cc Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/831fb3cc Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/831fb3cc Branch: refs/heads/master Commit: 831fb3ccb8a0ba449d249962379afd268e8fe032 Parents: 1cdc5ac Author: chenhengAuthored: Tue Sep 13 10:07:45 2016 +0800 Committer: chenheng Committed: Tue Sep 13 10:07:45 2016 +0800 -- .../hadoop/hbase/client/AbstractResponse.java | 38 .../hadoop/hbase/client/AsyncProcess.java | 22 --- .../org/apache/hadoop/hbase/client/HTable.java | 43 - .../hadoop/hbase/client/MultiResponse.java | 7 ++- .../hadoop/hbase/client/SingleResponse.java | 65 .../hbase/protobuf/ResponseConverter.java | 14 + .../hadoop/hbase/client/TestAsyncProcess.java | 18 +++--- .../hadoop/hbase/client/TestFromClientSide.java | 46 ++ 8 files changed, 222 insertions(+), 31 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/831fb3cc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AbstractResponse.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AbstractResponse.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AbstractResponse.java new file mode 100644 index 000..7878d05 --- /dev/null +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AbstractResponse.java @@ -0,0 +1,38 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.hadoop.hbase.client; + +import org.apache.hadoop.hbase.classification.InterfaceAudience; + +/** + * This class is used to extend AP to process single action request, like delete, get etc. + */ +@InterfaceAudience.Private +abstract class AbstractResponse { + + public enum ResponseType { + +SINGLE(0), +MULTI (1); + +ResponseType(int value) {} + } + + public abstract ResponseType type(); +} http://git-wip-us.apache.org/repos/asf/hbase/blob/831fb3cc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java index c5745e9..1531201 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java @@ -756,14 +756,14 @@ class AsyncProcess { @Override public void run() { -MultiResponse res; +AbstractResponse res; CancellableRegionServerCallable callable = currentCallable; try { // setup the callable based on the actions, if we don't have one already from the request if (callable == null) { callable = createCallable(server, tableName, multiAction); } - RpcRetryingCaller caller = createCaller(callable); + RpcRetryingCaller caller = createCaller(callable); try { if (callsInProgress != null) { callsInProgress.add(callable); @@ -785,9 +785,16 @@ class AsyncProcess { receiveGlobalFailure(multiAction, server, numAttempt, t); return; } - - // Normal case: we received an answer from the server, and it's not an exception. - receiveMultiAction(multiAction, server, res, numAttempt); + if (res.type() == AbstractResponse.ResponseType.MULTI) { +// Normal case: we received an answer from the server, and it's not an exception. +receiveMultiAction(multiAction, server, (MultiResponse) res, numAttempt); + } else { +if (results != null) { + SingleResponse
[5/7] hbase git commit: Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/hbase
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/hbase Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/156a8b2b Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/156a8b2b Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/156a8b2b Branch: refs/heads/master Commit: 156a8b2bad2577ace5d0958acc79f56b2bc23e0c Parents: 2ab3384 77b3273 Author: anoopsamjohnAuthored: Tue Sep 13 12:08:36 2016 +0530 Committer: anoopsamjohn Committed: Tue Sep 13 12:08:36 2016 +0530 -- --
[4/7] hbase git commit: HBASE-16229 Cleaning up size and heapSize calculation.
HBASE-16229 Cleaning up size and heapSize calculation. Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2ab33846 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2ab33846 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2ab33846 Branch: refs/heads/master Commit: 2ab3384669f1df514de250918aeaa51e9ba6b71c Parents: 831fb3c Author: anoopsamjohnAuthored: Tue Sep 13 11:43:26 2016 +0530 Committer: anoopsamjohn Committed: Tue Sep 13 11:43:26 2016 +0530 -- .../org/apache/hadoop/hbase/util/ClassSize.java | 15 +++ .../hbase/regionserver/AbstractMemStore.java| 49 +++ .../hbase/regionserver/CompactingMemStore.java | 92 ++--- .../hbase/regionserver/CompactionPipeline.java | 31 +++-- .../hbase/regionserver/DefaultMemStore.java | 30 ++--- .../hbase/regionserver/ImmutableSegment.java| 84 ++-- .../hadoop/hbase/regionserver/MemStore.java | 6 +- .../hbase/regionserver/MemStoreCompactor.java | 24 ++-- .../hbase/regionserver/MemStoreSnapshot.java| 2 +- .../hbase/regionserver/MutableSegment.java | 25 ++-- .../hadoop/hbase/regionserver/Segment.java | 103 ++- .../hbase/regionserver/SegmentFactory.java | 43 +++ .../apache/hadoop/hbase/io/TestHeapSize.java| 92 - .../regionserver/TestCompactingMemStore.java| 22 +--- .../TestCompactingToCellArrayMapMemStore.java | 4 +- .../regionserver/TestPerColumnFamilyFlush.java | 49 +++ .../TestWalAndCompactingMemStoreFlush.java | 129 +++ 17 files changed, 417 insertions(+), 383 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/2ab33846/hbase-common/src/main/java/org/apache/hadoop/hbase/util/ClassSize.java -- diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/ClassSize.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/ClassSize.java index ff9dbcb..85a6483 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/ClassSize.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/ClassSize.java @@ -46,6 +46,12 @@ public class ClassSize { /** Overhead for ArrayList(0) */ public static final int ARRAYLIST; + /** Overhead for LinkedList(0) */ + public static final int LINKEDLIST; + + /** Overhead for a single entry in LinkedList */ + public static final int LINKEDLIST_ENTRY; + /** Overhead for ByteBuffer */ public static final int BYTE_BUFFER; @@ -100,6 +106,9 @@ public class ClassSize { /** Overhead for AtomicBoolean */ public static final int ATOMIC_BOOLEAN; + /** Overhead for AtomicReference */ + public static final int ATOMIC_REFERENCE; + /** Overhead for CopyOnWriteArraySet */ public static final int COPYONWRITE_ARRAYSET; @@ -240,6 +249,10 @@ public class ClassSize { ARRAYLIST = align(OBJECT + REFERENCE + (2 * Bytes.SIZEOF_INT)) + align(ARRAY); +LINKEDLIST = align(OBJECT + (2 * Bytes.SIZEOF_INT) + (2 * REFERENCE)); + +LINKEDLIST_ENTRY = align(OBJECT + (2 * REFERENCE)); + //noinspection PointlessArithmeticExpression BYTE_BUFFER = align(OBJECT + REFERENCE + (5 * Bytes.SIZEOF_INT) + @@ -292,6 +305,8 @@ public class ClassSize { ATOMIC_BOOLEAN = align(OBJECT + Bytes.SIZEOF_BOOLEAN); +ATOMIC_REFERENCE = align(OBJECT + REFERENCE); + COPYONWRITE_ARRAYSET = align(OBJECT + REFERENCE); COPYONWRITE_ARRAYLIST = align(OBJECT + (2 * REFERENCE) + ARRAY); http://git-wip-us.apache.org/repos/asf/hbase/blob/2ab33846/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/AbstractMemStore.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/AbstractMemStore.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/AbstractMemStore.java index 419b76a..5e9f632 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/AbstractMemStore.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/AbstractMemStore.java @@ -52,34 +52,29 @@ public abstract class AbstractMemStore implements MemStore { private final CellComparator comparator; // active segment absorbs write operations - private volatile MutableSegment active; + protected volatile MutableSegment active; // Snapshot of memstore. Made for flusher. - private volatile ImmutableSegment snapshot; + protected volatile ImmutableSegment snapshot; protected volatile long snapshotId; // Used to track when to flush private volatile long timeOfOldestEdit; - public final static long FIXED_OVERHEAD = ClassSize.align( -
[1/7] hbase git commit: Adding checks in Scanner's setStartRow and setStopRow for invalid row key sizes.
Repository: hbase Updated Branches: refs/heads/master 1d6c90b49 -> 56be3ac7c Adding checks in Scanner's setStartRow and setStopRow for invalid row key sizes. Signed-off-by: Gary HelmlingProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/1cdc5acf Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/1cdc5acf Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/1cdc5acf Branch: refs/heads/master Commit: 1cdc5acfd456688f106287c19ae9af62fd03a3af Parents: 8855670 Author: Dustin Pho Authored: Mon Sep 12 13:25:02 2016 -0700 Committer: Gary Helmling Committed: Mon Sep 12 16:54:51 2016 -0700 -- .../org/apache/hadoop/hbase/client/Scan.java| 16 +++ .../apache/hadoop/hbase/client/TestScan.java| 28 2 files changed, 44 insertions(+) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/1cdc5acf/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Scan.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Scan.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Scan.java index ee3ed43..22f611a 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Scan.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Scan.java @@ -373,8 +373,16 @@ public class Scan extends Query { * next closest row after the specified row. * @param startRow row to start scanner at or after * @return this + * @throws IllegalArgumentException if startRow does not meet criteria + * for a row key (when length exceeds {@link HConstants#MAX_ROW_LENGTH}) */ public Scan setStartRow(byte [] startRow) { +if (Bytes.len(startRow) > HConstants.MAX_ROW_LENGTH) { + throw new IllegalArgumentException( +"startRow's length must be less than or equal to " + +HConstants.MAX_ROW_LENGTH + " to meet the criteria" + +" for a row key."); +} this.startRow = startRow; return this; } @@ -389,8 +397,16 @@ public class Scan extends Query { * use {@link #setRowPrefixFilter(byte[])}. * The 'trailing 0' will not yield the desired result. * @return this + * @throws IllegalArgumentException if stopRow does not meet criteria + * for a row key (when length exceeds {@link HConstants#MAX_ROW_LENGTH}) */ public Scan setStopRow(byte [] stopRow) { +if (Bytes.len(stopRow) > HConstants.MAX_ROW_LENGTH) { + throw new IllegalArgumentException( +"stopRow's length must be less than or equal to " + +HConstants.MAX_ROW_LENGTH + " to meet the criteria" + +" for a row key."); +} this.stopRow = stopRow; return this; } http://git-wip-us.apache.org/repos/asf/hbase/blob/1cdc5acf/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestScan.java -- diff --git a/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestScan.java b/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestScan.java index 129914f..16c74df 100644 --- a/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestScan.java +++ b/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestScan.java @@ -25,6 +25,8 @@ import java.io.IOException; import java.util.Arrays; import java.util.Set; +import org.apache.hadoop.hbase.HConstants; +import org.apache.hadoop.hbase.exceptions.IllegalArgumentIOException; import org.apache.hadoop.hbase.protobuf.ProtobufUtil; import org.apache.hadoop.hbase.protobuf.generated.ClientProtos; import org.apache.hadoop.hbase.security.visibility.Authorizations; @@ -132,5 +134,31 @@ public class TestScan { fail("should not throw exception"); } } + + @Test + public void testSetStartRowAndSetStopRow() { +Scan scan = new Scan(); +scan.setStartRow(null); +scan.setStartRow(new byte[1]); +scan.setStartRow(new byte[HConstants.MAX_ROW_LENGTH]); +try { + scan.setStartRow(new byte[HConstants.MAX_ROW_LENGTH+1]); + fail("should've thrown exception"); +} catch (IllegalArgumentException iae) { +} catch (Exception e) { + fail("expected IllegalArgumentException to be thrown"); +} + +scan.setStopRow(null); +scan.setStopRow(new byte[1]); +scan.setStopRow(new byte[HConstants.MAX_ROW_LENGTH]); +try { + scan.setStopRow(new byte[HConstants.MAX_ROW_LENGTH+1]); + fail("should've thrown exception"); +} catch (IllegalArgumentException iae) { +} catch (Exception e) { + fail("expected IllegalArgumentException to be thrown"); +} + } }
hbase git commit: HBASE-16381 Shell deleteall command should support row key prefixes (Yi Liang)
Repository: hbase Updated Branches: refs/heads/master 8ef6c7634 -> 1d6c90b49 HBASE-16381 Shell deleteall command should support row key prefixes (Yi Liang) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/1d6c90b4 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/1d6c90b4 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/1d6c90b4 Branch: refs/heads/master Commit: 1d6c90b4969b8ec47699c69984be052050a9ee46 Parents: 8ef6c76 Author: chenhengAuthored: Thu Sep 15 19:18:47 2016 +0800 Committer: chenheng Committed: Thu Sep 15 19:20:29 2016 +0800 -- hbase-shell/src/main/ruby/hbase/table.rb| 81 +++- .../src/main/ruby/shell/commands/deleteall.rb | 17 +++- hbase-shell/src/test/ruby/hbase/table_test.rb | 12 +++ 3 files changed, 86 insertions(+), 24 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/1d6c90b4/hbase-shell/src/main/ruby/hbase/table.rb -- diff --git a/hbase-shell/src/main/ruby/hbase/table.rb b/hbase-shell/src/main/ruby/hbase/table.rb index 5930c0d..22bbcfe 100644 --- a/hbase-shell/src/main/ruby/hbase/table.rb +++ b/hbase-shell/src/main/ruby/hbase/table.rb @@ -160,6 +160,62 @@ EOF end #-- +# Create a Delete mutation +def _createdelete_internal(row, column = nil, +timestamp = org.apache.hadoop.hbase.HConstants::LATEST_TIMESTAMP, args = {}) + temptimestamp = timestamp + if temptimestamp.kind_of?(Hash) +timestamp = org.apache.hadoop.hbase.HConstants::LATEST_TIMESTAMP + end + d = org.apache.hadoop.hbase.client.Delete.new(row.to_s.to_java_bytes, timestamp) + if temptimestamp.kind_of?(Hash) +temptimestamp.each do |k, v| + if v.kind_of?(String) +set_cell_visibility(d, v) if v + end +end + end + if args.any? + visibility = args[VISIBILITY] + set_cell_visibility(d, visibility) if visibility + end + if column +family, qualifier = parse_column_name(column) +d.addColumns(family, qualifier, timestamp) + end + return d +end + + #-- +# Delete rows using prefix +def _deleterows_internal(row, column = nil, +timestamp = org.apache.hadoop.hbase.HConstants::LATEST_TIMESTAMP, args={}) + cache = row["CACHE"] ? row["CACHE"] : 100 + prefix = row["ROWPREFIXFILTER"] + + # create scan to get table names using prefix + scan = org.apache.hadoop.hbase.client.Scan.new + scan.setRowPrefixFilter(prefix.to_java_bytes) + # Run the scanner to get all rowkeys + scanner = @table.getScanner(scan) + # Create a list to store all deletes + list = java.util.ArrayList.new + # Iterate results + iter = scanner.iterator + while iter.hasNext +row = iter.next +key = org.apache.hadoop.hbase.util.Bytes::toStringBinary(row.getRow) +d = _createdelete_internal(key, column, timestamp, args) +list.add(d) +if list.size >= cache + @table.delete(list) + list.clear +end + end + @table.delete(list) +end + + #-- # Delete a cell def _delete_internal(row, column, timestamp = org.apache.hadoop.hbase.HConstants::LATEST_TIMESTAMP, args = {}) @@ -175,27 +231,12 @@ EOF if is_meta_table? raise ArgumentError, "Row Not Found" if _get_internal(row).nil? end - temptimestamp = timestamp - if temptimestamp.kind_of?(Hash) - timestamp = org.apache.hadoop.hbase.HConstants::LATEST_TIMESTAMP - end - d = org.apache.hadoop.hbase.client.Delete.new(row.to_s.to_java_bytes, timestamp) - if temptimestamp.kind_of?(Hash) - temptimestamp.each do |k, v| - if v.kind_of?(String) - set_cell_visibility(d, v) if v - end -end - end - if args.any? - visibility = args[VISIBILITY] - set_cell_visibility(d, visibility) if visibility - end - if column -family, qualifier = parse_column_name(column) -d.addColumns(family, qualifier, timestamp) + if row.kind_of?(Hash) +_deleterows_internal(row, column, timestamp, args) + else +d = _createdelete_internal(row, column, timestamp, args) +@table.delete(d) end - @table.delete(d) end