Package org.apache.hadoop.hbase

Class HBaseTestingUtility

java.lang.Object

org.apache.hadoop.hbase.HBaseCommonTestingUtility

org.apache.hadoop.hbase.HBaseZKTestingUtility

org.apache.hadoop.hbase.HBaseTestingUtility

@Public
@Deprecated
public class HBaseTestingUtility
extends HBaseZKTestingUtility

Deprecated.

since 3.0.0, will be removed in 4.0.0. Use TestingHBaseCluster instead.

Facility for testing HBase. Replacement for old HBaseTestCase and HBaseClusterTestCase functionality. Create an instance and keep it around testing HBase. This class is meant to be your one-stop shop for anything you might need testing. Manages one cluster at a time only. Managed cluster can be an in-process MiniHBaseCluster, or a deployed cluster of type DistributedHBaseCluster. Not all methods work with the real cluster. Depends on log4j being on classpath and hbase-site.xml for logging and test-run configuration. It does not set logging levels. In the configuration properties, default values for master-info-port and region-server-port are overridden such that a random port will be assigned (thus avoiding port contention if another local HBase instance is already running).

To preserve test data directories, pass the system property "hbase.testing.preserve.testdir" setting it to true.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	HBaseTestingUtility.FsDatasetAsyncDiskServiceFixer	Deprecated.
static class	HBaseTestingUtility.SeenRowTracker	Deprecated. A tracker for tracking and validating table rows generated with loadTable(Table, byte[])

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.HBaseCommonTestingUtility

HBaseCommonTestingUtility.PortAllocator

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicReference<AsyncClusterConnection>	asyncConnection	Deprecated.
static final Collection<Object[]>	BLOOM_AND_COMPRESSION_COMBINATIONS	Deprecated.
static final byte[][]	COLUMNS	Deprecated.
private org.apache.hadoop.fs.Path	dataTestDirOnTestFS	Deprecated. Directory on test filesystem where we put the data for this instance of HBaseTestingUtility
static final int	DEFAULT_REGIONS_PER_SERVER	Deprecated. The default number of regions per regionserver when creating a pre-split table.
private org.apache.hadoop.hdfs.MiniDFSCluster	dfsCluster	Deprecated.
private HBaseTestingUtility.FsDatasetAsyncDiskServiceFixer	dfsClusterFixer	Deprecated.
static final byte[]	fam1	Deprecated.
static final byte[]	fam2	Deprecated.
static final byte[]	fam3	Deprecated.
static final char	FIRST_CHAR	Deprecated.
private static String	FS_URI	Deprecated. Filesystem URI used for map-reduce mini-cluster setup
private String	hadoopLogDir	Deprecated.
private Admin	hbaseAdmin	Deprecated.
private HBaseCluster	hbaseCluster	Deprecated.
static final byte[][]	KEYS	Deprecated.
static final byte[][]	KEYS_FOR_HBA_CREATE_TABLE	Deprecated.
static final char	LAST_CHAR	Deprecated.
private static final int	MAXVERSIONS	Deprecated.
static final List<Object[]>	MEMSTORETS_TAGS_PARAMETRIZED	Deprecated. This is for unit tests parameterized with a single boolean.
private boolean	miniClusterRunning	Deprecated. If there is a mini cluster running for this testing utility instance.
private org.apache.hadoop.mapred.MiniMRCluster	mrCluster	Deprecated.
static final String	REGIONS_PER_SERVER_KEY	Deprecated.
static final byte[][]	ROWS	Deprecated. All the row values for the data loaded by loadTable(Table, byte[])
static final String	START_KEY	Deprecated.
static final byte[]	START_KEY_BYTES	Deprecated.

Fields inherited from class org.apache.hadoop.hbase.HBaseZKTestingUtility

clusterTestDir, zooKeeperWatcher

Fields inherited from class org.apache.hadoop.hbase.HBaseCommonTestingUtility

BASE_TEST_DIRECTORY_KEY, BOOLEAN_PARAMETERIZED, COMPRESSION_ALGORITHMS, COMPRESSION_ALGORITHMS_PARAMETERIZED, conf, DEFAULT_BASE_TEST_DIRECTORY, LOG

Constructor Summary

Constructors

Constructor	Description
HBaseTestingUtility()	Deprecated. Create an HBaseTestingUtility using a default configuration.
HBaseTestingUtility(org.apache.hadoop.conf.Configuration conf)	Deprecated. Create an HBaseTestingUtility using a given configuration.

Method Summary

