Package org.apache.hadoop.hbase.coprocessor

Class TestOpenTableInCoprocessor

java.lang.Object

org.apache.hadoop.hbase.coprocessor.TestOpenTableInCoprocessor

@Tag("org.apache.hadoop.hbase.testclassification.CoprocessorTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
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	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	Description
private static boolean[]	completed
private static boolean[]	completedWithPool
private static final byte[]	family
private static final org.apache.hadoop.hbase.TableName	otherTable
private static final org.apache.hadoop.hbase.TableName	primaryTable
private static HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestOpenTableInCoprocessor()

Method Summary

Modifier and Type	Method	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 Details

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 HBaseTestingUtil UTIL

Constructor Details

TestOpenTableInCoprocessor

public TestOpenTableInCoprocessor()

Method Details

setupCluster

@BeforeAll
public static void setupCluster()
                         throws Exception

Throws:

Exception

cleanupTestTable

@AfterEach
public void cleanupTestTable()
                      throws Exception

Throws:

Exception

teardownCluster

@AfterAll
public static void teardownCluster()
                            throws Exception

Throws:

Exception

testCoprocessorCanCreateConnectionToRemoteTable

@Test
public void testCoprocessorCanCreateConnectionToRemoteTable()
                                                     throws Throwable

Throws:

Throwable

testCoprocessorCanCreateConnectionToRemoteTableWithCustomPool

@Test
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

Throws:

IOException