Package org.apache.hadoop.hbase.client
package org.apache.hadoop.hbase.client
-
ClassDescriptionBased class for testing operation timeout logic for
ConnectionImplementation
.Based class for testing rpc timeout logic forConnectionImplementation
.Based class for testing timeout logic forConnectionImplementation
.This copro sleeps 20 second.Base class to test Configuration Update logic.Test that we can actually send and use region metrics to slowdown client writesBase class for testing clone snapsotRegistry that does nothing.DummyAsyncTable<C extends ScanResultConsumerBase>Can be overridden in UT if you only want to implement part of the methods inAsyncTable
.Connection
testing utility.This coproceesor sleep 2s at first increment/append rpc call.Base class for testing the scenarios where replicas are enabled for the meta table.Base class for testing restore snapshotA simplisticScanResultConsumer
for use in tests.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 inHBaseRpcController
for several admin operations.Only used to test stopMaster/stopRegionServer/shutdown methods.See HBASE-24513.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.The purpose of this test is to make sure the region exception won't corrupt the results of batch.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 inHBaseRpcController
for several table operations.Test the admin operations for Balancer, Normalizer, CleanerChore, and CatalogJanitor.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.My BufferedMutator.An override of HRegion to allow sleep after get(), waiting for the release of DBBMake sure we will honor theHConstants.META_REPLICAS_NUM
.Test client behavior w/o setting up a cluster.These tests verify that the RPC timeouts ('hbase.client.operation.timeout' and 'hbase.client.scanner.timeout.period') work correctly using a modified Region Server which injects delays to get, scan and mutate operations.ThisRSRpcServices
class injects delay for Rpc calls and after executes super methods.Test the ClientScanner.Rpc Channel implementation with RandomTimeoutBlockingRpcChannelTestcase for HBASE-21732.This class is for testing HBaseConnectionManager featuresTest a drop timeout request.Coprocessor that sleeps a while the first time you do a GetRun 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.Test ImmutableHRegionInfoSmall tests for ImmutableScanMake sure we will honor theHConstants.META_REPLICAS_NUM
.And also test upgrading.Test allIncrement
client 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.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 toTimestampsFilter
using 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.Test that correct rpc priority is sent to server from blocking Table calls.Run tests related toTimestampsFilter
using HBase client APIs.A drop-in replacement forBufferingScanResultConsumer
that adds tracing spans to its implementation of theAdvancedScanResultConsumer
API.