Modifier and Type	Method	Description
private void	assertEquals(String message, int expected, int actual)	Deprecated.
static void	assertKVListsEqual(String additionalMsg, List<? extends Cell> expected, List<? extends Cell> actual)	Deprecated.
void	assertRegionOnlyOnServer(RegionInfo hri, ServerName server, long timeout)	Deprecated. Check to make sure the region is open on the specified region server, but not on any other one.
void	assertRegionOnServer(RegionInfo hri, ServerName server, long timeout)	Deprecated. Due to async racing issue, a region may not be in the online region list of a region server yet, after the assignment znode is deleted and the new assignment is recorded in master.
boolean	assignRegion(RegionInfo regionInfo)	Deprecated. Uses directly the assignment manager to assign the region.
static boolean	available(int port)	Deprecated. Checks to see if a specific port is available.
static void	await(long sleepMillis, BooleanSupplier condition)	Deprecated. Await the successful return of condition, sleeping sleepMillis between invocations.
private static List<Object[]>	bloomAndCompressionCombinations()	Deprecated. Create all combinations of Bloom filters and compression algorithms for testing.
String	checksumRows(Table table)	Deprecated. Return an md5 digest of the entire contents of a table.
private void	cleanup()	Deprecated.
boolean	cleanupDataTestDirOnTestFS()	Deprecated. Cleans the test data directory on the test filesystem.
boolean	cleanupDataTestDirOnTestFS(String subdirName)	Deprecated. Cleans a subdirectory under the test data directory on the test filesystem.
void	closeConnection()	Deprecated.
static void	closeRegionAndWAL(HRegion r)	Deprecated. Close both the HRegion r and it's underlying WAL.
static void	closeRegionAndWAL(Region r)	Deprecated. Close both the region r and it's underlying WAL.
void	compact(boolean major)	Deprecated. Compact all regions in the mini hbase cluster
void	compact(TableName tableName, boolean major)	Deprecated. Compact all of a table's reagion in the mini hbase cluster
static int	countRows(Table table)	Deprecated. Return the number of rows in the given table.
int	countRows(Table table, byte[]... families)	Deprecated.
static int	countRows(Table table, Scan scan)	Deprecated.
int	countRows(InternalScanner scanner)	Deprecated.
int	countRows(Region region)	Deprecated.
int	countRows(Region region, Scan scan)	Deprecated.
int	countRows(TableName tableName)	Deprecated. Return the number of rows in the given table.
private String	createDirAndSetProperty(String property)	Deprecated.
private String	createDirAndSetProperty(String relPath, String property)	Deprecated.
private void	createDirsAndSetProperties()	Deprecated. This is used before starting HDFS and map-reduce mini-clusters Run something like the below to check for the likes of '/tmp' references -- i.e.
HRegion	createLocalHRegion(RegionInfo info, org.apache.hadoop.conf.Configuration conf, TableDescriptor desc, WAL wal)	Deprecated. Create an HRegion that writes to the local tmp dirs with specified wal
HRegion	createLocalHRegion(RegionInfo info, TableDescriptor desc)	Deprecated. Create an HRegion that writes to the local tmp dirs.
HRegion	createLocalHRegion(TableDescriptor desc, byte[] startKey, byte[] endKey)	Deprecated. Create an HRegion that writes to the local tmp dirs
HRegion	createLocalHRegion(TableName tableName, byte[] startKey, byte[] stopKey, org.apache.hadoop.conf.Configuration conf, boolean isReadOnly, Durability durability, WAL wal, byte[]... families)	Deprecated. Return a region on which you must call closeRegionAndWAL(HRegion) when done.
HRegion	createLocalHRegionWithInMemoryFlags(TableName tableName, byte[] startKey, byte[] stopKey, org.apache.hadoop.conf.Configuration conf, boolean isReadOnly, Durability durability, WAL wal, boolean[] compactedMemStore, byte[]... families)	Deprecated.
RegionServerServices	createMockRegionServerService()	Deprecated. Create a stubbed out RegionServerService, mainly for getting FS.
RegionServerServices	createMockRegionServerService(RpcServerInterface rpc)	Deprecated. Create a stubbed out RegionServerService, mainly for getting FS.
RegionServerServices	createMockRegionServerService(ServerName name)	Deprecated. Create a stubbed out RegionServerService, mainly for getting FS.
TableDescriptorBuilder	createModifyableTableDescriptor(String name)	Deprecated.
TableDescriptorBuilder	createModifyableTableDescriptor(TableName name, int minVersions, int versions, int ttl, KeepDeletedCells keepDeleted)	Deprecated.
List<RegionInfo>	createMultiRegionsInMeta(org.apache.hadoop.conf.Configuration conf, TableDescriptor htd, byte[][] startKeys)	Deprecated. Create rows in hbase:meta for regions of the specified table with the specified start keys.
Table	createMultiRegionTable(TableName tableName, byte[] family)	Deprecated. Create a table with multiple regions.
Table	createMultiRegionTable(TableName tableName, byte[][] families)	Deprecated. Create a table with multiple regions.
Table	createMultiRegionTable(TableName tableName, byte[][] families, int numVersions)	Deprecated. Create a table with multiple regions.
Table	createMultiRegionTable(TableName tableName, byte[] family, int numRegions)	Deprecated. Create a table with multiple regions.
Table	createMultiRegionTable(TableName tableName, int replicaCount, byte[][] families)	Deprecated. Create a table with multiple regions.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableDescriptor desc, ColumnFamilyDescriptor hcd)	Deprecated. Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableDescriptor desc, ColumnFamilyDescriptor[] hcds, int numRegionsPerServer)	Deprecated. Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableDescriptor td, ColumnFamilyDescriptor[] cds, RegionSplitter.SplitAlgorithm splitter, int numRegionsPerServer)	Deprecated. Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableDescriptor desc, ColumnFamilyDescriptor hcd, int numRegionsPerServer)	Deprecated. Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableName tableName, byte[][] columnFamilies, Compression.Algorithm compression, DataBlockEncoding dataBlockEncoding, int numRegionsPerServer, int regionReplication, Durability durability)	Deprecated. Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableName tableName, byte[] columnFamily, Compression.Algorithm compression, DataBlockEncoding dataBlockEncoding)	Deprecated. Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableName tableName, byte[] columnFamily, Compression.Algorithm compression, DataBlockEncoding dataBlockEncoding, int numRegionsPerServer, int regionReplication, Durability durability)	Deprecated. Creates a pre-split table for load testing.
Table	createRandomTable(TableName tableName, Collection<String> families, int maxVersions, int numColsPerRow, int numFlushes, int numRegions, int numRowsPerFlush)	Deprecated. Creates a random table with the given parameters
static HRegion	createRegionAndWAL(RegionInfo info, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.conf.Configuration conf, TableDescriptor htd)	Deprecated. Create a region with it's own WAL.
static HRegion	createRegionAndWAL(RegionInfo info, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.conf.Configuration conf, TableDescriptor htd, boolean initialize)	Deprecated. Create a region with it's own WAL.
static HRegion	createRegionAndWAL(RegionInfo info, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.conf.Configuration conf, TableDescriptor htd, BlockCache blockCache)	Deprecated. Create a region with it's own WAL.
static HRegion	createRegionAndWAL(RegionInfo info, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.conf.Configuration conf, TableDescriptor htd, MobFileCache mobFileCache)	Deprecated. Create a region with it's own WAL.
org.apache.hadoop.fs.Path	createRootDir()	Deprecated. Same as createRootDir(boolean create) except that create flag is false.
org.apache.hadoop.fs.Path	createRootDir(boolean create)	Deprecated. Creates an hbase rootdir in user home directory.
private void	createSubDirAndSystemProperty(String propertyName, org.apache.hadoop.fs.Path parent, String subDirName)	Deprecated.
Table	createTable(TableDescriptor htd, byte[][] splitRows)	Deprecated. Create a table.
Table	createTable(TableDescriptor htd, byte[][] families, byte[][] splitKeys, org.apache.hadoop.conf.Configuration c)	Deprecated. Create a table.
Table	createTable(TableDescriptor htd, byte[][] families, byte[][] splitKeys, BloomType type, int blockSize, org.apache.hadoop.conf.Configuration c)	Deprecated. Create a table.
Table	createTable(TableDescriptor htd, byte[][] families, org.apache.hadoop.conf.Configuration c)	Deprecated. Create a table.
Table	createTable(TableName tableName, byte[] family)	Deprecated. Create a table.
Table	createTable(TableName tableName, byte[][] families)	Deprecated. Create a table.
Table	createTable(TableName tableName, byte[][] families, byte[][] splitKeys)	Deprecated. Create a table.
Table	createTable(TableName tableName, byte[][] families, byte[][] splitKeys, int replicaCount)	Deprecated. Create a table.
Table	createTable(TableName tableName, byte[][] families, byte[][] splitKeys, int replicaCount, org.apache.hadoop.conf.Configuration c)	Deprecated. Create a table.
Table	createTable(TableName tableName, byte[][] families, int numVersions)	Deprecated. Create a table.
Table	createTable(TableName tableName, byte[][] families, int[] numVersions)	Deprecated. Create a table.
Table	createTable(TableName tableName, byte[][] families, int numVersions, byte[][] splitKeys)	Deprecated. Create a table.
Table	createTable(TableName tableName, byte[][] families, int numVersions, byte[] startKey, byte[] endKey, int numRegions)	Deprecated.
Table	createTable(TableName tableName, byte[][] families, int numVersions, int blockSize)	Deprecated. Create a table.
Table	createTable(TableName tableName, byte[][] families, int numVersions, int blockSize, String cpName)	Deprecated.
Table	createTable(TableName tableName, byte[] family, byte[][] splitRows)	Deprecated. Create a table.
Table	createTable(TableName tableName, byte[] family, int numVersions)	Deprecated. Create a table.
Table	createTable(TableName tableName, String family)	Deprecated. Create a table.
Table	createTable(TableName tableName, String[] families)	Deprecated. Create a table.
TableDescriptor	createTableDescriptor(TableName name)	Deprecated. Create a table of name name.
TableDescriptor	createTableDescriptor(TableName tableName, byte[] family)	Deprecated.
TableDescriptor	createTableDescriptor(TableName tableName, byte[][] families, int maxVersions)	Deprecated.
TableDescriptor	createTableDescriptor(TableName name, int minVersions, int versions, int ttl, KeepDeletedCells keepDeleted)	Deprecated.
HRegion	createTestRegion(String tableName, ColumnFamilyDescriptor cd)	Deprecated.
HRegion	createTestRegion(String tableName, ColumnFamilyDescriptor cd, BlockCache blockCache)	Deprecated.
static WAL	createWal(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path rootDir, RegionInfo hri)	Deprecated. Create an unmanaged WAL.
org.apache.hadoop.fs.Path	createWALRootDir()	Deprecated. Creates a hbase walDir in the user's home directory.
private void	decrementMinRegionServerCount()	Deprecated.
private void	decrementMinRegionServerCount(org.apache.hadoop.conf.Configuration conf)	Deprecated.
void	deleteNumericRows(Table t, byte[] f, int startRow, int endRow)	Deprecated.
void	deleteTable(TableName tableName)	Deprecated. Drop an existing table
Table	deleteTableData(TableName tableName)	Deprecated. Provide an existing table name to truncate.
void	deleteTableIfAny(TableName tableName)	Deprecated. Drop an existing table
void	enableDebug(Class<?> clazz)	Deprecated. In 2.3.0, will be removed in 4.0.0.
private void	enableShortCircuit()	Deprecated. Enable the short circuit read, unless configured differently.
boolean	ensureSomeNonStoppedRegionServersAvailable(int num)	Deprecated. Make sure that at least the specified number of region servers are running.
boolean	ensureSomeRegionServersAvailable(int num)	Deprecated. Make sure that at least the specified number of region servers are running
void	expireMasterSession()	Deprecated. Expire the Master's session
void	expireRegionServerSession(int index)	Deprecated. Expire a region server's session
void	expireSession(ZKWatcher nodeZK)	Deprecated.
void	expireSession(ZKWatcher nodeZK, boolean checkStatus)	Deprecated. Expire a ZooKeeper session as recommended in ZooKeeper documentation http://hbase.apache.org/book.html#trouble.zookeeper There are issues when doing this: [1] http://www.mail-archive.com/dev@zookeeper.apache.org/msg01942.html [2] https://issues.apache.org/jira/browse/ZOOKEEPER-1105
String	explainTableAvailability(TableName tableName)	Deprecated.
String	explainTableState(TableName table, TableState.State state)	Deprecated.
TableState	findLastTableState(TableName table)	Deprecated.
void	flush()	Deprecated. Flushes all caches in the mini hbase cluster
void	flush(TableName tableName)	Deprecated. Flushes all caches in the mini hbase cluster
private void	forceChangeTaskLogDir()	Deprecated. Tasktracker has a bug where changing the hadoop.log.dir system property will not change its internal static LOG_DIR variable.
static List<ColumnFamilyDescriptor>	generateColumnDescriptors()	Deprecated. Create a set of column descriptors with the combination of compression, encoding, bloom codecs available.
static List<ColumnFamilyDescriptor>	generateColumnDescriptors(String prefix)	Deprecated. Create a set of column descriptors with the combination of compression, encoding, bloom codecs available.
Admin	getAdmin()	Deprecated. Returns an Admin instance which is shared between HBaseTestingUtility instance users.
static NavigableSet<String>	getAllOnlineRegions(MiniHBaseCluster cluster)	Deprecated.
AsyncClusterConnection	getAsyncConnection()	Deprecated. Get a shared AsyncClusterConnection to the cluster.
AsyncClusterConnection	getAsyncConnection(User user)	Deprecated. Get a assigned AsyncClusterConnection to the cluster.
private org.apache.hadoop.fs.Path	getBaseTestDirOnTestFS()	Deprecated.
Result	getClosestRowBefore(Region r, byte[] row, byte[] family)	Deprecated.
String	getClusterKey()	Deprecated. since 2.7.0, will be removed in 4.0.0.
org.apache.hadoop.conf.Configuration	getConfiguration()	Deprecated. Returns this classes's instance of Configuration.
Connection	getConnection()	Deprecated. Get a shared Connection to the cluster.
Connection	getConnection(User user)	Deprecated. Get a assigned Connection to the cluster.
org.apache.hadoop.fs.Path	getDataTestDirOnTestFS()	Deprecated. Returns a Path in the test filesystem, obtained from getTestFileSystem() to write temporary test data.
org.apache.hadoop.fs.Path	getDataTestDirOnTestFS(String subdirName)	Deprecated. Returns a Path in the test filesystem, obtained from getTestFileSystem() to write temporary test data.
org.apache.hadoop.fs.Path	getDefaultRootDirPath()	Deprecated. Same as {getDefaultRootDirPath(boolean create) except that create flag is false.
org.apache.hadoop.fs.Path	getDefaultRootDirPath(boolean create)	Deprecated. Returns the path to the default root dir the minicluster uses.
org.apache.hadoop.hdfs.MiniDFSCluster	getDFSCluster()	Deprecated.
static User	getDifferentUser(org.apache.hadoop.conf.Configuration c, String differentiatingSuffix)	Deprecated. This method clones the passed c configuration setting a new user into the clone.
static List<Cell>	getFromStoreFile(HStore store, byte[] row, NavigableSet<byte[]> columns)	Deprecated. Do a small get/scan against one store.
static List<Cell>	getFromStoreFile(HStore store, Get get)	Deprecated. Do a small get/scan against one store.
MiniHBaseCluster	getHBaseCluster()	Deprecated. Get the Mini HBase cluster.
HBaseCluster	getHBaseClusterInterface()	Deprecated. Returns the HBaseCluster instance.
Hbck	getHbck()	Deprecated. Returns an Hbck instance.
static int	getMetaRSPort(Connection connection)	Deprecated.
List<byte[]>	getMetaTableRows()	Deprecated. Returns all rows from the hbase:meta table.
List<byte[]>	getMetaTableRows(TableName tableName)	Deprecated. Returns all rows from the hbase:meta table for a given user table
MiniHBaseCluster	getMiniHBaseCluster()	Deprecated.
private org.apache.hadoop.fs.Path	getNewDataTestDirOnTestFS()	Deprecated. Sets up a new path in test filesystem to be used by tests.
int	getNumHFiles(TableName tableName, byte[] family)	Deprecated.
int	getNumHFilesForRS(HRegionServer rs, TableName tableName, byte[] family)	Deprecated.
HRegionServer	getOtherRegionServer(HRegionServer rs)	Deprecated. Find any other region server which is different from the one identified by parameter
private List<RegionInfo>	getRegions(TableName tableName)	Deprecated. Returns all regions of the specified table
byte[][]	getRegionSplitStartKeys(byte[] startKey, byte[] endKey, int numRegions)	Deprecated. Create region split keys between startkey and endKey
String	getRpcConnnectionURI()	Deprecated.
HRegionServer	getRSForFirstRegionInTable(TableName tableName)	Deprecated. Tool to get the reference to the region server object that holds the region of the specified user table.
HRegion	getSplittableRegion(TableName tableName, int maxAttempts)	Deprecated. Retrieves a splittable region randomly from tableName
static Compression.Algorithm[]	getSupportedCompressionAlgorithms()	Deprecated. Get supported compression algorithms.
org.apache.hadoop.fs.FileSystem	getTestFileSystem()	Deprecated.
String	getZkConnectionURI()	Deprecated.
void	invalidateConnection()	Deprecated. Resets the connections so that the next time getConnection() is called, a new connection is created.
boolean	isNewVersionBehaviorEnabled()	Deprecated. Check whether the tests should assume NEW_VERSION_BEHAVIOR when creating new column families.
boolean	isReadShortCircuitOn()	Deprecated. Get the HBase setting for dfs.client.read.shortcircuit from the conf or a system property.
private boolean	isTargetTable(byte[] inRow, Cell c)	Deprecated.
void	killMiniHBaseCluster()	Deprecated. Abruptly Shutdown HBase mini cluster.
void	loadNumericRows(Table t, byte[] f, int startRow, int endRow)	Deprecated.
void	loadRandomRows(Table t, byte[] f, int rowSize, int totalRows)	Deprecated.
int	loadRegion(HRegion r, byte[] f)	Deprecated.
int	loadRegion(HRegion r, byte[] f, boolean flush)	Deprecated. Load region with rows from 'aaa' to 'zzz'.
int	loadRegion(Region r, byte[] f)	Deprecated.
int	loadTable(Table t, byte[] f)	Deprecated. Load table with rows from 'aaa' to 'zzz'.
int	loadTable(Table t, byte[][] f)	Deprecated. Load table of multiple column families with rows from 'aaa' to 'zzz'.
int	loadTable(Table t, byte[][] f, byte[] value)	Deprecated. Load table of multiple column families with rows from 'aaa' to 'zzz'.
int	loadTable(Table t, byte[][] f, byte[] value, boolean writeToWAL)	Deprecated. Load table of multiple column families with rows from 'aaa' to 'zzz'.
int	loadTable(Table t, byte[] f, boolean writeToWAL)	Deprecated. Load table with rows from 'aaa' to 'zzz'.
private static List<Object[]>	memStoreTSAndTagsCombination()	Deprecated. Create combination of memstoreTS and tags
static List<Object[]>	memStoreTSTagsAndOffheapCombination()	Deprecated.
static void	modifyTableSync(Admin admin, TableDescriptor desc)	Deprecated. since 3.0.0 and will be removed in 4.0.0.
void	moveRegionAndWait(RegionInfo destRegion, ServerName destServer)	Deprecated. Move region to destination server and wait till region is completely moved and online
<any>	predicateNoRegionsInTransition()	Deprecated. Returns a Predicate for checking that there are no regions in transition in master
<any>	predicateTableAvailable(TableName tableName)	Deprecated. Returns a Predicate for checking that table is enabled
<any>	predicateTableDisabled(TableName tableName)	Deprecated. Returns a Predicate for checking that table is enabled
<any>	predicateTableEnabled(TableName tableName)	Deprecated. Returns a Predicate for checking that table is enabled
static int	randomFreePort()	Deprecated.
static String	randomMultiCastAddress()	Deprecated.
void	restartHBaseCluster(int servers)	Deprecated. Starts the hbase cluster up again after shutting it down previously in a test.
void	restartHBaseCluster(int servers, List<Integer> ports)	Deprecated.
void	restartHBaseCluster(StartMiniClusterOption option)	Deprecated.
static <T> String	safeGetAsStr(List<T> lst, int i)	Deprecated.
void	setDFSCluster(org.apache.hadoop.hdfs.MiniDFSCluster cluster)	Deprecated.
void	setDFSCluster(org.apache.hadoop.hdfs.MiniDFSCluster cluster, boolean requireDown)	Deprecated. Set the MiniDFSCluster
static void	setFileSystemURI(String fsURI)	Deprecated.
private void	setFs()	Deprecated.
void	setHBaseCluster(HBaseCluster hbaseCluster)	Deprecated.
private void	setHBaseFsTmpDir()	Deprecated.
static void	setMaxRecoveryErrorCount(OutputStream stream, int max)	Deprecated. Set maxRecoveryErrorCount in DFSClient.
static void	setReplicas(Admin admin, TableName table, int replicaCount)	Deprecated. Set the number of Region replicas.
protected org.apache.hadoop.fs.Path	setupDataTestDir()	Deprecated. Home our data in a dir under HBaseCommonTestingUtility.DEFAULT_BASE_TEST_DIRECTORY.
private void	setupDataTestDirOnTestFS()	Deprecated. Sets up a path in test filesystem to be used by tests.
org.apache.hadoop.minikdc.MiniKdc	setupMiniKdc(File keytabFile)	Deprecated. Sets up MiniKdc for testing security.
void	shutdownMiniCluster()	Deprecated. Stops mini hbase, zk, and hdfs clusters.
void	shutdownMiniDFSCluster()	Deprecated. Shuts down instance created by call to startMiniDFSCluster(int) or does nothing.
void	shutdownMiniHBaseCluster()	Deprecated. Shutdown HBase mini cluster.Does not shutdown zk or dfs if running.
void	shutdownMiniMapReduceCluster()	Deprecated. Stops the previously started MiniMRCluster.
MiniHBaseCluster	startMiniCluster()	Deprecated. Start up a minicluster of hbase, dfs and zookeeper all using default options.
MiniHBaseCluster	startMiniCluster(boolean createWALDir)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniCluster(int numSlaves)	Deprecated. Start up a minicluster of hbase, dfs and zookeeper clusters with given slave node number.
MiniHBaseCluster	startMiniCluster(int numSlaves, boolean createRootDir)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniCluster(int numSlaves, boolean createRootDir, boolean createWALDir)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniCluster(int numMasters, int numSlaves)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniCluster(int numMasters, int numSlaves, boolean createRootDir)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniCluster(int numMasters, int numRegionServers, int numDataNodes)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniCluster(int numMasters, int numRegionServers, int numDataNodes, String[] dataNodeHosts, Class<? extends HMaster> masterClass, Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> rsClass)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniCluster(int numMasters, int numRegionServers, int numDataNodes, String[] dataNodeHosts, Class<? extends HMaster> masterClass, Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> rsClass, boolean createRootDir, boolean createWALDir)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniCluster(int numMasters, int numSlaves, String[] dataNodeHosts)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniCluster(int numMasters, int numSlaves, String[] dataNodeHosts, boolean createRootDir)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniCluster(int numMasters, int numSlaves, String[] dataNodeHosts, Class<? extends HMaster> masterClass, Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> rsClass)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniCluster(StartMiniClusterOption option)	Deprecated. Start up a mini cluster of hbase, optionally dfs and zookeeper if needed.
org.apache.hadoop.hdfs.MiniDFSCluster	startMiniDFSCluster(int servers)	Deprecated. Start a minidfscluster.
org.apache.hadoop.hdfs.MiniDFSCluster	startMiniDFSCluster(int servers, String[] hosts)	Deprecated. Start a minidfscluster.
org.apache.hadoop.hdfs.MiniDFSCluster	startMiniDFSCluster(int servers, String[] racks, String[] hosts)	Deprecated.
org.apache.hadoop.hdfs.MiniDFSCluster	startMiniDFSCluster(String[] hosts)	Deprecated. Start a minidfscluster.
org.apache.hadoop.hdfs.MiniDFSCluster	startMiniDFSClusterForTestWAL(int namenodePort)	Deprecated.
MiniHBaseCluster	startMiniHBaseCluster()	Deprecated. Starts up mini hbase cluster using default options.
MiniHBaseCluster	startMiniHBaseCluster(int numMasters, int numRegionServers)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniHBaseCluster(int numMasters, int numRegionServers, List<Integer> rsPorts)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniHBaseCluster(int numMasters, int numRegionServers, List<Integer> rsPorts, Class<? extends HMaster> masterClass, Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> rsClass, boolean createRootDir, boolean createWALDir)	Deprecated. since 2.2.0 and will be removed in 4.0.0.
MiniHBaseCluster	startMiniHBaseCluster(StartMiniClusterOption option)	Deprecated. Starts up mini hbase cluster.
org.apache.hadoop.mapred.MiniMRCluster	startMiniMapReduceCluster()	Deprecated. Starts a MiniMRCluster with a default number of TaskTracker's.
private void	startMiniMapReduceCluster(int servers)	Deprecated. Starts a MiniMRCluster.
Table	truncateTable(TableName tableName)	Deprecated. Truncate a table using the admin command.
Table	truncateTable(TableName tableName, boolean preserveRegions)	Deprecated. Truncate a table using the admin command.
void	unassignRegion(byte[] regionName)	Deprecated. Unassign the named region.
void	unassignRegion(String regionName)	Deprecated. Unassign the named region.
void	unassignRegionByRow(byte[] row, RegionLocator table)	Deprecated. Closes the region containing the given row.
void	unassignRegionByRow(String row, RegionLocator table)	Deprecated. Closes the region containing the given row.
void	verifyNumericRows(Table table, byte[] f, int startRow, int endRow, int replicaId)	Deprecated.
void	verifyNumericRows(HRegion region, byte[] f, int startRow, int endRow)	Deprecated.
void	verifyNumericRows(HRegion region, byte[] f, int startRow, int endRow, boolean present)	Deprecated.
void	verifyNumericRows(Region region, byte[] f, int startRow, int endRow)	Deprecated.
void	verifyNumericRows(Region region, byte[] f, int startRow, int endRow, boolean present)	Deprecated.
void	verifyTableDescriptorIgnoreTableName(TableDescriptor ltd, TableDescriptor rtd)	Deprecated.
static void	waitForHostPort(String host, int port)	Deprecated.
void	waitLabelAvailable(long timeoutMillis, String... labels)	Deprecated. Wait until labels is ready in VisibilityLabelsCache.
void	waitTableAvailable(byte[] table, long timeoutMillis)	Deprecated. Wait until all regions in a table have been assigned
void	waitTableAvailable(TableName table)	Deprecated. Wait until all regions in a table have been assigned.
void	waitTableAvailable(TableName table, long timeoutMillis)	Deprecated.
void	waitTableDisabled(byte[] table)	Deprecated. Waits for a table to be 'disabled'.
void	waitTableDisabled(byte[] table, long timeoutMillis)	Deprecated. Waits for a table to be 'disabled'.
void	waitTableDisabled(TableName table, long millisTimeout)	Deprecated.
void	waitTableEnabled(byte[] table, long timeoutMillis)	Deprecated. Waits for a table to be 'enabled'.
void	waitTableEnabled(TableName table)	Deprecated. Waits for a table to be 'enabled'.
void	waitTableEnabled(TableName table, long timeoutMillis)	Deprecated.
void	waitUntilAllRegionsAssigned(TableName tableName)	Deprecated. Wait until all regions for a table in hbase:meta have a non-empty info:server, up to a configuable timeout value (default is 60 seconds) This means all regions have been deployed, master has been informed and updated hbase:meta with the regions deployed server.
void	waitUntilAllRegionsAssigned(TableName tableName, long timeout)	Deprecated. Wait until all regions for a table in hbase:meta have a non-empty info:server, or until timeout.
void	waitUntilAllSystemRegionsAssigned()	Deprecated. Waith until all system table's regions get assigned
void	waitUntilNoRegionsInTransition()	Deprecated. Wait until no regions in transition.
void	waitUntilNoRegionsInTransition(long timeout)	Deprecated. Wait until no regions in transition.

Methods inherited from class org.apache.hadoop.hbase.HBaseZKTestingUtility

cleanupTestDir, getClusterTestDir, getZkCluster, getZooKeeperWatcher, getZooKeeperWatcher, setupClusterTestDir, setZkCluster, shutdownMiniZKCluster, startMiniZKCluster, startMiniZKCluster

Methods inherited from class org.apache.hadoop.hbase.HBaseCommonTestingUtility

cleanupTestDir, createSubDir, deleteDir, deleteOnExit, getDataTestDir, getDataTestDir, getRandomDir, getRandomUUID, waitFor, waitFor, waitFor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

REGIONS_PER_SERVER_KEY

public static final String REGIONS_PER_SERVER_KEY

Deprecated.

See Also:

• Constant Field Values

DEFAULT_REGIONS_PER_SERVER

public static final int DEFAULT_REGIONS_PER_SERVER

Deprecated.

The default number of regions per regionserver when creating a pre-split table.

See Also:

• Constant Field Values

dfsCluster

private org.apache.hadoop.hdfs.MiniDFSCluster dfsCluster

Deprecated.

dfsClusterFixer

private HBaseTestingUtility.FsDatasetAsyncDiskServiceFixer dfsClusterFixer

Deprecated.

hbaseCluster

private volatile HBaseCluster hbaseCluster

Deprecated.

mrCluster

private org.apache.hadoop.mapred.MiniMRCluster mrCluster

Deprecated.

miniClusterRunning

private volatile boolean miniClusterRunning

Deprecated.

If there is a mini cluster running for this testing utility instance.

hadoopLogDir

private String hadoopLogDir

Deprecated.

dataTestDirOnTestFS

private org.apache.hadoop.fs.Path dataTestDirOnTestFS

Deprecated.

Directory on test filesystem where we put the data for this instance of HBaseTestingUtility

asyncConnection

private final AtomicReference<AsyncClusterConnection> asyncConnection

Deprecated.

FS_URI

private static String FS_URI

Deprecated.

Filesystem URI used for map-reduce mini-cluster setup

MEMSTORETS_TAGS_PARAMETRIZED

public static final List<Object[]> MEMSTORETS_TAGS_PARAMETRIZED

Deprecated.

This is for unit tests parameterized with a single boolean.

BLOOM_AND_COMPRESSION_COMBINATIONS

public static final Collection<Object[]> BLOOM_AND_COMPRESSION_COMBINATIONS

Deprecated.

fam1

public static final byte[] fam1

Deprecated.

fam2

public static final byte[] fam2

Deprecated.

fam3

public static final byte[] fam3

Deprecated.

COLUMNS

public static final byte[][] COLUMNS

Deprecated.

MAXVERSIONS

private static final int MAXVERSIONS

Deprecated.

See Also:

• Constant Field Values

FIRST_CHAR

public static final char FIRST_CHAR

Deprecated.

See Also:

• Constant Field Values

LAST_CHAR

public static final char LAST_CHAR

Deprecated.

See Also:

• Constant Field Values

START_KEY_BYTES

public static final byte[] START_KEY_BYTES

Deprecated.

START_KEY

public static final String START_KEY

Deprecated.

ROWS

public static final byte[][] ROWS

Deprecated.

All the row values for the data loaded by loadTable(Table, byte[])

KEYS

public static final byte[][] KEYS

Deprecated.

KEYS_FOR_HBA_CREATE_TABLE

public static final byte[][] KEYS_FOR_HBA_CREATE_TABLE

Deprecated.

hbaseAdmin

private Admin hbaseAdmin

Deprecated.

Constructor Details

HBaseTestingUtility

public HBaseTestingUtility()

Deprecated.

Create an HBaseTestingUtility using a default configuration.

Initially, all tmp files are written to a local test data directory. Once startMiniDFSCluster(int) is called, either directly or via startMiniCluster(), tmp data will be written to the DFS directory instead.

HBaseTestingUtility

public HBaseTestingUtility(org.apache.hadoop.conf.Configuration conf)

Deprecated.

Create an HBaseTestingUtility using a given configuration.

Initially, all tmp files are written to a local test data directory. Once startMiniDFSCluster(int) is called, either directly or via startMiniCluster(), tmp data will be written to the DFS directory instead.

Parameters:

conf - The configuration to use for further operations

Method Details

available

public static boolean available(int port)

Deprecated.

Checks to see if a specific port is available.

Parameters:

port - the port number to check for availability

Returns:

true if the port is available, or false if not

bloomAndCompressionCombinations

private static List<Object[]> bloomAndCompressionCombinations()

Deprecated.

Create all combinations of Bloom filters and compression algorithms for testing.

memStoreTSAndTagsCombination

private static List<Object[]> memStoreTSAndTagsCombination()

Deprecated.

Create combination of memstoreTS and tags

memStoreTSTagsAndOffheapCombination

public static List<Object[]> memStoreTSTagsAndOffheapCombination()

Deprecated.

closeRegionAndWAL

public static void closeRegionAndWAL(Region r)
                              throws IOException

Deprecated.

Close both the region r and it's underlying WAL. For use in tests.

Throws:

IOException

closeRegionAndWAL

public static void closeRegionAndWAL(HRegion r)
                              throws IOException

Deprecated.

Close both the HRegion r and it's underlying WAL. For use in tests.

Throws:

IOException

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Deprecated.

Returns this classes's instance of Configuration. Be careful how you use the returned Configuration since Connection instances can be shared. The Map of Connections is keyed by the Configuration. If say, a Connection was being used against a cluster that had been shutdown, see shutdownMiniCluster(), then the Connection will no longer be wholesome. Rather than use the return direct, its usually best to make a copy and use that. Do Configuration c = new Configuration(INSTANCE.getConfiguration());

Overrides:

getConfiguration in class HBaseCommonTestingUtility

Returns:

Instance of Configuration.

setHBaseCluster

public void setHBaseCluster(HBaseCluster hbaseCluster)

Deprecated.

setupDataTestDir

protected org.apache.hadoop.fs.Path setupDataTestDir()

Deprecated.

Home our data in a dir under HBaseCommonTestingUtility.DEFAULT_BASE_TEST_DIRECTORY. Give it a random name so can have many concurrent tests running if we need to. Moding a System property is not the way to do concurrent instances -- another instance could grab the temporary value unintentionally -- but not anything can do about it at moment; single instance only is how the minidfscluster works. We also create the underlying directory names for hadoop.log.dir, mapreduce.cluster.local.dir and hadoop.tmp.dir, and set the values in the conf, and as a system property for hadoop.tmp.dir (We do not create them!).

Overrides:

setupDataTestDir in class HBaseCommonTestingUtility

Returns:

The calculated data test build directory, if newly-created.

createSubDirAndSystemProperty

private void createSubDirAndSystemProperty(String propertyName,
 org.apache.hadoop.fs.Path parent,
 String subDirName)

Deprecated.

getBaseTestDirOnTestFS

private org.apache.hadoop.fs.Path getBaseTestDirOnTestFS()
                                                  throws IOException

Deprecated.

Returns:

Where to write test data on the test filesystem; Returns working directory for the test filesystem by default

Throws:

IOException

See Also:

• setupDataTestDirOnTestFS()
• getTestFileSystem()

getDataTestDirOnTestFS

public org.apache.hadoop.fs.Path getDataTestDirOnTestFS()
                                                 throws IOException

Deprecated.

Returns a Path in the test filesystem, obtained from getTestFileSystem() to write temporary test data. Call this method after setting up the mini dfs cluster if the test relies on it.

Returns:

a unique path in the test filesystem

Throws:

IOException

getDataTestDirOnTestFS

public org.apache.hadoop.fs.Path getDataTestDirOnTestFS(String subdirName)
                                                 throws IOException

Deprecated.

Returns a Path in the test filesystem, obtained from getTestFileSystem() to write temporary test data. Call this method after setting up the mini dfs cluster if the test relies on it.

Parameters:

subdirName - name of the subdir to create under the base test dir

Returns:

a unique path in the test filesystem

Throws:

IOException

setupDataTestDirOnTestFS

private void setupDataTestDirOnTestFS()
                               throws IOException

Deprecated.

Sets up a path in test filesystem to be used by tests. Creates a new directory if not already setup.

Throws:

IOException

getNewDataTestDirOnTestFS

private org.apache.hadoop.fs.Path getNewDataTestDirOnTestFS()
                                                     throws IOException

Deprecated.

Sets up a new path in test filesystem to be used by tests.

Throws:

IOException

cleanupDataTestDirOnTestFS

public boolean cleanupDataTestDirOnTestFS()
                                   throws IOException

Deprecated.

Cleans the test data directory on the test filesystem.

Returns:

True if we removed the test dirs

Throws:

IOException

cleanupDataTestDirOnTestFS

public boolean cleanupDataTestDirOnTestFS(String subdirName)
                                   throws IOException

Deprecated.

Cleans a subdirectory under the test data directory on the test filesystem.

Returns:

True if we removed child

Throws:

IOException

startMiniDFSCluster

public org.apache.hadoop.hdfs.MiniDFSCluster startMiniDFSCluster(int servers)
                                                          throws Exception

Deprecated.

Start a minidfscluster.

Parameters:

servers - How many DNs to start.

Returns:

The mini dfs cluster created.

Throws:

Exception

See Also:

• shutdownMiniDFSCluster()

startMiniDFSCluster

public org.apache.hadoop.hdfs.MiniDFSCluster startMiniDFSCluster(String[] hosts)
                                                          throws Exception

Deprecated.

Start a minidfscluster. This is useful if you want to run datanode on distinct hosts for things like HDFS block location verification. If you start MiniDFSCluster without host names, all instances of the datanodes will have the same host name.

Parameters:

hosts - hostnames DNs to run on.

Returns:

The mini dfs cluster created.

Throws:

Exception

See Also:

• shutdownMiniDFSCluster()

startMiniDFSCluster

public org.apache.hadoop.hdfs.MiniDFSCluster startMiniDFSCluster(int servers,
 String[] hosts)
                                                          throws Exception

Deprecated.

Start a minidfscluster. Can only create one.

Parameters:

servers - How many DNs to start.

hosts - hostnames DNs to run on.

Returns:

The mini dfs cluster created.

Throws:

Exception

See Also:

• shutdownMiniDFSCluster()

setFs

private void setFs()
            throws IOException

Deprecated.

Throws:

IOException

startMiniDFSCluster

public org.apache.hadoop.hdfs.MiniDFSCluster startMiniDFSCluster(int servers,
 String[] racks,
 String[] hosts)
                                                          throws Exception

Deprecated.

Throws:

Exception

startMiniDFSClusterForTestWAL

public org.apache.hadoop.hdfs.MiniDFSCluster startMiniDFSClusterForTestWAL(int namenodePort)
                                                                    throws IOException

Deprecated.

Throws:

IOException

createDirsAndSetProperties

private void createDirsAndSetProperties()
                                 throws IOException

Deprecated.

This is used before starting HDFS and map-reduce mini-clusters Run something like the below to check for the likes of '/tmp' references -- i.e. references outside of the test data dir -- in the conf.

 Configuration conf = TEST_UTIL.getConfiguration();
 for (Iterator<Map.Entry<String, String>> i = conf.iterator(); i.hasNext();) {
   Map.Entry<String, String> e = i.next();
   assertFalse(e.getKey() + " " + e.getValue(), e.getValue().contains("/tmp"));
 }
 

Throws:

IOException

isNewVersionBehaviorEnabled

public boolean isNewVersionBehaviorEnabled()

Deprecated.

Check whether the tests should assume NEW_VERSION_BEHAVIOR when creating new column families. Default to false.

isReadShortCircuitOn

public boolean isReadShortCircuitOn()

Deprecated.

Get the HBase setting for dfs.client.read.shortcircuit from the conf or a system property. This allows to specify this parameter on the command line. If not set, default is true.

enableShortCircuit

private void enableShortCircuit()

Deprecated.

Enable the short circuit read, unless configured differently. Set both HBase and HDFS settings, including skipping the hdfs checksum checks.

createDirAndSetProperty

private String createDirAndSetProperty(String property)

Deprecated.

createDirAndSetProperty

private String createDirAndSetProperty(String relPath,
 String property)

Deprecated.

shutdownMiniDFSCluster

public void shutdownMiniDFSCluster()
                            throws IOException

Deprecated.

Shuts down instance created by call to startMiniDFSCluster(int) or does nothing.

Throws:

IOException

startMiniCluster

@Deprecated
public MiniHBaseCluster startMiniCluster(boolean createWALDir)
                                  throws Exception

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniCluster(StartMiniClusterOption) instead.

Start up a minicluster of hbase, dfs, and zookeeper where WAL's walDir is created separately. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

createWALDir - Whether to create a new WAL directory.

Returns:

The mini HBase cluster created.

Throws:

Exception

See Also:

• shutdownMiniCluster()
• startMiniCluster(StartMiniClusterOption)
• HBASE-21071

startMiniCluster

@Deprecated
public MiniHBaseCluster startMiniCluster(int numSlaves,
 boolean createRootDir)
                                  throws Exception

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniCluster(StartMiniClusterOption) instead.

Start up a minicluster of hbase, dfs, and zookeeper. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numSlaves - Slave node number, for both HBase region server and HDFS data node.

createRootDir - Whether to create a new root or data directory path.

Returns:

The mini HBase cluster created.

Throws:

Exception

See Also:

• shutdownMiniCluster()
• startMiniCluster(StartMiniClusterOption)
• HBASE-21071

startMiniCluster

@Deprecated
public MiniHBaseCluster startMiniCluster(int numSlaves,
 boolean createRootDir,
 boolean createWALDir)
                                  throws Exception

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniCluster(StartMiniClusterOption) instead.

Start up a minicluster of hbase, dfs, and zookeeper. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numSlaves - Slave node number, for both HBase region server and HDFS data node.

createRootDir - Whether to create a new root or data directory path.

createWALDir - Whether to create a new WAL directory.

Returns:

The mini HBase cluster created.

Throws:

Exception

See Also:

• shutdownMiniCluster()
• startMiniCluster(StartMiniClusterOption)
• HBASE-21071

startMiniCluster

@Deprecated
public MiniHBaseCluster startMiniCluster(int numMasters,
 int numSlaves,
 boolean createRootDir)
                                  throws Exception

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniCluster(StartMiniClusterOption) instead.

Start up a minicluster of hbase, dfs, and zookeeper. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numMasters - Master node number.

numSlaves - Slave node number, for both HBase region server and HDFS data node.

createRootDir - Whether to create a new root or data directory path.

Returns:

The mini HBase cluster created.

Throws:

Exception

See Also:

• shutdownMiniCluster()
• startMiniCluster(StartMiniClusterOption)
• HBASE-21071

startMiniCluster

@Deprecated
public MiniHBaseCluster startMiniCluster(int numMasters,
 int numSlaves)
                                  throws Exception

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniCluster(StartMiniClusterOption) instead.

Start up a minicluster of hbase, dfs, and zookeeper. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numMasters - Master node number.

numSlaves - Slave node number, for both HBase region server and HDFS data node.

Returns:

The mini HBase cluster created.

Throws:

Exception

See Also:

• shutdownMiniCluster()
• startMiniCluster(StartMiniClusterOption)
• HBASE-21071

startMiniCluster

@Deprecated
public MiniHBaseCluster startMiniCluster(int numMasters,
 int numSlaves,
 String[] dataNodeHosts,
 boolean createRootDir)
                                  throws Exception

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniCluster(StartMiniClusterOption) instead.

Start up a minicluster of hbase, dfs, and zookeeper. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numMasters - Master node number.

numSlaves - Slave node number, for both HBase region server and HDFS data node.

dataNodeHosts - The hostnames of DataNodes to run on. If not null, its size will overwrite HDFS data node number.

createRootDir - Whether to create a new root or data directory path.

Returns:

The mini HBase cluster created.

Throws:

Exception

See Also:

• shutdownMiniCluster()
• startMiniCluster(StartMiniClusterOption)
• HBASE-21071

startMiniCluster

@Deprecated
public MiniHBaseCluster startMiniCluster(int numMasters,
 int numSlaves,
 String[] dataNodeHosts)
                                  throws Exception

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniCluster(StartMiniClusterOption) instead.

Start up a minicluster of hbase, dfs, and zookeeper. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numMasters - Master node number.

numSlaves - Slave node number, for both HBase region server and HDFS data node.

dataNodeHosts - The hostnames of DataNodes to run on. If not null, its size will overwrite HDFS data node number.

Returns:

The mini HBase cluster created.

Throws:

Exception

See Also:

• shutdownMiniCluster()
• startMiniCluster(StartMiniClusterOption)
• HBASE-21071

startMiniCluster

@Deprecated
public MiniHBaseCluster startMiniCluster(int numMasters,
 int numRegionServers,
 int numDataNodes)
                                  throws Exception

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniCluster(StartMiniClusterOption) instead.

Start up a minicluster of hbase, dfs, and zookeeper. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numMasters - Master node number.

numRegionServers - Number of region servers.

numDataNodes - Number of datanodes.

Returns:

The mini HBase cluster created.

Throws:

Exception

See Also:

• shutdownMiniCluster()
• startMiniCluster(StartMiniClusterOption)
• HBASE-21071

startMiniCluster

@Deprecated
public MiniHBaseCluster startMiniCluster(int numMasters,
 int numSlaves,
 String[] dataNodeHosts,
 Class<? extends HMaster> masterClass,
 Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> rsClass)
                                  throws Exception

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniCluster(StartMiniClusterOption) instead.

Start up a minicluster of hbase, dfs, and zookeeper. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numMasters - Master node number.

numSlaves - Slave node number, for both HBase region server and HDFS data node.

dataNodeHosts - The hostnames of DataNodes to run on. If not null, its size will overwrite HDFS data node number.

masterClass - The class to use as HMaster, or null for default.

rsClass - The class to use as HRegionServer, or null for default.

Returns:

The mini HBase cluster created.

Throws:

Exception

See Also:

• shutdownMiniCluster()
• startMiniCluster(StartMiniClusterOption)
• HBASE-21071

startMiniCluster

@Deprecated
public MiniHBaseCluster startMiniCluster(int numMasters,
 int numRegionServers,
 int numDataNodes,
 String[] dataNodeHosts,
 Class<? extends HMaster> masterClass,
 Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> rsClass)
                                  throws Exception

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniCluster(StartMiniClusterOption) instead.

Start up a minicluster of hbase, dfs, and zookeeper. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numMasters - Master node number.

numRegionServers - Number of region servers.

numDataNodes - Number of datanodes.

dataNodeHosts - The hostnames of DataNodes to run on. If not null, its size will overwrite HDFS data node number.

masterClass - The class to use as HMaster, or null for default.

rsClass - The class to use as HRegionServer, or null for default.

Returns:

The mini HBase cluster created.

Throws:

Exception

See Also:

• shutdownMiniCluster()
• startMiniCluster(StartMiniClusterOption)
• HBASE-21071

startMiniCluster

@Deprecated
public MiniHBaseCluster startMiniCluster(int numMasters,
 int numRegionServers,
 int numDataNodes,
 String[] dataNodeHosts,
 Class<? extends HMaster> masterClass,
 Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> rsClass,
 boolean createRootDir,
 boolean createWALDir)
                                  throws Exception

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniCluster(StartMiniClusterOption) instead.

Start up a minicluster of hbase, dfs, and zookeeper. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numMasters - Master node number.

numRegionServers - Number of region servers.

numDataNodes - Number of datanodes.

dataNodeHosts - The hostnames of DataNodes to run on. If not null, its size will overwrite HDFS data node number.

masterClass - The class to use as HMaster, or null for default.

rsClass - The class to use as HRegionServer, or null for default.

createRootDir - Whether to create a new root or data directory path.

createWALDir - Whether to create a new WAL directory.

Returns:

The mini HBase cluster created.

Throws:

Exception

See Also:

• shutdownMiniCluster()
• startMiniCluster(StartMiniClusterOption)
• HBASE-21071

startMiniCluster

public MiniHBaseCluster startMiniCluster(int numSlaves)
                                  throws Exception

Deprecated.

Start up a minicluster of hbase, dfs and zookeeper clusters with given slave node number. All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numSlaves - slave node number, for both HBase region server and HDFS data node.

Throws:

Exception

See Also:

• startMiniCluster(StartMiniClusterOption option)
• shutdownMiniDFSCluster()

startMiniCluster

public MiniHBaseCluster startMiniCluster()
                                  throws Exception

Deprecated.

Start up a minicluster of hbase, dfs and zookeeper all using default options. Option default value can be found in StartMiniClusterOption.Builder.

Throws:

Exception

See Also:

• startMiniCluster(StartMiniClusterOption option)
• shutdownMiniDFSCluster()

startMiniCluster

public MiniHBaseCluster startMiniCluster(StartMiniClusterOption option)
                                  throws Exception

Deprecated.

Start up a mini cluster of hbase, optionally dfs and zookeeper if needed. It modifies Configuration. It homes the cluster data directory under a random subdirectory in a directory under System property test.build.data, to be cleaned up on exit.

Throws:

Exception

See Also:

• shutdownMiniDFSCluster()

startMiniHBaseCluster

public MiniHBaseCluster startMiniHBaseCluster(StartMiniClusterOption option)
                                       throws IOException,
InterruptedException

Deprecated.

Starts up mini hbase cluster. Usually you won't want this. You'll usually want startMiniCluster(). This is useful when doing stepped startup of clusters.

Returns:

Reference to the hbase mini hbase cluster.

Throws:

IOException

InterruptedException

See Also:

• startMiniCluster(StartMiniClusterOption)
• shutdownMiniHBaseCluster()

startMiniHBaseCluster

public MiniHBaseCluster startMiniHBaseCluster()
                                       throws IOException,
InterruptedException

Deprecated.

Starts up mini hbase cluster using default options. Default options can be found in StartMiniClusterOption.Builder.

Throws:

IOException

InterruptedException

See Also:

• startMiniHBaseCluster(StartMiniClusterOption)
• shutdownMiniHBaseCluster()

startMiniHBaseCluster

@Deprecated
public MiniHBaseCluster startMiniHBaseCluster(int numMasters,
 int numRegionServers)
                                       throws IOException,
InterruptedException

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniHBaseCluster(StartMiniClusterOption) instead.

Starts up mini hbase cluster. Usually you won't want this. You'll usually want startMiniCluster(). All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numMasters - Master node number.

numRegionServers - Number of region servers.

Returns:

The mini HBase cluster created.

Throws:

IOException

InterruptedException

See Also:

• shutdownMiniHBaseCluster()
• startMiniHBaseCluster(StartMiniClusterOption)
• HBASE-21071

startMiniHBaseCluster

@Deprecated
public MiniHBaseCluster startMiniHBaseCluster(int numMasters,
 int numRegionServers,
 List<Integer> rsPorts)
                                       throws IOException,
InterruptedException

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniHBaseCluster(StartMiniClusterOption) instead.

Starts up mini hbase cluster. Usually you won't want this. You'll usually want startMiniCluster(). All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numMasters - Master node number.

numRegionServers - Number of region servers.

rsPorts - Ports that RegionServer should use.

Returns:

The mini HBase cluster created.

Throws:

IOException

InterruptedException

See Also:

• shutdownMiniHBaseCluster()
• startMiniHBaseCluster(StartMiniClusterOption)
• HBASE-21071

startMiniHBaseCluster

@Deprecated
public MiniHBaseCluster startMiniHBaseCluster(int numMasters,
 int numRegionServers,
 List<Integer> rsPorts,
 Class<? extends HMaster> masterClass,
 Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> rsClass,
 boolean createRootDir,
 boolean createWALDir)
                                       throws IOException,
InterruptedException

Deprecated.

since 2.2.0 and will be removed in 4.0.0. Use startMiniHBaseCluster(StartMiniClusterOption) instead.

Starts up mini hbase cluster. Usually you won't want this. You'll usually want startMiniCluster(). All other options will use default values, defined in StartMiniClusterOption.Builder.

Parameters:

numMasters - Master node number.

numRegionServers - Number of region servers.

rsPorts - Ports that RegionServer should use.

masterClass - The class to use as HMaster, or null for default.

rsClass - The class to use as HRegionServer, or null for default.

createRootDir - Whether to create a new root or data directory path.

createWALDir - Whether to create a new WAL directory.

Returns:

The mini HBase cluster created.

Throws:

IOException

InterruptedException

See Also:

• shutdownMiniHBaseCluster()
• startMiniHBaseCluster(StartMiniClusterOption)
• HBASE-21071

restartHBaseCluster

public void restartHBaseCluster(int servers)
                         throws IOException,
InterruptedException

Deprecated.

Starts the hbase cluster up again after shutting it down previously in a test. Use this if you want to keep dfs/zk up and just stop/start hbase.

Parameters:

servers - number of region servers

Throws:

IOException

InterruptedException

restartHBaseCluster

public void restartHBaseCluster(int servers,
 List<Integer> ports)
                         throws IOException,
InterruptedException

Deprecated.

Throws:

IOException

InterruptedException

restartHBaseCluster

public void restartHBaseCluster(StartMiniClusterOption option)
                         throws IOException,
InterruptedException

Deprecated.

Throws:

IOException

InterruptedException

getMiniHBaseCluster

public MiniHBaseCluster getMiniHBaseCluster()

Deprecated.

Returns:

Current mini hbase cluster. Only has something in it after a call to startMiniCluster().

See Also:

• startMiniCluster()

shutdownMiniCluster

public void shutdownMiniCluster()
                         throws IOException

Deprecated.

Stops mini hbase, zk, and hdfs clusters.

Throws:

IOException

See Also:

• startMiniCluster(int)

shutdownMiniHBaseCluster

public void shutdownMiniHBaseCluster()
                              throws IOException

Deprecated.

Shutdown HBase mini cluster.Does not shutdown zk or dfs if running.

Throws:

IOException - in case command is unsuccessful

killMiniHBaseCluster

public void killMiniHBaseCluster()
                          throws IOException

Deprecated.

Abruptly Shutdown HBase mini cluster. Does not shutdown zk or dfs if running.

Throws:

IOException - throws in case command is unsuccessful

cleanup

private void cleanup()
              throws IOException

Deprecated.

Throws:

IOException

getDefaultRootDirPath

public org.apache.hadoop.fs.Path getDefaultRootDirPath(boolean create)
                                                throws IOException

Deprecated.

Returns the path to the default root dir the minicluster uses. If create is true, a new root directory path is fetched irrespective of whether it has been fetched before or not. If false, previous path is used. Note: this does not cause the root dir to be created.

Returns:

Fully qualified path for the default hbase root dir

Throws:

IOException

getDefaultRootDirPath

public org.apache.hadoop.fs.Path getDefaultRootDirPath()
                                                throws IOException

Deprecated.

Same as {getDefaultRootDirPath(boolean create) except that create flag is false. Note: this does not cause the root dir to be created.

Returns:

Fully qualified path for the default hbase root dir

Throws:

IOException

createRootDir

public org.apache.hadoop.fs.Path createRootDir(boolean create)
                                        throws IOException

Deprecated.

Creates an hbase rootdir in user home directory. Also creates hbase version file. Normally you won't make use of this method. Root hbasedir is created for you as part of mini cluster startup. You'd only use this method if you were doing manual operation.

Parameters:

create - This flag decides whether to get a new root or data directory path or not, if it has been fetched already. Note : Directory will be made irrespective of whether path has been fetched or not. If directory already exists, it will be overwritten

Returns:

Fully qualified path to hbase root dir

Throws:

IOException

createRootDir

public org.apache.hadoop.fs.Path createRootDir()
                                        throws IOException

Deprecated.

Same as createRootDir(boolean create) except that create flag is false.

Returns:

Fully qualified path to hbase root dir

Throws:

IOException

createWALRootDir

public org.apache.hadoop.fs.Path createWALRootDir()
                                           throws IOException

Deprecated.

Creates a hbase walDir in the user's home directory. Normally you won't make use of this method. Root hbaseWALDir is created for you as part of mini cluster startup. You'd only use this method if you were doing manual operation.

Returns:

Fully qualified path to hbase root dir

Throws:

IOException

setHBaseFsTmpDir

private void setHBaseFsTmpDir()
                       throws IOException

Deprecated.

Throws:

IOException

flush

public void flush()
           throws IOException

Deprecated.

Flushes all caches in the mini hbase cluster

Throws:

IOException

flush

public void flush(TableName tableName)
           throws IOException

Deprecated.

Flushes all caches in the mini hbase cluster

Throws:

IOException

compact

public void compact(boolean major)
             throws IOException

Deprecated.

Compact all regions in the mini hbase cluster

Throws:

IOException

compact

public void compact(TableName tableName,
 boolean major)
             throws IOException

Deprecated.

Compact all of a table's reagion in the mini hbase cluster

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 String family)
                  throws IOException

Deprecated.

Create a table.

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 String[] families)
                  throws IOException

