HBase

Syntax

connect(host, port, [isFramed])

Details

Build a connection to HBase via Thrift server and return an HBase handle.

Parameters

• host: A STRING scalar indicating the server address to connect to.
• port: An integer indicating the port number of the Thrift server.
• isFramed: A BOOLEAN scalar indicating the way of data transmission. If set to false (default), data is transmitted through TBufferedTransport; if set to true, data is transmitted through TFramedTransport.

Examples

conn = hbase::connect("192.168.1.114",9090)

Note: If the connection remains inactive for a while (1min by default), HBase will automatically close it. If you try to operate through this connection, the No more data to read error will be reported. In such a case, you have to execute hbase::connect to reconnect.

You can configure with hbase.thrift.server.socket.read.timeout and hbase.thrift.connection.max-idletime to change the timeout.

The following configuration parameters change the timeout to 1 day.

<property>
         <name>hbase.thrift.server.socket.read.timeout</name>
         <value>86400000</value>
         <description>eg:milisecond</description>
</property>

<property>
         <name>hbase.thrift.connection.max-idletime</name>
         <value>86400000</value>
</property>

Syntax

showTables(hbaseConnection)

Details

Return all table names of the connected database.

Parameters

• hbaseConnection: The handle returned by hbase::connect.

Examples

conn = hbase::connect("192.168.1.114", 9090)
hbase::showTables(conn)

Syntax

deleteTable(hbaseConnection, tableName)

Details

Delete the tables in the database.

Parameters

• hbaseConnection: The handle returned by hbase::connect.
• tableName: A STRING scalar/vector indicating the name of the table to be deleted.

Examples

conn = hbase::connect("192.168.1.114", 9090)
hbase::deleteTable(conn, "demo_table")

Syntax

getRow(hbaseConnection, tableName, rowKey, [columnName])

Details

Return the specific record with rowKey.

Parameters

• hbaseConnection: The handle returned by hbase::connect.
• tableName: A STRING scalar indicating the name of the table to be read.
• rowKey: A STRING scalar indicating the index of the row to be read.
• columnName: A STRING scalar/vector indicating the name of the column to be read. If not specified, all columns are read by default.

Examples

conn = hbase::connect("192.168.1.114", 9090)
hbase::getRow(conn, "test", "row1")

Syntax

load(hbaseConnection, tableName, [schema])

Details

Import the HBase results into a DolphinDB in-memory table. The data types supported for schema are described in "Data Type Mappings".

Parameters

• hbaseConnection: The handle returned by hbase::connect.
• tableName: A STRING scalar indicating the name of the table to be loaded.
• schema (optional): If specified, it is a table containing names of the columns to be imported and their data types. The column names specified in schema must be consistent with the HBase column names. If not specified, the table will be created based on the first row with each column of STRING type. Note that each row must have the same size.

Examples

conn = hbase::connect("192.168.1.114", 9090)
t =  table(["cf:a","cf:b", "cf:c", "cf:time"] as name, ["STRING", "INT", "FLOAT", "TIMESTAMP"] as type)
t1 = hbase::load(conn, "test", t)