Logo Search packages:      
Sourcecode: hbase version File versions  Download package

org::apache::hadoop::hbase::client::TestOldAPIHTable Class Reference

Inheritance diagram for org::apache::hadoop::hbase::client::TestOldAPIHTable:

org::apache::hadoop::hbase::HBaseClusterTestCase org::apache::hadoop::hbase::HConstants org::apache::hadoop::hbase::HBaseTestCase

List of all members.


Detailed Description

Tests HTable

Definition at line 39 of file TestOldAPIHTable.java.


Public Types

enum  Modify {
  CLOSE_REGION, TABLE_COMPACT, TABLE_FLUSH, TABLE_MAJOR_COMPACT,
  TABLE_SET_HTD, TABLE_SPLIT
}

Public Member Functions

void testGetClosestRowBefore () throws IOException
void testGetRow ()
void testHTable () throws IOException
void testTableNotFoundExceptionWithATable ()
void testTableNotFoundExceptionWithoutAnyTables ()
void threadDumpingJoin ()

Public Attributes

MiniHBaseCluster cluster
volatile HBaseConfiguration conf

Static Public Attributes

static final int ALL_VERSIONS = Integer.MAX_VALUE
static final byte[] CATALOG_FAMILY = Bytes.toBytes(CATALOG_FAMILY_STR)
static final String CATALOG_FAMILY_STR = "info"
static final byte[] CATALOG_HISTORIAN_FAMILY = Bytes.toBytes("historian")
static final String CLUSTER_DISTRIBUTED = "hbase.cluster.distributed"
static final String CLUSTER_IS_DISTRIBUTED = "true"
static final String CLUSTER_IS_LOCAL = "false"
static long DEFAULT_HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE = Long.MAX_VALUE
static final String DEFAULT_HOST = "0.0.0.0"
static final int DEFAULT_MASTER_INFOPORT = 60010
static final int DEFAULT_MASTER_PORT = 60000
static final long DEFAULT_MAX_FILE_SIZE = 256 * 1024 * 1024
static final String DEFAULT_REGION_SERVER_CLASS = HRegionInterface.class.getName()
static final int DEFAULT_REGIONSERVER_INFOPORT = 60030
static final int DEFAULT_REGIONSERVER_PORT = 60020
static final int DEFAULT_SIZE_RESERVATION_BLOCK = 1024 * 1024 * 5
static final int DEFAULT_ZOOKEEPER_PAUSE = 2 * 1000
static final int DEFAULT_ZOOKEEPER_RETRIES = 5
static final byte[] EMPTY_BYTE_ARRAY = new byte [0]
static final byte[] EMPTY_END_ROW = EMPTY_START_ROW
static final byte[] EMPTY_START_ROW = EMPTY_BYTE_ARRAY
static final String FILE_SYSTEM_VERSION = "7"
static final int FOREVER = Integer.MAX_VALUE
static final String HBASE_CLIENT_RETRIES_NUMBER_KEY
static String HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE_KEY = "hbase.client.scanner.max.result.size"
static final String HBASE_DIR = "hbase.rootdir"
static final String HREGION_COMPACTIONDIR_NAME = "compaction.dir"
static final String HREGION_LOGDIR_NAME = ".logs"
static final String HREGION_OLDLOGFILE_NAME = "oldlogfile.log"
static final String IN_MEMORY = "IN_MEMORY"
static final byte[] LAST_ROW = EMPTY_BYTE_ARRAY
static final long LATEST_TIMESTAMP = Long.MAX_VALUE
static final byte[] LATEST_TIMESTAMP_BYTES = Bytes.toBytes(LATEST_TIMESTAMP)
static final String MAJOR_COMPACTION_PERIOD = "hbase.hregion.majorcompaction"
static final String MASTER_PORT = "hbase.master.port"
static final int MAX_ROW_LENGTH = Short.MAX_VALUE
static final int MAXIMUM_VALUE_LENGTH = Integer.MAX_VALUE
static final int META_ROW_DELIMITER = ','
static final byte[] META_TABLE_NAME = Bytes.toBytes(".META.")
static final String NAME = "NAME"
static final String NINES = "99999999999999"
static final String REGION_IMPL = "hbase.hregion.impl"
static final String REGION_SERVER_CLASS = "hbase.regionserver.class"
static final String REGION_SERVER_IMPL = "hbase.regionserver.impl"
static final byte[] REGIONINFO_QUALIFIER = Bytes.toBytes("regioninfo")
static final String REGIONSERVER_PORT = "hbase.regionserver.port"
static int RETRY_BACKOFF [] = { 1, 1, 1, 2, 2, 4, 4, 8, 16, 32 }
static final byte[] ROOT_TABLE_NAME = Bytes.toBytes("-ROOT-")
static final byte[] SERVER_QUALIFIER = Bytes.toBytes("server")
static final byte[] SPLITA_QUALIFIER = Bytes.toBytes("splitA")
static final byte[] SPLITB_QUALIFIER = Bytes.toBytes("splitB")
static final byte[] STARTCODE_QUALIFIER = Bytes.toBytes("serverstartcode")
static final String TEST_DIRECTORY_KEY = "test.build.data"
static final String THREAD_WAKE_FREQUENCY = "hbase.server.thread.wakefrequency"
static final String UTF8_ENCODING = "UTF-8"
static final String VERSION_FILE_NAME = "hbase.version"
static final String VERSIONS = "VERSIONS"
static final int WEEK_IN_SECONDS = 7 * 24 * 3600
static final String ZEROES = "00000000000000"
static final String ZOOKEEPER_CONFIG_NAME = "zoo.cfg"
static final String ZOOKEEPER_PAUSE = "zookeeper.pause"
static final String ZOOKEEPER_QUORUM = "hbase.zookeeper.quorum"
static final String ZOOKEEPER_RETRIES = "zookeeper.retries"