Deprecated.

Create a table.

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[] family)
                  throws IOException

Deprecated.

Create a table.

Returns:

A Table instance for the created table.

Throws:

IOException

createMultiRegionTable

public Table createMultiRegionTable(TableName tableName,
 byte[] family,
 int numRegions)
                             throws IOException

Deprecated.

Create a table with multiple regions.

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[][] families)
                  throws IOException

Deprecated.

Create a table.

Returns:

A Table instance for the created table.

Throws:

IOException

createMultiRegionTable

public Table createMultiRegionTable(TableName tableName,
 byte[][] families)
                             throws IOException

Deprecated.

Create a table with multiple regions.

Returns:

A Table instance for the created table.

Throws:

IOException

createMultiRegionTable

public Table createMultiRegionTable(TableName tableName,
 int replicaCount,
 byte[][] families)
                             throws IOException

Deprecated.

Create a table with multiple regions.

Parameters:

replicaCount - replica count.

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[][] families,
 byte[][] splitKeys)
                  throws IOException

Deprecated.

Create a table.

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[][] families,
 byte[][] splitKeys,
 int replicaCount)
                  throws IOException

Deprecated.

Create a table.

Parameters:

tableName - the table name

families - the families

splitKeys - the splitkeys

replicaCount - the region replica count

