org.apache.hadoop.hbase.coprocessor

Class TestOpenTableInCoprocessor

java.lang.Object

org.apache.hadoop.hbase.coprocessor.TestOpenTableInCoprocessor

public class TestOpenTableInCoprocessor
extends java.lang.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.

Constructor Summary

Constructors

Constructor and Description
TestOpenTableInCoprocessor()

Method Summary

Modifier and Type	Method and Description
void	cleanupTestTable()
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

Constructor Detail

TestOpenTableInCoprocessor

public TestOpenTableInCoprocessor()

Method Detail

setupCluster

public static void setupCluster()
                         throws java.lang.Exception

Throws:

java.lang.Exception

cleanupTestTable

public void cleanupTestTable()
                      throws java.lang.Exception

Throws:

java.lang.Exception

teardownCluster

public static void teardownCluster()
                            throws java.lang.Exception

Throws:

java.lang.Exception

testCoprocessorCanCreateConnectionToRemoteTable

public void testCoprocessorCanCreateConnectionToRemoteTable()
                                                     throws java.lang.Throwable

Throws:

java.lang.Throwable

testCoprocessorCanCreateConnectionToRemoteTableWithCustomPool

public void testCoprocessorCanCreateConnectionToRemoteTableWithCustomPool()
                                                                   throws java.lang.Throwable

Throws:

java.lang.Throwable