PHP から Thrift で HBase に値を格納する

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

• テーブルの作成
• サンプルコード
• 結果
• あわせて読む

テーブルの作成

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 ();

		$table = 't1';
		$mutations = array ();
		$family = 'f1';
		for ($i = 0; $i < 10; $i++)
		{
			$mutations[] = new Mutation (
				array (
					'column' => "$family:$i",
					'value' => "$i" )
			);
		}

		$row = 'row1';
		$client->mutateRow ($table, $row, $mutations);

		$row = 'row2';
		$client->mutateRow ($table, $row, $mutations);

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

hbase_test ();

結果

$ ./bin/hbase shell
hbase(main):006:0> scan 't1'
ROW                                                           COLUMN+CELL
 row1                                                         column=f1:0, timestamp=1336841239583, value=0
 row1                                                         column=f1:1, timestamp=1336841239583, value=1
 row1                                                         column=f1:2, timestamp=1336841239583, value=2
 row1                                                         column=f1:3, timestamp=1336841239583, value=3
 row1                                                         column=f1:4, timestamp=1336841239583, value=4
 row1                                                         column=f1:5, timestamp=1336841239583, value=5
 row1                                                         column=f1:6, timestamp=1336841239583, value=6
 row1                                                         column=f1:7, timestamp=1336841239583, value=7
 row1                                                         column=f1:8, timestamp=1336841239583, value=8
 row1                                                         column=f1:9, timestamp=1336841239583, value=9
 row2                                                         column=f1:0, timestamp=1336841781384, value=0
 row2                                                         column=f1:1, timestamp=1336841781384, value=1
 row2                                                         column=f1:2, timestamp=1336841781384, value=2
 row2                                                         column=f1:3, timestamp=1336841781384, value=3
 row2                                                         column=f1:4, timestamp=1336841781384, value=4
 row2                                                         column=f1:5, timestamp=1336841781384, value=5
 row2                                                         column=f1:6, timestamp=1336841781384, value=6
 row2                                                         column=f1:7, timestamp=1336841781384, value=7
 row2                                                         column=f1:8, timestamp=1336841781384, value=8
 row2                                                         column=f1:9, timestamp=1336841781384, value=9
2 row(s) in 0.3270 seconds

hbase(main):007:0>

あわせて読む

• [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 から行を取得する