org.apache.flink.tests.util.hbase

Class LocalStandaloneHBaseResource

java.lang.Object

org.apache.flink.tests.util.hbase.LocalStandaloneHBaseResource

All Implemented Interfaces:

HBaseResource, ExternalResource, org.junit.rules.TestRule

public class LocalStandaloneHBaseResource
extends Object
implements HBaseResource

HBaseResource that downloads hbase and set up a local hbase cluster.

Method Summary

Modifier and Type	Method and Description
void	afterTestSuccess()
void	before()
void	createTable(String tableName, String... columnFamilies) Creates a table with the given name and column families.
void	putData(String tableName, String rowKey, String columnFamily, String columnQualifier, String value) Put the given data to the given table.
List<String>	scanTable(String tableName) Scan the given HBase table.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.tests.util.hbase.HBaseResource

get

Methods inherited from interface org.apache.flink.util.ExternalResource

afterTestFailure, apply

Method Detail

before

public void before()
            throws Exception

Specified by:

before in interface ExternalResource

Throws:

Exception

afterTestSuccess

public void afterTestSuccess()

Specified by:

afterTestSuccess in interface ExternalResource

createTable

public void createTable(String tableName,
                        String... columnFamilies)
                 throws IOException

Description copied from interface: HBaseResource

Creates a table with the given name and column families.

Specified by:

createTable in interface HBaseResource

Parameters:

tableName - desired table name

columnFamilies - column family to create

Throws:

IOException

scanTable

public List<String> scanTable(String tableName)
                       throws IOException

Description copied from interface: HBaseResource

Scan the given HBase table.

Specified by:

scanTable in interface HBaseResource

Parameters:

tableName - table desired to scan

Throws:

IOException

putData

public void putData(String tableName,
                    String rowKey,
                    String columnFamily,
                    String columnQualifier,
                    String value)
             throws IOException

Description copied from interface: HBaseResource

Put the given data to the given table.

Specified by:

putData in interface HBaseResource

Parameters:

tableName - table to put data

rowKey - row key of the given data

columnFamily - column family of the given data

columnQualifier - column qualifier of the given data

value - value of the given data

Throws:

IOException