org.apache.hadoop.hbase.coprocessor

Class TestOpenTableInCoprocessor

java.lang.Object

org.apache.hadoop.hbase.coprocessor.TestOpenTableInCoprocessor

public class TestOpenTableInCoprocessor
extends Object

Test that a coprocessor can open a connection and write to another table, inside a hook.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestOpenTableInCoprocessor.CustomThreadPoolCoprocessor Coprocessor that creates an HTable with a pool to write to another table
static class	TestOpenTableInCoprocessor.SendToOtherTableCoprocessor Custom coprocessor that just copies the write to another table.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static boolean[]	completed
private static boolean[]	completedWithPool
private static byte[]	family
private static org.apache.hadoop.hbase.TableName	otherTable
private static org.apache.hadoop.hbase.TableName	primaryTable
private static HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
TestOpenTableInCoprocessor()

Method Summary

Modifier and Type	Method and Description
void	cleanupTestTable()
private int	getKeyValueCount(org.apache.hadoop.hbase.client.Table table) Count the number of keyvalue in the table.
private void	runCoprocessorConnectionToRemoteTable(Class clazz, boolean[] completeCheck)
static void	setupCluster()
static void	teardownCluster()
void	testCoprocessorCanCreateConnectionToRemoteTable()
void	testCoprocessorCanCreateConnectionToRemoteTableWithCustomPool()

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

otherTable

private static final org.apache.hadoop.hbase.TableName otherTable

primaryTable

private static final org.apache.hadoop.hbase.TableName primaryTable

family

private static final byte[] family

completed

private static boolean[] completed

completedWithPool

private static boolean[] completedWithPool

UTIL

private static HBaseTestingUtility UTIL

Constructor Detail

TestOpenTableInCoprocessor

public TestOpenTableInCoprocessor()

Method Detail

setupCluster

public static void setupCluster()
                         throws Exception

Throws:

Exception

cleanupTestTable

public void cleanupTestTable()
                      throws Exception

Throws:

Exception

teardownCluster

public static void teardownCluster()
                            throws Exception

Throws:

Exception

testCoprocessorCanCreateConnectionToRemoteTable

public void testCoprocessorCanCreateConnectionToRemoteTable()
                                                     throws Throwable

Throws:

Throwable

testCoprocessorCanCreateConnectionToRemoteTableWithCustomPool

public void testCoprocessorCanCreateConnectionToRemoteTableWithCustomPool()
                                                                   throws Throwable

Throws:

Throwable

runCoprocessorConnectionToRemoteTable

private void runCoprocessorConnectionToRemoteTable(Class clazz,
                                                   boolean[] completeCheck)
                                            throws Throwable

Throws:

Throwable

getKeyValueCount

private int getKeyValueCount(org.apache.hadoop.hbase.client.Table table)
                      throws IOException

Count the number of keyvalue in the table. Scans all possible versions

Parameters:

table - table to scan

Returns:

number of keyvalues over all rows in the table n

Throws:

IOException