Returns:

A Table instance for the created table.

Throws:

IOException - throws IOException

createTable

public Table createTable(TableName tableName,
 byte[][] families,
 int numVersions,
 byte[] startKey,
 byte[] endKey,
 int numRegions)
                  throws IOException

Deprecated.

Throws:

IOException

createTable

public Table createTable(TableDescriptor htd,
 byte[][] families,
 org.apache.hadoop.conf.Configuration c)
                  throws IOException

Deprecated.

Create a table.

Parameters:

c - Configuration to use

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableDescriptor htd,
 byte[][] families,
 byte[][] splitKeys,
 org.apache.hadoop.conf.Configuration c)
                  throws IOException

Deprecated.

Create a table.

Parameters:

htd - table descriptor

families - array of column families

splitKeys - array of split keys

c - Configuration to use

Returns:

A Table instance for the created table.

Throws:

IOException - if getAdmin or createTable fails

createTable

public Table createTable(TableDescriptor htd,
 byte[][] families,
 byte[][] splitKeys,
 BloomType type,
 int blockSize,
 org.apache.hadoop.conf.Configuration c)
                  throws IOException

Deprecated.

Create a table.

Parameters:

htd - table descriptor

families - array of column families

splitKeys - array of split keys

type - Bloom type

blockSize - block size

