Package org.apache.hadoop.hbase.client
package org.apache.hadoop.hbase.client
-
ClassDescriptionBased class for testing operation timeout logic.Based class for testing rpc timeout logic.Based class for testing timeout logic.This copro sleeps 20 second.Base class to test Configuration Update logic.A scan result consumer which buffers all the data in memory and you can call the
BufferingScanResultConsumer.take()method below to get the result one by one.Test that we can actually send and use region metrics to slowdown client writesBase class for testing clone snapsotRegistry that does nothing.Can be overridden in UT if you only want to implement part of the methods inAsyncClusterConnection.DummyAsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>Can be overridden in UT if you only want to implement part of the methods inAsyncTable.Base for TestFromClientSide* classes.Connectiontesting utility.Advise the scanning infrastructure to collect up tolimitresults.Base class for testing the scenarios where replicas are enabled for the meta table.Base class for testing restore snapshotA ResultScanner which will only send request to RS when there are no cached results when calling next, just like the ResultScanner in the old time.A simplisticScanResultConsumerfor use in tests.This coproceesor sleep 2s at first increment/append rpc call.Class to test HBaseAdmin.Class to test HBaseAdmin.Testcase to make sure that we always set scanner id in ScanResponse.Run Append tests that use the HBase clients;Class to test AsyncAdmin.Testcase for HBASE-22135.Confirm that we will set the priority inHBaseRpcControllerfor several admin operations.Only used to test stopMaster/stopRegionServer/shutdown methods.See HBASE-24513, HBASE-28608.Test covers when client is configured withRpcConnectionRegistry.Test covers when client is configured withZKConnectionRegistry.Class to test asynchronous namespace admin operations.Class to test asynchronous procedure admin operations.Class to test asynchronous region admin operations.Class to test asynchronous region admin operations.Class to test asynchronous replication admin operations.Class to test asynchronous replication admin operations when more than 1 clusterClass to test asynchronous table admin operations.Class to test asynchronous table admin operationsClass to test asynchronous table admin operations.Will split the table, and move region randomly when testing.Fix an infinite loop inAsyncNonMetaRegionLocator, see the comments on HBASE-21943 for more details.Confirm that we will set the priority inHBaseRpcControllerfor several table operations.Test the admin operations for Balancer, Normalizer, CleanerChore, and CatalogJanitor.Test basic read write operation with differentConnectionRegistryimplementations.Make sure that we can update the bootstrap server from master to region server, and region server could also contact each other to update the bootstrap nodes.Just to create an instance, this doesn't actually function.An override of HRegion to allow sleep after get(), waiting for the release of DBBMake sure we will honor theHConstants.META_REPLICAS_NUM.Blocking rpc channel that goes via hbase rpc.Rpc Channel implementation with RandomTimeoutBlockingRpcChannelTestcase for HBASE-21732.This class is for testingConnection.See HBASE-28608.Make sure we can successfully parse the URI componentTest a drop timeout request.Coprocessor that sleeps a while the first time you do a GetMake sure we could fallback to use replay method if replicateToReplica method is not present, i.e, we are connecting an old region server.Run tests that use the HBase clients;Table.Run tests that use the HBase clients;Table.Run tests that use the HBase clients;Table.Do some ops and prove that client and server can work w/o codecs; that we can pb all the time.Test all client operations with a coprocessor that just implements the default flush/compact/scan policy.Test all client operations with a coprocessor that just implements the default flush/compact/scan policy.Test all client operations with a coprocessor that just implements the default flush/compact/scan policy.Test all client operations with a coprocessor that just implements the default flush/compact/scan policy.Testcase for HBASE-19608.Testcase for HBASE-21032, where use the wrong readType from a Scan instance which is actually a get scan and cause returning only 1 cell per rpc call.Testcase for HBASE-21032, where use the wrong readType from a Scan instance which is actually a get scan and cause returning only 1 cell per rpc call.Class to test HBaseHbck.Small tests for ImmutableScanMake sure we will honor theHConstants.META_REPLICAS_NUM.And also test upgrading.Test allIncrementclient operations with a coprocessor that just implements the default flush/compact/scan policy.Run Increment tests that use the HBase clients;TableBuilder.Test scan/get offset and limit settings within one row through HRegion API.With filter we may stop at a middle of row and think that we still have more cells for the current row but actually all the remaining cells will be filtered out by the filter.The purpose of this test is to ensure whether rs deals with the malformed cells correctly.Throws CallQueueTooBigException for all gets.Rotates through the possible cache clearing and non-cache clearing exceptions for requests.Test MetaTableAccessor but without spinning up a cluster.This coprocessor is used to delay the flush.Test to verify that the cloned table is independent of the table from which it was clonedTest create/using/deleting snapshots from the clientRun tests related toTimestampsFilterusing HBase client APIs.This test sets the multi size WAAAAAY low and then checks to make sure that gets will still make progress.Run tests that use the functionality of the Operation superclass for Puts, Gets, Deletes, Scans, and MultiPuts.Test that I can Iterate Client Actions that hold Cells (Get does not have Cells).With filter we may stop at a middle of row and think that we still have more cells for the current row but actually all the remaining cells will be filtered out by the filter.Tests for region replicas.This copro is used to synchronize the tests.This copro is used to slow down the primary meta region scan a bitThis copro is used to simulate region server down exception for Get and ScanThis copro is used to synchronize the tests.A dummy RpcChannel implementation that intercepts the GetClusterId() RPC calls and injects errors.A client-side test, mostly testing scanners with various parameters.Testcase for newly added feature in HBASE-17143, such as startRow and stopRow inclusive/exclusive, limit for rows, etc.Test various scanner timeout issues.Testcase to make sure that we do not close scanners if ScanRequest.numberOfRows is zero.This class is for testing HBaseConnectionManager ServerBusyException.HBASE-19496 noticed that the RegionLoad/ServerLoad may be corrupted if rpc server reuses the bytebuffer backed, so this test call the Admin#getLastMajorCompactionTimestamp() to invoke HMaster to iterate all stored server/region loads.Test to verify that the cloned table is independent of the table from which it was clonedThis class tests that the use of a temporary snapshot directory supports snapshot functionality while the temporary directory is on the same file system as the root directoryTest create/using/deleting snapshots from the clientTest class to verify that metadata is consistent before and after a snapshot attempt.This class tests that the use of a temporary snapshot directory supports snapshot functionality while the temporary directory is on a different file system than the root directoryTest restore/clone snapshots with TTL from the clientTest setting values in the descriptor.Run tests related toTimestampsFilterusing HBase client APIs.A drop-in replacement forBufferingScanResultConsumerthat adds tracing spans to its implementation of theAdvancedScanResultConsumerAPI.A wrapper overSimpleScanResultConsumerthat adds tracing of spans to its implementation.