The panko.storage.hbase.inmemory Module¶

This is a very crude version of “in-memory HBase”, which implements just enough functionality of HappyBase API to support testing of our driver.

service None

Bases: object

HappyBase.Connection mock.

MConnection.create_table(n, families=None)¶

MConnection.delete_table(name, use_prefix=True)¶

static MConnection.open()¶

MConnection.table(name)¶

service None

Bases: object

MConnectionPool.connection()¶

service None

Bases: object

HappyBase.Table mock.

static MTable.ColumnPrefixFilter(args, rows)[source]¶

This is filter for testing “in-memory HBase”.

This method is called from scan() when ‘ColumnPrefixFilter’ is found in the ‘filter’ argument.

Parameters

• args – a list of filter arguments, contain prefix of column

• rows – a dict of row prefixes for filtering

static MTable.QualifierFilter(args, rows)[source]¶

This is filter for testing “in-memory HBase”.

This method is called from scan() when ‘QualifierFilter’ is found in the ‘filter’ argument

static MTable.RowFilter(args, rows)[source]¶

This is filter for testing “in-memory HBase”.

This method is called from scan() when ‘RowFilter’ is found in the ‘filter’ argument.

Parameters

• args – a list of filter arguments, it contains operator and sought string

• rows – a dict of rows which are filtered

static MTable.SingleColumnValueFilter(args, rows)[source]¶

This is filter for testing “in-memory HBase”.

This method is called from scan() when ‘SingleColumnValueFilter’ is found in the ‘filter’ argument.

MTable.delete(key)[source]¶

MTable.put(key, data, ts=None)[source]¶

MTable.row(key, columns=None)[source]¶

MTable.rows(keys)[source]¶

MTable.scan(filter=None, columns=None, row_start=None, row_stop=None, limit=None)[source]¶