c - Configuration to use

Returns:

A Table instance for the created table.

Throws:

IOException - if getAdmin or createTable fails

createTable

public Table createTable(TableDescriptor htd,
 byte[][] splitRows)
                  throws IOException

Deprecated.

Create a table.

Parameters:

htd - table descriptor

splitRows - array of split keys

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[][] families,
 byte[][] splitKeys,
 int replicaCount,
 org.apache.hadoop.conf.Configuration c)
                  throws IOException

Deprecated.

Create a table.

Parameters:

tableName - the table name

families - the families

splitKeys - the split keys

replicaCount - the replica count

c - Configuration to use

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[] family,
 int numVersions)
                  throws IOException

Deprecated.

Create a table.

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[][] families,
 int numVersions)
                  throws IOException

Deprecated.

Create a table.

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[][] families,
 int numVersions,
 byte[][] splitKeys)
                  throws IOException

Deprecated.

Create a table.

Returns:

A Table instance for the created table.

Throws:

IOException

createMultiRegionTable

public Table createMultiRegionTable(TableName tableName,
 byte[][] families,
 int numVersions)
                             throws IOException

Deprecated.

Create a table with multiple regions.

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[][] families,
 int numVersions,
 int blockSize)
                  throws IOException

Deprecated.

Create a table.

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[][] families,
 int numVersions,
 int blockSize,
 String cpName)
                  throws IOException

