hbase-0.92.2にphp経由でアクセスするスクリプト

hbase-thrift-test.php

<?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 = '192.168.222.211'; // リモートでも接続出来ます。
  $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 ();