org.apache.flink.tests.util.hbase

Interface HBaseResource

All Superinterfaces:

ExternalResource, org.junit.rules.TestRule

All Known Implementing Classes:

LocalStandaloneHBaseResource

public interface HBaseResource
extends ExternalResource

Generic interface for interacting with HBase.

Method Summary

Modifier and Type	Method and Description
void	createTable(String tableName, String... columnFamilies) Creates a table with the given name and column families.
static HBaseResource	get(String version) Returns the configured HBaseResource implementation, or a LocalStandaloneHBaseResource if none is configured.
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 interface org.apache.flink.util.ExternalResource

afterTestFailure, afterTestSuccess, apply, before

Method Detail

createTable

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

Creates a table with the given name and column families.

Parameters:

tableName - desired table name

columnFamilies - column family to create

Throws:

IOException

scanTable

List<String> scanTable(String tableName)
                throws IOException

Scan the given HBase table.

Parameters:

tableName - table desired to scan

Throws:

IOException

putData

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

Put the given data to the given table.

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

get

static HBaseResource get(String version)

Returns the configured HBaseResource implementation, or a LocalStandaloneHBaseResource if none is configured.

Parameters:

version - The hbase version

Returns:

configured HbaseResource, or LocalStandaloneHBaseResource if none is configured