Deprecated.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[][] families,
 int[] numVersions)
                  throws IOException

Deprecated.

Create a table.

Returns:

A Table instance for the created table.

Throws:

IOException

createTable

public Table createTable(TableName tableName,
 byte[] family,
 byte[][] splitRows)
                  throws IOException

Deprecated.

Create a table.

Returns:

A Table instance for the created table.

Throws:

IOException

createMultiRegionTable

public Table createMultiRegionTable(TableName tableName,
 byte[] family)
                             throws IOException

Deprecated.

Create a table with multiple regions.

Returns:

A Table instance for the created table.

Throws:

IOException

modifyTableSync

@Deprecated
public static void modifyTableSync(Admin admin,
 TableDescriptor desc)
                            throws IOException,
InterruptedException

Deprecated.

since 3.0.0 and will be removed in 4.0.0. Just use Admin.modifyTable(TableDescriptor) directly as it is synchronous now.

Modify a table, synchronous.

Throws:

IOException

InterruptedException

See Also:

• Admin.modifyTable(TableDescriptor)
• HBASE-22002

setReplicas

public static void setReplicas(Admin admin,
 TableName table,
 int replicaCount)
                        throws IOException,
InterruptedException

Deprecated.

Set the number of Region replicas.

Throws:

IOException

InterruptedException

deleteTable

public void deleteTable(TableName tableName)
                 throws IOException

Deprecated.

Drop an existing table

Parameters:

tableName - existing table

Throws:

IOException

deleteTableIfAny

public void deleteTableIfAny(TableName tableName)
                      throws IOException

Deprecated.

Drop an existing table

Parameters:

tableName - existing table

Throws:

IOException

createModifyableTableDescriptor

public TableDescriptorBuilder createModifyableTableDescriptor(String name)

Deprecated.

createTableDescriptor

public TableDescriptor createTableDescriptor(TableName name,
 int minVersions,
 int versions,
 int ttl,
 KeepDeletedCells keepDeleted)

Deprecated.

createModifyableTableDescriptor

public TableDescriptorBuilder createModifyableTableDescriptor(TableName name,
 int minVersions,
 int versions,
 int ttl,
 KeepDeletedCells keepDeleted)

Deprecated.

createTableDescriptor

public TableDescriptor createTableDescriptor(TableName name)

Deprecated.

Create a table of name name.

Parameters:

name - Name to give table.

Returns:

Column descriptor.

createTableDescriptor

public TableDescriptor createTableDescriptor(TableName tableName,
 byte[] family)

Deprecated.

createTableDescriptor

public TableDescriptor createTableDescriptor(TableName tableName,
 byte[][] families,
 int maxVersions)

Deprecated.

createLocalHRegion

public HRegion createLocalHRegion(TableDescriptor desc,
 byte[] startKey,
 byte[] endKey)
                           throws IOException

Deprecated.

Create an HRegion that writes to the local tmp dirs

Parameters:

desc - a table descriptor indicating which table the region belongs to

startKey - the start boundary of the region

endKey - the end boundary of the region

Returns:

a region that writes to local dir for testing

Throws:

IOException

createLocalHRegion

public HRegion createLocalHRegion(RegionInfo info,
 TableDescriptor desc)
                           throws IOException

Deprecated.

Create an HRegion that writes to the local tmp dirs. Creates the WAL for you. Be sure to call closeRegionAndWAL(HRegion) when you're finished with it.

Throws:

IOException

createLocalHRegion

public HRegion createLocalHRegion(RegionInfo info,
 org.apache.hadoop.conf.Configuration conf,
 TableDescriptor desc,
 WAL wal)
                           throws IOException

Deprecated.

Create an HRegion that writes to the local tmp dirs with specified wal

Parameters:

info - regioninfo

conf - configuration

desc - table descriptor

wal - wal for this region.

Returns:

created hregion

Throws:

IOException

createLocalHRegion

public HRegion createLocalHRegion(TableName tableName,
 byte[] startKey,
 byte[] stopKey,
 org.apache.hadoop.conf.Configuration conf,
 boolean isReadOnly,
 Durability durability,
 WAL wal,
 byte[]... families)
                           throws IOException

Deprecated.

Return a region on which you must call closeRegionAndWAL(HRegion) when done.

Throws:

IOException

createLocalHRegionWithInMemoryFlags

public HRegion createLocalHRegionWithInMemoryFlags(TableName tableName,
 byte[] startKey,
 byte[] stopKey,
 org.apache.hadoop.conf.Configuration conf,
 boolean isReadOnly,
 Durability durability,
 WAL wal,
 boolean[] compactedMemStore,
 byte[]... families)
                                            throws IOException

Deprecated.

Throws:

IOException

deleteTableData

public Table deleteTableData(TableName tableName)
                      throws IOException

Deprecated.

Provide an existing table name to truncate. Scans the table and issues a delete for each row read.

Parameters:

tableName - existing table

Returns:

HTable to that new table

Throws:

IOException

truncateTable

public Table truncateTable(TableName tableName,
 boolean preserveRegions)
                    throws IOException

Deprecated.

Truncate a table using the admin command. Effectively disables, deletes, and recreates the table.

Parameters:

tableName - table which must exist.

preserveRegions - keep the existing split points

Returns:

HTable for the new table

Throws:

IOException

truncateTable

public Table truncateTable(TableName tableName)
                    throws IOException

Deprecated.

Truncate a table using the admin command. Effectively disables, deletes, and recreates the table. For previous behavior of issuing row deletes, see deleteTableData. Expressly does not preserve regions of existing table.

Parameters:

tableName - table which must exist.

Returns:

HTable for the new table

Throws:

IOException

loadTable

public int loadTable(Table t,
 byte[] f)
              throws IOException

Deprecated.

Load table with rows from 'aaa' to 'zzz'.

Parameters:

t - Table

f - Family

Returns:

Count of rows loaded.

Throws:

IOException

loadTable

public int loadTable(Table t,
 byte[] f,
 boolean writeToWAL)
              throws IOException

Deprecated.

Load table with rows from 'aaa' to 'zzz'.

Parameters:

t - Table

f - Family

Returns:

Count of rows loaded.

Throws:

IOException

loadTable

public int loadTable(Table t,
 byte[][] f)
              throws IOException

Deprecated.

Load table of multiple column families with rows from 'aaa' to 'zzz'.

Parameters:

t - Table

f - Array of Families to load

Returns:

Count of rows loaded.

Throws:

IOException

loadTable

public int loadTable(Table t,
 byte[][] f,
 byte[] value)
              throws IOException

Deprecated.

Load table of multiple column families with rows from 'aaa' to 'zzz'.

Parameters:

t - Table

f - Array of Families to load

value - the values of the cells. If null is passed, the row key is used as value

Returns:

Count of rows loaded.

Throws:

IOException

loadTable

public int loadTable(Table t,
 byte[][] f,
 byte[] value,
 boolean writeToWAL)
              throws IOException

Deprecated.

Load table of multiple column families with rows from 'aaa' to 'zzz'.

Parameters:

t - Table

f - Array of Families to load

value - the values of the cells. If null is passed, the row key is used as value

Returns:

Count of rows loaded.

Throws:

IOException

loadRegion

public int loadRegion(HRegion r,
 byte[] f)
               throws IOException

Deprecated.

Throws:

IOException

loadRegion

public int loadRegion(Region r,
 byte[] f)
               throws IOException

Deprecated.

Throws:

IOException

loadRegion

public int loadRegion(HRegion r,
 byte[] f,
 boolean flush)
               throws IOException

Deprecated.

Load region with rows from 'aaa' to 'zzz'.

Parameters:

r - Region

f - Family

flush - flush the cache if true

Returns:

Count of rows loaded.

Throws:

IOException

loadNumericRows

public void loadNumericRows(Table t,
 byte[] f,
 int startRow,
 int endRow)
                     throws IOException

Deprecated.

Throws:

IOException

loadRandomRows

public void loadRandomRows(Table t,
 byte[] f,
 int rowSize,
 int totalRows)
                    throws IOException

Deprecated.

Throws:

IOException

verifyNumericRows

public void verifyNumericRows(Table table,
 byte[] f,
 int startRow,
 int endRow,
 int replicaId)
                       throws IOException

Deprecated.

Throws:

IOException

verifyNumericRows

public void verifyNumericRows(Region region,
 byte[] f,
 int startRow,
 int endRow)
                       throws IOException

Deprecated.

Throws:

IOException

verifyNumericRows

public void verifyNumericRows(HRegion region,
 byte[] f,
 int startRow,
 int endRow)
                       throws IOException

Deprecated.

Throws:

IOException

verifyNumericRows

public void verifyNumericRows(Region region,
 byte[] f,
 int startRow,
 int endRow,
 boolean present)
                       throws IOException

Deprecated.

Throws:

IOException

verifyNumericRows

public void verifyNumericRows(HRegion region,
 byte[] f,
 int startRow,
 int endRow,
 boolean present)
                       throws IOException

Deprecated.

Throws:

IOException

deleteNumericRows

public void deleteNumericRows(Table t,
 byte[] f,
 int startRow,
 int endRow)
                       throws IOException

Deprecated.

Throws:

IOException

countRows

public static int countRows(Table table)
                     throws IOException

Deprecated.

Return the number of rows in the given table.

Parameters:

table - to count rows

Returns:

count of rows

Throws:

IOException

countRows

public static int countRows(Table table,
 Scan scan)
                     throws IOException

Deprecated.

Throws:

IOException

countRows

public int countRows(Table table,
 byte[]... families)
              throws IOException

Deprecated.

Throws:

IOException

countRows

public int countRows(TableName tableName)
              throws IOException

Deprecated.

Return the number of rows in the given table.

Throws:

IOException

countRows

public int countRows(Region region)
              throws IOException

Deprecated.

Throws:

IOException

countRows

public int countRows(Region region,
 Scan scan)
              throws IOException

Deprecated.

Throws:

IOException

countRows

public int countRows(InternalScanner scanner)
              throws IOException

Deprecated.

Throws:

IOException

checksumRows

public String checksumRows(Table table)
                    throws Exception

Deprecated.

Return an md5 digest of the entire contents of a table.

Throws:

Exception

createMultiRegionsInMeta

public List<RegionInfo> createMultiRegionsInMeta(org.apache.hadoop.conf.Configuration conf,
 TableDescriptor htd,
 byte[][] startKeys)
                                          throws IOException

Deprecated.

Create rows in hbase:meta for regions of the specified table with the specified start keys. The first startKey should be a 0 length byte array if you want to form a proper range of regions.

Returns:

list of region info for regions added to meta

Throws:

IOException

createWal

public static WAL createWal(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.fs.Path rootDir,
 RegionInfo hri)
                     throws IOException

Deprecated.

Create an unmanaged WAL. Be sure to close it when you're through.

Throws:

IOException

createRegionAndWAL

public static HRegion createRegionAndWAL(RegionInfo info,
 org.apache.hadoop.fs.Path rootDir,
 org.apache.hadoop.conf.Configuration conf,
 TableDescriptor htd)
                                  throws IOException

Deprecated.