Protected Member Functions

HRegion createNewHRegion (HTableDescriptor desc, byte[] startKey, byte[] endKey) throws IOException
HTableDescriptor createTableDescriptor (final String name, final int versions)
HTableDescriptor createTableDescriptor (final String name)
Path getUnitTestdir (String testName)
void hBaseClusterSetup () throws Exception
HRegion openClosedRegion (final HRegion closedRegion) throws IOException
void postHBaseClusterSetup () throws Exception
void preHBaseClusterSetup () throws Exception
void setOpenMetaTable (boolean val)
void setUp () throws Exception
void tearDown () throws Exception
void threadDumpingJoin (final Thread t)

Static Protected Member Functions

static long addContent (final Incommon updater, final String columnFamily, final String column, final byte[] startKeyBytes, final byte[] endKey, final long ts) throws IOException
static long addContent (final Incommon updater, final String family, final String column, final byte[] startKeyBytes, final byte[] endKey) throws IOException
static long addContent (final Incommon updater, final String columnFamily, final byte[] startKeyBytes, final byte[] endKey) throws IOException
static long addContent (final Incommon updater, final String family, final String column) throws IOException
static long addContent (final Incommon updater, final String columnFamily) throws IOException
static long addContent (final HRegion r, final byte[] columnFamily) throws IOException

Protected Attributes

MiniDFSCluster dfsCluster
FileSystem fs = null
HRegion meta = null
int regionServers
HRegion root = null
String START_KEY
boolean startDfs
Path testDir = null
MiniZooKeeperCluster zooKeeperCluster

Static Protected Attributes

static final byte[][] COLUMNS = {fam1, fam2, fam3}
static final byte[] fam1 = Bytes.toBytes("colfamily1")
static final byte[] fam2 = Bytes.toBytes("colfamily2")
static final byte[] fam3 = Bytes.toBytes("colfamily3")
static final char FIRST_CHAR = 'a'
static final char LAST_CHAR = 'z'
static final int MAXVERSIONS = 3
static final String PUNCTUATION = "~`@#$%^&*()-_+=:;',.<>/?[]{}|"
static final byte[] START_KEY_BYTES = {FIRST_CHAR, FIRST_CHAR, FIRST_CHAR}

Static Package Functions

 [static initializer]

Static Package Attributes

static final Long ZERO_L = Long.valueOf(0L)

Static Private Attributes

static final byte[] attrName = Bytes.toBytes("TESTATTR")
static final byte[] attrValue = Bytes.toBytes("somevalue")
static final HColumnDescriptor column
static final byte[] COLUMN_FAMILY = Bytes.toBytes(COLUMN_FAMILY_STR)
static final byte[][] COLUMN_FAMILY_ARRAY = {COLUMN_FAMILY}
static final String COLUMN_FAMILY_STR = "contents:"
static final byte[] nosuchTable = Bytes.toBytes("nosuchTable")
static final byte[] row = Bytes.toBytes("row")
static final byte[] tableAname = Bytes.toBytes("tableA")
static final byte[] tableBname = Bytes.toBytes("tableB")

The documentation for this class was generated from the following file:

Generated by  Doxygen 1.6.0   Back to index