PHP から Thrift で HBase のテーブルを取得する

このドキュメントの内容は、以下の通りです。

• thrift によるソースコード生成
• HBase の起動
• テーブルの作成
• サンプルコード
• あわせて読む

thrift によるソースコード生成

thrift --gen php ~/dev/hbase-0.92.1/src/main/resources/org/apache/hadoop/hbase/thrift/Hbase.thrift

薫 $ find gen-php
gen-php
gen-php/Hbase
gen-php/Hbase/Hbase_types.php
gen-php/Hbase/Hbase.php

include_once $GLOBALS['THRIFT_ROOT'].'/packages/Hbase/Hbase_types.php';

cp -r /usr/ports/devel/thrift/work/thrift-0.8.0/lib/php/src .

HBase の起動

./bin/start-hbase.sh
./bin/hbase start thrift

薫 $ jps
66321 Jps
65103 HMaster
65048 ThriftServer

テーブルの作成

create 't1', 'f1'

サンプルコード

<?php

$GLOBALS['THRIFT_ROOT'] = 'src/';
include 'gen-php/Hbase/Hbase_types.php';
include 'gen-php/Hbase/Hbase.php';

include 'src/transport/TSocket.php';
include 'src/transport/TBufferedTransport.php';
include 'src/protocol/TBinaryProtocol.php';

function hbase_test ()
{
	$server = 'localhost';
	$port = 9090;
	try {
		$socket = new TSocket ($server, $port);

		$transport = new TBufferedTransport ($socket);

		$protocol = new TBinaryProtocol ($transport);
		$client = new HbaseClient ($protocol);

		$transport->open ();

		$tables = $client->getTableNames ();
		var_dump ($tables);

	} catch (TException $e) {
		error_log ('TException');
		error_log ($e);
	} catch (Exception $e) {
		error_log ('Exception');
		error_log ($e);
	}
}

hbase_test ();

あわせて読む

• [2012-03-30-1] Thrift とは
• [2012-03-31-1] FreeBSD thrift をインストールする
• [2012-04-01-1] FreeBSD php5-thrift をインストールする
• [2012-04-02-1] PHP から Thrift で HBase のテーブルを取得する
• [2012-04-03-1] PHP から Thrift で HBase に値を格納する
• [2012-04-04-1] PHP から Thrift で HBase から行を取得する