Create a region with it's own WAL. Be sure to call closeRegionAndWAL(HRegion) to clean up all resources.

Throws:

IOException

createRegionAndWAL

public static HRegion createRegionAndWAL(RegionInfo info,
 org.apache.hadoop.fs.Path rootDir,
 org.apache.hadoop.conf.Configuration conf,
 TableDescriptor htd,
 BlockCache blockCache)
                                  throws IOException

Deprecated.

Create a region with it's own WAL. Be sure to call closeRegionAndWAL(HRegion) to clean up all resources.

Throws:

IOException

createRegionAndWAL

public static HRegion createRegionAndWAL(RegionInfo info,
 org.apache.hadoop.fs.Path rootDir,
 org.apache.hadoop.conf.Configuration conf,
 TableDescriptor htd,
 MobFileCache mobFileCache)
                                  throws IOException

Deprecated.

Create a region with it's own WAL. Be sure to call closeRegionAndWAL(HRegion) to clean up all resources.

Throws:

IOException

createRegionAndWAL

public static HRegion createRegionAndWAL(RegionInfo info,
 org.apache.hadoop.fs.Path rootDir,
 org.apache.hadoop.conf.Configuration conf,
 TableDescriptor htd,
 boolean initialize)
                                  throws IOException

Deprecated.

Create a region with it's own WAL. Be sure to call closeRegionAndWAL(HRegion) to clean up all resources.

Throws:

IOException

getMetaTableRows

public List<byte[]> getMetaTableRows()
                              throws IOException

Deprecated.

Returns all rows from the hbase:meta table.

Throws:

IOException - When reading the rows fails.

getMetaTableRows

public List<byte[]> getMetaTableRows(TableName tableName)
                              throws IOException

Deprecated.

Returns all rows from the hbase:meta table for a given user table

Throws:

IOException - When reading the rows fails.

getRegions

private List<RegionInfo> getRegions(TableName tableName)
                             throws IOException

Deprecated.

Returns all regions of the specified table

Parameters:

tableName - the table name

Returns:

all regions of the specified table

Throws:

IOException - when getting the regions fails.

getOtherRegionServer

public HRegionServer getOtherRegionServer(HRegionServer rs)

Deprecated.

Find any other region server which is different from the one identified by parameter

Returns:

another region server

getRSForFirstRegionInTable

public HRegionServer getRSForFirstRegionInTable(TableName tableName)
                                         throws IOException,
InterruptedException

Deprecated.

Tool to get the reference to the region server object that holds the region of the specified user table.

Parameters:

tableName - user table to lookup in hbase:meta

Returns:

region server that holds it, null if the row doesn't exist

Throws:

IOException

InterruptedException

startMiniMapReduceCluster

public org.apache.hadoop.mapred.MiniMRCluster startMiniMapReduceCluster()
                                                                 throws IOException

Deprecated.

Starts a MiniMRCluster with a default number of TaskTracker's.

Throws:

IOException - When starting the cluster fails.

forceChangeTaskLogDir

private void forceChangeTaskLogDir()

Deprecated.

Tasktracker has a bug where changing the hadoop.log.dir system property will not change its internal static LOG_DIR variable.

startMiniMapReduceCluster

private void startMiniMapReduceCluster(int servers)
                                throws IOException

Deprecated.

Starts a MiniMRCluster. Call setFileSystemURI(String) to use a different filesystem.

Parameters:

servers - The number of TaskTracker's to start.

Throws:

IOException - When starting the cluster fails.

shutdownMiniMapReduceCluster

public void shutdownMiniMapReduceCluster()

Deprecated.

Stops the previously started MiniMRCluster.

createMockRegionServerService

public RegionServerServices createMockRegionServerService()
                                                   throws IOException

Deprecated.

Create a stubbed out RegionServerService, mainly for getting FS.

Throws:

IOException

createMockRegionServerService

public RegionServerServices createMockRegionServerService(RpcServerInterface rpc)
                                                   throws IOException

Deprecated.

Create a stubbed out RegionServerService, mainly for getting FS. This version is used by TestTokenAuthentication

Throws:

IOException

createMockRegionServerService

public RegionServerServices createMockRegionServerService(ServerName name)
                                                   throws IOException

Deprecated.

Create a stubbed out RegionServerService, mainly for getting FS. This version is used by TestOpenRegionHandler

Throws:

IOException

enableDebug

@Deprecated
public void enableDebug(Class<?> clazz)

Deprecated.

In 2.3.0, will be removed in 4.0.0. Only support changing log level on log4j now as HBase only uses log4j. You should do this by your own as it you know which log framework you are using then set the log level to debug is very easy.

Switches the logger for the given class to DEBUG level.

Parameters:

clazz - The class for which to switch to debug logging.

expireMasterSession

public void expireMasterSession()
                         throws Exception

Deprecated.

Expire the Master's session

Throws:

Exception

expireRegionServerSession

public void expireRegionServerSession(int index)
                               throws Exception

Deprecated.

Expire a region server's session

Parameters:

index - which RS

Throws:

Exception

decrementMinRegionServerCount

private void decrementMinRegionServerCount()

Deprecated.

decrementMinRegionServerCount

private void decrementMinRegionServerCount(org.apache.hadoop.conf.Configuration conf)

Deprecated.

expireSession

public void expireSession(ZKWatcher nodeZK)
                   throws Exception

Deprecated.

Throws:

Exception

expireSession

public void expireSession(ZKWatcher nodeZK,
 boolean checkStatus)
                   throws Exception

Deprecated.

Expire a ZooKeeper session as recommended in ZooKeeper documentation http://hbase.apache.org/book.html#trouble.zookeeper There are issues when doing this: [1] http://www.mail-archive.com/dev@zookeeper.apache.org/msg01942.html [2] https://issues.apache.org/jira/browse/ZOOKEEPER-1105

Parameters:

nodeZK - - the ZK watcher to expire

checkStatus - - true to check if we can create a Table with the current configuration.

Throws:

Exception

getHBaseCluster

public MiniHBaseCluster getHBaseCluster()

Deprecated.

Get the Mini HBase cluster.

Returns:

hbase cluster

See Also:

• getHBaseClusterInterface()

getHBaseClusterInterface

public HBaseCluster getHBaseClusterInterface()

Deprecated.

Returns the HBaseCluster instance.

Returned object can be any of the subclasses of HBaseCluster, and the tests referring this should not assume that the cluster is a mini cluster or a distributed one. If the test only works on a mini cluster, then specific method getMiniHBaseCluster() can be used instead w/o the need to type-cast.

invalidateConnection

public void invalidateConnection()
                          throws IOException

Deprecated.

Resets the connections so that the next time getConnection() is called, a new connection is created. This is needed in cases where the entire cluster / all the masters are shutdown and the connection is not valid anymore. TODO: There should be a more coherent way of doing this. Unfortunately the way tests are written, not all start() stop() calls go through this class. Most tests directly operate on the underlying mini/local hbase cluster. That makes it difficult for this wrapper class to maintain the connection state automatically. Cleaning this is a much bigger refactor.

Throws:

IOException

getConnection

public Connection getConnection()
                         throws IOException

Deprecated.

Get a shared Connection to the cluster. this method is thread safe.

Returns:

A Connection that can be shared. Don't close. Will be closed on shutdown of cluster.

Throws:

IOException

getConnection

public Connection getConnection(User user)
                         throws IOException

Deprecated.

Get a assigned Connection to the cluster. this method is thread safe.

Parameters:

user - assigned user

Returns:

A Connection with assigned user.

Throws:

IOException

getAsyncConnection

public AsyncClusterConnection getAsyncConnection()
                                          throws IOException

Deprecated.

Get a shared AsyncClusterConnection to the cluster. this method is thread safe.

Returns:

An AsyncClusterConnection that can be shared. Don't close. Will be closed on shutdown of cluster.

Throws:

IOException

getAsyncConnection

public AsyncClusterConnection getAsyncConnection(User user)
                                          throws IOException

Deprecated.

Get a assigned AsyncClusterConnection to the cluster. this method is thread safe.

Parameters:

user - assigned user

Returns:

An AsyncClusterConnection with assigned user.

Throws:

IOException

closeConnection

public void closeConnection()
                     throws IOException

Deprecated.

Throws:

IOException

getAdmin

public Admin getAdmin()
               throws IOException

Deprecated.

Returns an Admin instance which is shared between HBaseTestingUtility instance users. Closing it has no effect, it will be closed automatically when the cluster shutdowns

Throws:

IOException

getHbck

public Hbck getHbck()
             throws IOException

Deprecated.

Returns an Hbck instance. Needs be closed when done.

Throws:

IOException

unassignRegion

public void unassignRegion(String regionName)
                    throws IOException

Deprecated.

Unassign the named region.

Parameters:

regionName - The region to unassign.

Throws:

IOException

unassignRegion

public void unassignRegion(byte[] regionName)
                    throws IOException

Deprecated.

Unassign the named region.

Parameters:

regionName - The region to unassign.

Throws:

IOException

unassignRegionByRow

public void unassignRegionByRow(String row,
 RegionLocator table)
                         throws IOException

Deprecated.

Closes the region containing the given row.

Parameters:

row - The row to find the containing region.

table - The table to find the region.

Throws:

IOException

unassignRegionByRow

public void unassignRegionByRow(byte[] row,
 RegionLocator table)
                         throws IOException

Deprecated.

Closes the region containing the given row.

Parameters:

row - The row to find the containing region.

table - The table to find the region.

Throws:

IOException

getSplittableRegion

public HRegion getSplittableRegion(TableName tableName,
 int maxAttempts)

Deprecated.

Retrieves a splittable region randomly from tableName

Parameters:

tableName - name of table

maxAttempts - maximum number of attempts, unlimited for value of -1

Returns:

the HRegion chosen, null if none was found within limit of maxAttempts

getDFSCluster

public org.apache.hadoop.hdfs.MiniDFSCluster getDFSCluster()

Deprecated.

setDFSCluster

public void setDFSCluster(org.apache.hadoop.hdfs.MiniDFSCluster cluster)
                   throws IllegalStateException,
IOException

Deprecated.

Throws:

IllegalStateException

IOException

setDFSCluster

public void setDFSCluster(org.apache.hadoop.hdfs.MiniDFSCluster cluster,
 boolean requireDown)
                   throws IllegalStateException,
IOException

Deprecated.

Set the MiniDFSCluster

Parameters:

cluster - cluster to use

requireDown - require the that cluster not be "up" (MiniDFSCluster#isClusterUp) before it is set.

Throws:

IllegalStateException - if the passed cluster is up when it is required to be down

IOException - if the FileSystem could not be set from the passed dfs cluster

getTestFileSystem

public org.apache.hadoop.fs.FileSystem getTestFileSystem()
                                                  throws IOException

Deprecated.

Throws:

IOException

waitTableAvailable

public void waitTableAvailable(TableName table)
                        throws InterruptedException,
IOException

Deprecated.

Wait until all regions in a table have been assigned. Waits default timeout before giving up (30 seconds).

Parameters:

table - Table to wait on.

Throws:

InterruptedException

IOException

waitTableAvailable

public void waitTableAvailable(TableName table,
 long timeoutMillis)
                        throws InterruptedException,
IOException

Deprecated.

Throws:

InterruptedException

IOException

waitTableAvailable

public void waitTableAvailable(byte[] table,
 long timeoutMillis)
                        throws InterruptedException,
IOException

Deprecated.

Wait until all regions in a table have been assigned

Parameters:

table - Table to wait on.

timeoutMillis - Timeout.

Throws:

InterruptedException

IOException

explainTableAvailability

public String explainTableAvailability(TableName tableName)
                                throws IOException

Deprecated.

Throws:

IOException

explainTableState

public String explainTableState(TableName table,
 TableState.State state)
                         throws IOException

Deprecated.

Throws:

IOException

findLastTableState

public TableState findLastTableState(TableName table)
                              throws IOException

Deprecated.

Throws:

IOException

waitTableEnabled

public void waitTableEnabled(TableName table)
                      throws InterruptedException,
IOException

Deprecated.

Waits for a table to be 'enabled'. Enabled means that table is set as 'enabled' and the regions have been all assigned. Will timeout after default period (30 seconds) Tolerates nonexistent table.

Parameters:

table - the table to wait on.

Throws:

InterruptedException - if interrupted while waiting

IOException - if an IO problem is encountered

waitTableEnabled

public void waitTableEnabled(byte[] table,
 long timeoutMillis)
                      throws InterruptedException,
IOException

Deprecated.

Waits for a table to be 'enabled'. Enabled means that table is set as 'enabled' and the regions have been all assigned.

Parameters:

table - Table to wait on.

timeoutMillis - Time to wait on it being marked enabled.

Throws:

InterruptedException

IOException

See Also:

• waitTableEnabled(TableName, long)

waitTableEnabled

public void waitTableEnabled(TableName table,
 long timeoutMillis)
                      throws IOException

Deprecated.

Throws:

IOException

waitTableDisabled

public void waitTableDisabled(byte[] table)
                       throws InterruptedException,
IOException

Deprecated.

Waits for a table to be 'disabled'. Disabled means that table is set as 'disabled' Will timeout after default period (30 seconds)

Parameters:

table - Table to wait on.

Throws:

InterruptedException

IOException

waitTableDisabled

public void waitTableDisabled(TableName table,
 long millisTimeout)
                       throws InterruptedException,
IOException

Deprecated.

Throws:

InterruptedException

IOException

waitTableDisabled

public void waitTableDisabled(byte[] table,
 long timeoutMillis)
                       throws InterruptedException,
IOException

Deprecated.

Waits for a table to be 'disabled'. Disabled means that table is set as 'disabled'

Parameters:

table - Table to wait on.

timeoutMillis - Time to wait on it being marked disabled.

Throws:

InterruptedException

IOException

ensureSomeRegionServersAvailable

public boolean ensureSomeRegionServersAvailable(int num)
                                         throws IOException

Deprecated.

Make sure that at least the specified number of region servers are running

Parameters:

num - minimum number of region servers that should be running

Returns:

true if we started some servers

Throws:

IOException

ensureSomeNonStoppedRegionServersAvailable

public boolean ensureSomeNonStoppedRegionServersAvailable(int num)
                                                   throws IOException

Deprecated.

Make sure that at least the specified number of region servers are running. We don't count the ones that are currently stopping or are stopped.

Parameters:

num - minimum number of region servers that should be running

Returns:

true if we started some servers

Throws:

IOException

getDifferentUser

public static User getDifferentUser(org.apache.hadoop.conf.Configuration c,
 String differentiatingSuffix)
                             throws IOException

Deprecated.

This method clones the passed c configuration setting a new user into the clone. Use it getting new instances of FileSystem. Only works for DistributedFileSystem w/o Kerberos.

Parameters:

c - Initial configuration

differentiatingSuffix - Suffix to differentiate this user from others.

Returns:

A new configuration instance with a different user set into it.

Throws:

IOException

getAllOnlineRegions

public static NavigableSet<String> getAllOnlineRegions(MiniHBaseCluster cluster)
                                                throws IOException

Deprecated.

Throws:

IOException

setMaxRecoveryErrorCount

public static void setMaxRecoveryErrorCount(OutputStream stream,
 int max)

Deprecated.

Set maxRecoveryErrorCount in DFSClient. In 0.20 pre-append its hard-coded to 5 and makes tests linger. Here is the exception you'll see:

 2010-06-15 11:52:28,511 WARN  [DataStreamer for file /hbase/.logs/wal.1276627923013 block
 blk_928005470262850423_1021] hdfs.DFSClient$DFSOutputStream(2657): Error Recovery for block
 blk_928005470262850423_1021 failed  because recovery from primary datanode 127.0.0.1:53683
 failed 4 times.  Pipeline was 127.0.0.1:53687, 127.0.0.1:53683. Will retry...
 

Parameters:

stream - A DFSClient.DFSOutputStream.

assignRegion

public boolean assignRegion(RegionInfo regionInfo)
                     throws IOException,
InterruptedException

Deprecated.

Uses directly the assignment manager to assign the region. and waits until the specified region has completed assignment.

Returns:

true if the region is assigned false otherwise.

Throws:

IOException

InterruptedException

moveRegionAndWait

public void moveRegionAndWait(RegionInfo destRegion,
 ServerName destServer)
                       throws InterruptedException,
IOException

Deprecated.

Move region to destination server and wait till region is completely moved and online

Parameters:

destRegion - region to move

destServer - destination server of the region

Throws:

InterruptedException

IOException

waitUntilAllRegionsAssigned

public void waitUntilAllRegionsAssigned(TableName tableName)
                                 throws IOException

Deprecated.

Wait until all regions for a table in hbase:meta have a non-empty info:server, up to a configuable timeout value (default is 60 seconds) This means all regions have been deployed, master has been informed and updated hbase:meta with the regions deployed server.

Parameters:

tableName - the table name

Throws:

IOException

waitUntilAllSystemRegionsAssigned

public void waitUntilAllSystemRegionsAssigned()
                                       throws IOException

Deprecated.

Waith until all system table's regions get assigned

Throws:

IOException

waitUntilAllRegionsAssigned

public void waitUntilAllRegionsAssigned(TableName tableName,
 long timeout)
                                 throws IOException

Deprecated.

Wait until all regions for a table in hbase:meta have a non-empty info:server, or until timeout. This means all regions have been deployed, master has been informed and updated hbase:meta with the regions deployed server.

Parameters:

tableName - the table name

timeout - timeout, in milliseconds

Throws:

IOException

getFromStoreFile

public static List<Cell> getFromStoreFile(HStore store,
 Get get)
                                   throws IOException

Deprecated.

Do a small get/scan against one store. This is required because store has no actual methods of querying itself, and relies on StoreScanner.

Throws:

IOException

getRegionSplitStartKeys

public byte[][] getRegionSplitStartKeys(byte[] startKey,
 byte[] endKey,
 int numRegions)

Deprecated.

Create region split keys between startkey and endKey

Parameters:

numRegions - the number of regions to be created. it has to be greater than 3.

Returns:

resulting split keys

getFromStoreFile

public static List<Cell> getFromStoreFile(HStore store,
 byte[] row,
 NavigableSet<byte[]> columns)
                                   throws IOException

Deprecated.

Do a small get/scan against one store. This is required because store has no actual methods of querying itself, and relies on StoreScanner.

Throws:

IOException

assertKVListsEqual

public static void assertKVListsEqual(String additionalMsg,
 List<? extends Cell> expected,
 List<? extends Cell> actual)

Deprecated.

safeGetAsStr

public static <T> String safeGetAsStr(List<T> lst,
 int i)

Deprecated.

getRpcConnnectionURI

public String getRpcConnnectionURI()
                            throws UnknownHostException

Deprecated.

Throws:

UnknownHostException

getZkConnectionURI

public String getZkConnectionURI()

Deprecated.

getClusterKey

@Deprecated
public String getClusterKey()

Deprecated.

since 2.7.0, will be removed in 4.0.0. Now we use connection uri to specify the connection info of a cluster. Keep here only for compatibility.

Get the zk based cluster key for this cluster.

See Also:

• getRpcConnnectionURI()
• getZkConnectionURI()

createRandomTable

public Table createRandomTable(TableName tableName,
 Collection<String> families,
 int maxVersions,
 int numColsPerRow,
 int numFlushes,
 int numRegions,
 int numRowsPerFlush)
                        throws IOException,
InterruptedException

Deprecated.

Creates a random table with the given parameters

Throws:

IOException

InterruptedException

randomFreePort

public static int randomFreePort()

Deprecated.

randomMultiCastAddress

public static String randomMultiCastAddress()

Deprecated.

waitForHostPort

public static void waitForHostPort(String host,
 int port)
                            throws IOException

Deprecated.

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableName tableName,
 byte[] columnFamily,
 Compression.Algorithm compression,
 DataBlockEncoding dataBlockEncoding)
                                       throws IOException

Deprecated.

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableName tableName,
 byte[] columnFamily,
 Compression.Algorithm compression,
 DataBlockEncoding dataBlockEncoding,
 int numRegionsPerServer,
 int regionReplication,
 Durability durability)
                                       throws IOException

Deprecated.

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableName tableName,
 byte[][] columnFamilies,
 Compression.Algorithm compression,
 DataBlockEncoding dataBlockEncoding,
 int numRegionsPerServer,
 int regionReplication,
 Durability durability)
                                       throws IOException

Deprecated.

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableDescriptor desc,
 ColumnFamilyDescriptor hcd)
                                       throws IOException

Deprecated.

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableDescriptor desc,
 ColumnFamilyDescriptor hcd,
 int numRegionsPerServer)
                                       throws IOException

Deprecated.

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableDescriptor desc,
 ColumnFamilyDescriptor[] hcds,
 int numRegionsPerServer)
                                       throws IOException

Deprecated.

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableDescriptor td,
 ColumnFamilyDescriptor[] cds,
 RegionSplitter.SplitAlgorithm splitter,
 int numRegionsPerServer)
                                       throws IOException

Deprecated.

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

getMetaRSPort

public static int getMetaRSPort(Connection connection)
                         throws IOException

Deprecated.

Throws:

IOException

assertRegionOnServer

public void assertRegionOnServer(RegionInfo hri,
 ServerName server,
 long timeout)
                          throws IOException,
InterruptedException

Deprecated.

Due to async racing issue, a region may not be in the online region list of a region server yet, after the assignment znode is deleted and the new assignment is recorded in master.

Throws:

IOException

InterruptedException

assertRegionOnlyOnServer

public void assertRegionOnlyOnServer(RegionInfo hri,
 ServerName server,
 long timeout)
                              throws IOException,
InterruptedException

Deprecated.

Check to make sure the region is open on the specified region server, but not on any other one.

Throws:

IOException

InterruptedException

createTestRegion

public HRegion createTestRegion(String tableName,
 ColumnFamilyDescriptor cd)
                         throws IOException

Deprecated.

Throws:

IOException

createTestRegion

public HRegion createTestRegion(String tableName,
 ColumnFamilyDescriptor cd,
 BlockCache blockCache)
                         throws IOException

Deprecated.

Throws:

IOException

setFileSystemURI

public static void setFileSystemURI(String fsURI)

Deprecated.

predicateNoRegionsInTransition

public <any> predicateNoRegionsInTransition()

Deprecated.

Returns a Predicate for checking that there are no regions in transition in master

predicateTableEnabled

public <any> predicateTableEnabled(TableName tableName)

Deprecated.

Returns a Predicate for checking that table is enabled

predicateTableDisabled

public <any> predicateTableDisabled(TableName tableName)

Deprecated.

Returns a Predicate for checking that table is enabled

predicateTableAvailable

public <any> predicateTableAvailable(TableName tableName)

Deprecated.

Returns a Predicate for checking that table is enabled

waitUntilNoRegionsInTransition

public void waitUntilNoRegionsInTransition(long timeout)
                                    throws IOException

Deprecated.

Wait until no regions in transition.

Parameters:

timeout - How long to wait.

Throws:

IOException

waitUntilNoRegionsInTransition

public void waitUntilNoRegionsInTransition()
                                    throws IOException

Deprecated.

Wait until no regions in transition. (time limit 15min)

Throws:

IOException

waitLabelAvailable

public void waitLabelAvailable(long timeoutMillis,
 String... labels)

Deprecated.

Wait until labels is ready in VisibilityLabelsCache.

generateColumnDescriptors

public static List<ColumnFamilyDescriptor> generateColumnDescriptors()

Deprecated.

Create a set of column descriptors with the combination of compression, encoding, bloom codecs available.

Returns:

the list of column descriptors

generateColumnDescriptors

public static List<ColumnFamilyDescriptor> generateColumnDescriptors(String prefix)

Deprecated.

Create a set of column descriptors with the combination of compression, encoding, bloom codecs available.

Parameters:

prefix - family names prefix

Returns:

the list of column descriptors

getSupportedCompressionAlgorithms

public static Compression.Algorithm[] getSupportedCompressionAlgorithms()

Deprecated.

Get supported compression algorithms.

Returns:

supported compression algorithms.

getClosestRowBefore

public Result getClosestRowBefore(Region r,
 byte[] row,
 byte[] family)
                           throws IOException

Deprecated.

Throws:

IOException

isTargetTable

private boolean isTargetTable(byte[] inRow,
 Cell c)

Deprecated.

setupMiniKdc

public org.apache.hadoop.minikdc.MiniKdc setupMiniKdc(File keytabFile)
                                               throws Exception

Deprecated.

Sets up MiniKdc for testing security. Uses HBaseKerberosUtils to set the given keytab file as HBaseKerberosUtils#KRB_KEYTAB_FILE. FYI, there is also the easier-to-use kerby KDC server and utility for using it, org.apache.hadoop.hbase.util.SimpleKdcServerUtil. The kerby KDC server is preferred; less baggage. It came in in HBASE-5291.

Throws:

Exception

getNumHFiles

public int getNumHFiles(TableName tableName,
 byte[] family)

Deprecated.

getNumHFilesForRS

public int getNumHFilesForRS(HRegionServer rs,
 TableName tableName,
 byte[] family)

Deprecated.

assertEquals

private void assertEquals(String message,
 int expected,
 int actual)

Deprecated.

verifyTableDescriptorIgnoreTableName

public void verifyTableDescriptorIgnoreTableName(TableDescriptor ltd,
 TableDescriptor rtd)

Deprecated.

await

public static void await(long sleepMillis,
 BooleanSupplier condition)
                  throws InterruptedException

Deprecated.

Await the successful return of condition, sleeping sleepMillis between invocations.

Throws:

InterruptedException