You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2012/11/06 22:22:30 UTC
svn commit: r1406339 [12/17] - in /hbase/trunk: ./ examples/ hbase-examples/
hbase-examples/src/ hbase-examples/src/main/ hbase-examples/src/main/cpp/
hbase-examples/src/main/cpp/gen-cpp/ hbase-examples/src/main/java/
hbase-examples/src/main/java/org/ ...
Added: hbase/trunk/hbase-examples/src/main/php/gen-php/Hbase/Hbase.php
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-examples/src/main/php/gen-php/Hbase/Hbase.php?rev=1406339&view=auto
==============================================================================
--- hbase/trunk/hbase-examples/src/main/php/gen-php/Hbase/Hbase.php (added)
+++ hbase/trunk/hbase-examples/src/main/php/gen-php/Hbase/Hbase.php Tue Nov 6 21:22:27 2012
@@ -0,0 +1,13076 @@
+<?php
+namespace Hbase;
+/**
+ * Autogenerated by Thrift Compiler (0.9.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+use Thrift\Base\TBase;
+use Thrift\Type\TType;
+use Thrift\Type\TMessageType;
+use Thrift\Exception\TException;
+use Thrift\Exception\TProtocolException;
+use Thrift\Protocol\TProtocol;
+use Thrift\Exception\TApplicationException;
+
+
+interface HbaseIf {
+ public function enableTable($tableName);
+ public function disableTable($tableName);
+ public function isTableEnabled($tableName);
+ public function compact($tableNameOrRegionName);
+ public function majorCompact($tableNameOrRegionName);
+ public function getTableNames();
+ public function getColumnDescriptors($tableName);
+ public function getTableRegions($tableName);
+ public function createTable($tableName, $columnFamilies);
+ public function deleteTable($tableName);
+ public function get($tableName, $row, $column, $attributes);
+ public function getVer($tableName, $row, $column, $numVersions, $attributes);
+ public function getVerTs($tableName, $row, $column, $timestamp, $numVersions, $attributes);
+ public function getRow($tableName, $row, $attributes);
+ public function getRowWithColumns($tableName, $row, $columns, $attributes);
+ public function getRowTs($tableName, $row, $timestamp, $attributes);
+ public function getRowWithColumnsTs($tableName, $row, $columns, $timestamp, $attributes);
+ public function getRows($tableName, $rows, $attributes);
+ public function getRowsWithColumns($tableName, $rows, $columns, $attributes);
+ public function getRowsTs($tableName, $rows, $timestamp, $attributes);
+ public function getRowsWithColumnsTs($tableName, $rows, $columns, $timestamp, $attributes);
+ public function mutateRow($tableName, $row, $mutations, $attributes);
+ public function mutateRowTs($tableName, $row, $mutations, $timestamp, $attributes);
+ public function mutateRows($tableName, $rowBatches, $attributes);
+ public function mutateRowsTs($tableName, $rowBatches, $timestamp, $attributes);
+ public function atomicIncrement($tableName, $row, $column, $value);
+ public function deleteAll($tableName, $row, $column, $attributes);
+ public function deleteAllTs($tableName, $row, $column, $timestamp, $attributes);
+ public function deleteAllRow($tableName, $row, $attributes);
+ public function increment(\Hbase\TIncrement $increment);
+ public function incrementRows($increments);
+ public function deleteAllRowTs($tableName, $row, $timestamp, $attributes);
+ public function scannerOpenWithScan($tableName, \Hbase\TScan $scan, $attributes);
+ public function scannerOpen($tableName, $startRow, $columns, $attributes);
+ public function scannerOpenWithStop($tableName, $startRow, $stopRow, $columns, $attributes);
+ public function scannerOpenWithPrefix($tableName, $startAndPrefix, $columns, $attributes);
+ public function scannerOpenTs($tableName, $startRow, $columns, $timestamp, $attributes);
+ public function scannerOpenWithStopTs($tableName, $startRow, $stopRow, $columns, $timestamp, $attributes);
+ public function scannerGet($id);
+ public function scannerGetList($id, $nbRows);
+ public function scannerClose($id);
+ public function getRowOrBefore($tableName, $row, $family);
+ public function getRegionInfo($row);
+}
+
+class HbaseClient implements \Hbase\HbaseIf {
+ protected $input_ = null;
+ protected $output_ = null;
+
+ protected $seqid_ = 0;
+
+ public function __construct($input, $output=null) {
+ $this->input_ = $input;
+ $this->output_ = $output ? $output : $input;
+ }
+
+ public function enableTable($tableName)
+ {
+ $this->send_enableTable($tableName);
+ $this->recv_enableTable();
+ }
+
+ public function send_enableTable($tableName)
+ {
+ $args = new \Hbase\Hbase_enableTable_args();
+ $args->tableName = $tableName;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'enableTable', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('enableTable', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_enableTable()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_enableTable_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_enableTable_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ return;
+ }
+
+ public function disableTable($tableName)
+ {
+ $this->send_disableTable($tableName);
+ $this->recv_disableTable();
+ }
+
+ public function send_disableTable($tableName)
+ {
+ $args = new \Hbase\Hbase_disableTable_args();
+ $args->tableName = $tableName;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'disableTable', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('disableTable', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_disableTable()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_disableTable_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_disableTable_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ return;
+ }
+
+ public function isTableEnabled($tableName)
+ {
+ $this->send_isTableEnabled($tableName);
+ return $this->recv_isTableEnabled();
+ }
+
+ public function send_isTableEnabled($tableName)
+ {
+ $args = new \Hbase\Hbase_isTableEnabled_args();
+ $args->tableName = $tableName;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'isTableEnabled', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('isTableEnabled', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_isTableEnabled()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_isTableEnabled_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_isTableEnabled_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("isTableEnabled failed: unknown result");
+ }
+
+ public function compact($tableNameOrRegionName)
+ {
+ $this->send_compact($tableNameOrRegionName);
+ $this->recv_compact();
+ }
+
+ public function send_compact($tableNameOrRegionName)
+ {
+ $args = new \Hbase\Hbase_compact_args();
+ $args->tableNameOrRegionName = $tableNameOrRegionName;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'compact', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('compact', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_compact()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_compact_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_compact_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ return;
+ }
+
+ public function majorCompact($tableNameOrRegionName)
+ {
+ $this->send_majorCompact($tableNameOrRegionName);
+ $this->recv_majorCompact();
+ }
+
+ public function send_majorCompact($tableNameOrRegionName)
+ {
+ $args = new \Hbase\Hbase_majorCompact_args();
+ $args->tableNameOrRegionName = $tableNameOrRegionName;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'majorCompact', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('majorCompact', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_majorCompact()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_majorCompact_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_majorCompact_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ return;
+ }
+
+ public function getTableNames()
+ {
+ $this->send_getTableNames();
+ return $this->recv_getTableNames();
+ }
+
+ public function send_getTableNames()
+ {
+ $args = new \Hbase\Hbase_getTableNames_args();
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getTableNames', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getTableNames', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getTableNames()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getTableNames_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getTableNames_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getTableNames failed: unknown result");
+ }
+
+ public function getColumnDescriptors($tableName)
+ {
+ $this->send_getColumnDescriptors($tableName);
+ return $this->recv_getColumnDescriptors();
+ }
+
+ public function send_getColumnDescriptors($tableName)
+ {
+ $args = new \Hbase\Hbase_getColumnDescriptors_args();
+ $args->tableName = $tableName;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getColumnDescriptors', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getColumnDescriptors', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getColumnDescriptors()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getColumnDescriptors_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getColumnDescriptors_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getColumnDescriptors failed: unknown result");
+ }
+
+ public function getTableRegions($tableName)
+ {
+ $this->send_getTableRegions($tableName);
+ return $this->recv_getTableRegions();
+ }
+
+ public function send_getTableRegions($tableName)
+ {
+ $args = new \Hbase\Hbase_getTableRegions_args();
+ $args->tableName = $tableName;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getTableRegions', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getTableRegions', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getTableRegions()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getTableRegions_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getTableRegions_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getTableRegions failed: unknown result");
+ }
+
+ public function createTable($tableName, $columnFamilies)
+ {
+ $this->send_createTable($tableName, $columnFamilies);
+ $this->recv_createTable();
+ }
+
+ public function send_createTable($tableName, $columnFamilies)
+ {
+ $args = new \Hbase\Hbase_createTable_args();
+ $args->tableName = $tableName;
+ $args->columnFamilies = $columnFamilies;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'createTable', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('createTable', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_createTable()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_createTable_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_createTable_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ if ($result->ia !== null) {
+ throw $result->ia;
+ }
+ if ($result->exist !== null) {
+ throw $result->exist;
+ }
+ return;
+ }
+
+ public function deleteTable($tableName)
+ {
+ $this->send_deleteTable($tableName);
+ $this->recv_deleteTable();
+ }
+
+ public function send_deleteTable($tableName)
+ {
+ $args = new \Hbase\Hbase_deleteTable_args();
+ $args->tableName = $tableName;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'deleteTable', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('deleteTable', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_deleteTable()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_deleteTable_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_deleteTable_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ return;
+ }
+
+ public function get($tableName, $row, $column, $attributes)
+ {
+ $this->send_get($tableName, $row, $column, $attributes);
+ return $this->recv_get();
+ }
+
+ public function send_get($tableName, $row, $column, $attributes)
+ {
+ $args = new \Hbase\Hbase_get_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->column = $column;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'get', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('get', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_get()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_get_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_get_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("get failed: unknown result");
+ }
+
+ public function getVer($tableName, $row, $column, $numVersions, $attributes)
+ {
+ $this->send_getVer($tableName, $row, $column, $numVersions, $attributes);
+ return $this->recv_getVer();
+ }
+
+ public function send_getVer($tableName, $row, $column, $numVersions, $attributes)
+ {
+ $args = new \Hbase\Hbase_getVer_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->column = $column;
+ $args->numVersions = $numVersions;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getVer', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getVer', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getVer()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getVer_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getVer_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getVer failed: unknown result");
+ }
+
+ public function getVerTs($tableName, $row, $column, $timestamp, $numVersions, $attributes)
+ {
+ $this->send_getVerTs($tableName, $row, $column, $timestamp, $numVersions, $attributes);
+ return $this->recv_getVerTs();
+ }
+
+ public function send_getVerTs($tableName, $row, $column, $timestamp, $numVersions, $attributes)
+ {
+ $args = new \Hbase\Hbase_getVerTs_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->column = $column;
+ $args->timestamp = $timestamp;
+ $args->numVersions = $numVersions;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getVerTs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getVerTs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getVerTs()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getVerTs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getVerTs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getVerTs failed: unknown result");
+ }
+
+ public function getRow($tableName, $row, $attributes)
+ {
+ $this->send_getRow($tableName, $row, $attributes);
+ return $this->recv_getRow();
+ }
+
+ public function send_getRow($tableName, $row, $attributes)
+ {
+ $args = new \Hbase\Hbase_getRow_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getRow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getRow', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getRow()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getRow_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getRow_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getRow failed: unknown result");
+ }
+
+ public function getRowWithColumns($tableName, $row, $columns, $attributes)
+ {
+ $this->send_getRowWithColumns($tableName, $row, $columns, $attributes);
+ return $this->recv_getRowWithColumns();
+ }
+
+ public function send_getRowWithColumns($tableName, $row, $columns, $attributes)
+ {
+ $args = new \Hbase\Hbase_getRowWithColumns_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->columns = $columns;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getRowWithColumns', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getRowWithColumns', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getRowWithColumns()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getRowWithColumns_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getRowWithColumns_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getRowWithColumns failed: unknown result");
+ }
+
+ public function getRowTs($tableName, $row, $timestamp, $attributes)
+ {
+ $this->send_getRowTs($tableName, $row, $timestamp, $attributes);
+ return $this->recv_getRowTs();
+ }
+
+ public function send_getRowTs($tableName, $row, $timestamp, $attributes)
+ {
+ $args = new \Hbase\Hbase_getRowTs_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->timestamp = $timestamp;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getRowTs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getRowTs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getRowTs()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getRowTs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getRowTs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getRowTs failed: unknown result");
+ }
+
+ public function getRowWithColumnsTs($tableName, $row, $columns, $timestamp, $attributes)
+ {
+ $this->send_getRowWithColumnsTs($tableName, $row, $columns, $timestamp, $attributes);
+ return $this->recv_getRowWithColumnsTs();
+ }
+
+ public function send_getRowWithColumnsTs($tableName, $row, $columns, $timestamp, $attributes)
+ {
+ $args = new \Hbase\Hbase_getRowWithColumnsTs_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->columns = $columns;
+ $args->timestamp = $timestamp;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getRowWithColumnsTs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getRowWithColumnsTs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getRowWithColumnsTs()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getRowWithColumnsTs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getRowWithColumnsTs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getRowWithColumnsTs failed: unknown result");
+ }
+
+ public function getRows($tableName, $rows, $attributes)
+ {
+ $this->send_getRows($tableName, $rows, $attributes);
+ return $this->recv_getRows();
+ }
+
+ public function send_getRows($tableName, $rows, $attributes)
+ {
+ $args = new \Hbase\Hbase_getRows_args();
+ $args->tableName = $tableName;
+ $args->rows = $rows;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getRows', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getRows', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getRows()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getRows_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getRows_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getRows failed: unknown result");
+ }
+
+ public function getRowsWithColumns($tableName, $rows, $columns, $attributes)
+ {
+ $this->send_getRowsWithColumns($tableName, $rows, $columns, $attributes);
+ return $this->recv_getRowsWithColumns();
+ }
+
+ public function send_getRowsWithColumns($tableName, $rows, $columns, $attributes)
+ {
+ $args = new \Hbase\Hbase_getRowsWithColumns_args();
+ $args->tableName = $tableName;
+ $args->rows = $rows;
+ $args->columns = $columns;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getRowsWithColumns', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getRowsWithColumns', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getRowsWithColumns()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getRowsWithColumns_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getRowsWithColumns_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getRowsWithColumns failed: unknown result");
+ }
+
+ public function getRowsTs($tableName, $rows, $timestamp, $attributes)
+ {
+ $this->send_getRowsTs($tableName, $rows, $timestamp, $attributes);
+ return $this->recv_getRowsTs();
+ }
+
+ public function send_getRowsTs($tableName, $rows, $timestamp, $attributes)
+ {
+ $args = new \Hbase\Hbase_getRowsTs_args();
+ $args->tableName = $tableName;
+ $args->rows = $rows;
+ $args->timestamp = $timestamp;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getRowsTs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getRowsTs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getRowsTs()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getRowsTs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getRowsTs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getRowsTs failed: unknown result");
+ }
+
+ public function getRowsWithColumnsTs($tableName, $rows, $columns, $timestamp, $attributes)
+ {
+ $this->send_getRowsWithColumnsTs($tableName, $rows, $columns, $timestamp, $attributes);
+ return $this->recv_getRowsWithColumnsTs();
+ }
+
+ public function send_getRowsWithColumnsTs($tableName, $rows, $columns, $timestamp, $attributes)
+ {
+ $args = new \Hbase\Hbase_getRowsWithColumnsTs_args();
+ $args->tableName = $tableName;
+ $args->rows = $rows;
+ $args->columns = $columns;
+ $args->timestamp = $timestamp;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getRowsWithColumnsTs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getRowsWithColumnsTs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getRowsWithColumnsTs()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getRowsWithColumnsTs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getRowsWithColumnsTs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getRowsWithColumnsTs failed: unknown result");
+ }
+
+ public function mutateRow($tableName, $row, $mutations, $attributes)
+ {
+ $this->send_mutateRow($tableName, $row, $mutations, $attributes);
+ $this->recv_mutateRow();
+ }
+
+ public function send_mutateRow($tableName, $row, $mutations, $attributes)
+ {
+ $args = new \Hbase\Hbase_mutateRow_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->mutations = $mutations;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'mutateRow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('mutateRow', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_mutateRow()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_mutateRow_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_mutateRow_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ if ($result->ia !== null) {
+ throw $result->ia;
+ }
+ return;
+ }
+
+ public function mutateRowTs($tableName, $row, $mutations, $timestamp, $attributes)
+ {
+ $this->send_mutateRowTs($tableName, $row, $mutations, $timestamp, $attributes);
+ $this->recv_mutateRowTs();
+ }
+
+ public function send_mutateRowTs($tableName, $row, $mutations, $timestamp, $attributes)
+ {
+ $args = new \Hbase\Hbase_mutateRowTs_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->mutations = $mutations;
+ $args->timestamp = $timestamp;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'mutateRowTs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('mutateRowTs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_mutateRowTs()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_mutateRowTs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_mutateRowTs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ if ($result->ia !== null) {
+ throw $result->ia;
+ }
+ return;
+ }
+
+ public function mutateRows($tableName, $rowBatches, $attributes)
+ {
+ $this->send_mutateRows($tableName, $rowBatches, $attributes);
+ $this->recv_mutateRows();
+ }
+
+ public function send_mutateRows($tableName, $rowBatches, $attributes)
+ {
+ $args = new \Hbase\Hbase_mutateRows_args();
+ $args->tableName = $tableName;
+ $args->rowBatches = $rowBatches;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'mutateRows', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('mutateRows', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_mutateRows()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_mutateRows_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_mutateRows_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ if ($result->ia !== null) {
+ throw $result->ia;
+ }
+ return;
+ }
+
+ public function mutateRowsTs($tableName, $rowBatches, $timestamp, $attributes)
+ {
+ $this->send_mutateRowsTs($tableName, $rowBatches, $timestamp, $attributes);
+ $this->recv_mutateRowsTs();
+ }
+
+ public function send_mutateRowsTs($tableName, $rowBatches, $timestamp, $attributes)
+ {
+ $args = new \Hbase\Hbase_mutateRowsTs_args();
+ $args->tableName = $tableName;
+ $args->rowBatches = $rowBatches;
+ $args->timestamp = $timestamp;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'mutateRowsTs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('mutateRowsTs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_mutateRowsTs()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_mutateRowsTs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_mutateRowsTs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ if ($result->ia !== null) {
+ throw $result->ia;
+ }
+ return;
+ }
+
+ public function atomicIncrement($tableName, $row, $column, $value)
+ {
+ $this->send_atomicIncrement($tableName, $row, $column, $value);
+ return $this->recv_atomicIncrement();
+ }
+
+ public function send_atomicIncrement($tableName, $row, $column, $value)
+ {
+ $args = new \Hbase\Hbase_atomicIncrement_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->column = $column;
+ $args->value = $value;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'atomicIncrement', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('atomicIncrement', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_atomicIncrement()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_atomicIncrement_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_atomicIncrement_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ if ($result->ia !== null) {
+ throw $result->ia;
+ }
+ throw new \Exception("atomicIncrement failed: unknown result");
+ }
+
+ public function deleteAll($tableName, $row, $column, $attributes)
+ {
+ $this->send_deleteAll($tableName, $row, $column, $attributes);
+ $this->recv_deleteAll();
+ }
+
+ public function send_deleteAll($tableName, $row, $column, $attributes)
+ {
+ $args = new \Hbase\Hbase_deleteAll_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->column = $column;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'deleteAll', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('deleteAll', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_deleteAll()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_deleteAll_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_deleteAll_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ return;
+ }
+
+ public function deleteAllTs($tableName, $row, $column, $timestamp, $attributes)
+ {
+ $this->send_deleteAllTs($tableName, $row, $column, $timestamp, $attributes);
+ $this->recv_deleteAllTs();
+ }
+
+ public function send_deleteAllTs($tableName, $row, $column, $timestamp, $attributes)
+ {
+ $args = new \Hbase\Hbase_deleteAllTs_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->column = $column;
+ $args->timestamp = $timestamp;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'deleteAllTs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('deleteAllTs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_deleteAllTs()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_deleteAllTs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_deleteAllTs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ return;
+ }
+
+ public function deleteAllRow($tableName, $row, $attributes)
+ {
+ $this->send_deleteAllRow($tableName, $row, $attributes);
+ $this->recv_deleteAllRow();
+ }
+
+ public function send_deleteAllRow($tableName, $row, $attributes)
+ {
+ $args = new \Hbase\Hbase_deleteAllRow_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'deleteAllRow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('deleteAllRow', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_deleteAllRow()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_deleteAllRow_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_deleteAllRow_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ return;
+ }
+
+ public function increment(\Hbase\TIncrement $increment)
+ {
+ $this->send_increment($increment);
+ $this->recv_increment();
+ }
+
+ public function send_increment(\Hbase\TIncrement $increment)
+ {
+ $args = new \Hbase\Hbase_increment_args();
+ $args->increment = $increment;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'increment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('increment', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_increment()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_increment_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_increment_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ return;
+ }
+
+ public function incrementRows($increments)
+ {
+ $this->send_incrementRows($increments);
+ $this->recv_incrementRows();
+ }
+
+ public function send_incrementRows($increments)
+ {
+ $args = new \Hbase\Hbase_incrementRows_args();
+ $args->increments = $increments;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'incrementRows', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('incrementRows', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_incrementRows()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_incrementRows_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_incrementRows_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ return;
+ }
+
+ public function deleteAllRowTs($tableName, $row, $timestamp, $attributes)
+ {
+ $this->send_deleteAllRowTs($tableName, $row, $timestamp, $attributes);
+ $this->recv_deleteAllRowTs();
+ }
+
+ public function send_deleteAllRowTs($tableName, $row, $timestamp, $attributes)
+ {
+ $args = new \Hbase\Hbase_deleteAllRowTs_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->timestamp = $timestamp;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'deleteAllRowTs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('deleteAllRowTs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_deleteAllRowTs()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_deleteAllRowTs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_deleteAllRowTs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ return;
+ }
+
+ public function scannerOpenWithScan($tableName, \Hbase\TScan $scan, $attributes)
+ {
+ $this->send_scannerOpenWithScan($tableName, $scan, $attributes);
+ return $this->recv_scannerOpenWithScan();
+ }
+
+ public function send_scannerOpenWithScan($tableName, \Hbase\TScan $scan, $attributes)
+ {
+ $args = new \Hbase\Hbase_scannerOpenWithScan_args();
+ $args->tableName = $tableName;
+ $args->scan = $scan;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'scannerOpenWithScan', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('scannerOpenWithScan', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_scannerOpenWithScan()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_scannerOpenWithScan_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_scannerOpenWithScan_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("scannerOpenWithScan failed: unknown result");
+ }
+
+ public function scannerOpen($tableName, $startRow, $columns, $attributes)
+ {
+ $this->send_scannerOpen($tableName, $startRow, $columns, $attributes);
+ return $this->recv_scannerOpen();
+ }
+
+ public function send_scannerOpen($tableName, $startRow, $columns, $attributes)
+ {
+ $args = new \Hbase\Hbase_scannerOpen_args();
+ $args->tableName = $tableName;
+ $args->startRow = $startRow;
+ $args->columns = $columns;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'scannerOpen', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('scannerOpen', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_scannerOpen()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_scannerOpen_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_scannerOpen_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("scannerOpen failed: unknown result");
+ }
+
+ public function scannerOpenWithStop($tableName, $startRow, $stopRow, $columns, $attributes)
+ {
+ $this->send_scannerOpenWithStop($tableName, $startRow, $stopRow, $columns, $attributes);
+ return $this->recv_scannerOpenWithStop();
+ }
+
+ public function send_scannerOpenWithStop($tableName, $startRow, $stopRow, $columns, $attributes)
+ {
+ $args = new \Hbase\Hbase_scannerOpenWithStop_args();
+ $args->tableName = $tableName;
+ $args->startRow = $startRow;
+ $args->stopRow = $stopRow;
+ $args->columns = $columns;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'scannerOpenWithStop', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('scannerOpenWithStop', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_scannerOpenWithStop()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_scannerOpenWithStop_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_scannerOpenWithStop_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("scannerOpenWithStop failed: unknown result");
+ }
+
+ public function scannerOpenWithPrefix($tableName, $startAndPrefix, $columns, $attributes)
+ {
+ $this->send_scannerOpenWithPrefix($tableName, $startAndPrefix, $columns, $attributes);
+ return $this->recv_scannerOpenWithPrefix();
+ }
+
+ public function send_scannerOpenWithPrefix($tableName, $startAndPrefix, $columns, $attributes)
+ {
+ $args = new \Hbase\Hbase_scannerOpenWithPrefix_args();
+ $args->tableName = $tableName;
+ $args->startAndPrefix = $startAndPrefix;
+ $args->columns = $columns;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'scannerOpenWithPrefix', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('scannerOpenWithPrefix', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_scannerOpenWithPrefix()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_scannerOpenWithPrefix_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_scannerOpenWithPrefix_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("scannerOpenWithPrefix failed: unknown result");
+ }
+
+ public function scannerOpenTs($tableName, $startRow, $columns, $timestamp, $attributes)
+ {
+ $this->send_scannerOpenTs($tableName, $startRow, $columns, $timestamp, $attributes);
+ return $this->recv_scannerOpenTs();
+ }
+
+ public function send_scannerOpenTs($tableName, $startRow, $columns, $timestamp, $attributes)
+ {
+ $args = new \Hbase\Hbase_scannerOpenTs_args();
+ $args->tableName = $tableName;
+ $args->startRow = $startRow;
+ $args->columns = $columns;
+ $args->timestamp = $timestamp;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'scannerOpenTs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('scannerOpenTs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_scannerOpenTs()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_scannerOpenTs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_scannerOpenTs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("scannerOpenTs failed: unknown result");
+ }
+
+ public function scannerOpenWithStopTs($tableName, $startRow, $stopRow, $columns, $timestamp, $attributes)
+ {
+ $this->send_scannerOpenWithStopTs($tableName, $startRow, $stopRow, $columns, $timestamp, $attributes);
+ return $this->recv_scannerOpenWithStopTs();
+ }
+
+ public function send_scannerOpenWithStopTs($tableName, $startRow, $stopRow, $columns, $timestamp, $attributes)
+ {
+ $args = new \Hbase\Hbase_scannerOpenWithStopTs_args();
+ $args->tableName = $tableName;
+ $args->startRow = $startRow;
+ $args->stopRow = $stopRow;
+ $args->columns = $columns;
+ $args->timestamp = $timestamp;
+ $args->attributes = $attributes;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'scannerOpenWithStopTs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('scannerOpenWithStopTs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_scannerOpenWithStopTs()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_scannerOpenWithStopTs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_scannerOpenWithStopTs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("scannerOpenWithStopTs failed: unknown result");
+ }
+
+ public function scannerGet($id)
+ {
+ $this->send_scannerGet($id);
+ return $this->recv_scannerGet();
+ }
+
+ public function send_scannerGet($id)
+ {
+ $args = new \Hbase\Hbase_scannerGet_args();
+ $args->id = $id;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'scannerGet', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('scannerGet', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_scannerGet()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_scannerGet_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_scannerGet_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ if ($result->ia !== null) {
+ throw $result->ia;
+ }
+ throw new \Exception("scannerGet failed: unknown result");
+ }
+
+ public function scannerGetList($id, $nbRows)
+ {
+ $this->send_scannerGetList($id, $nbRows);
+ return $this->recv_scannerGetList();
+ }
+
+ public function send_scannerGetList($id, $nbRows)
+ {
+ $args = new \Hbase\Hbase_scannerGetList_args();
+ $args->id = $id;
+ $args->nbRows = $nbRows;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'scannerGetList', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('scannerGetList', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_scannerGetList()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_scannerGetList_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_scannerGetList_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ if ($result->ia !== null) {
+ throw $result->ia;
+ }
+ throw new \Exception("scannerGetList failed: unknown result");
+ }
+
+ public function scannerClose($id)
+ {
+ $this->send_scannerClose($id);
+ $this->recv_scannerClose();
+ }
+
+ public function send_scannerClose($id)
+ {
+ $args = new \Hbase\Hbase_scannerClose_args();
+ $args->id = $id;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'scannerClose', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('scannerClose', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_scannerClose()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_scannerClose_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_scannerClose_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ if ($result->ia !== null) {
+ throw $result->ia;
+ }
+ return;
+ }
+
+ public function getRowOrBefore($tableName, $row, $family)
+ {
+ $this->send_getRowOrBefore($tableName, $row, $family);
+ return $this->recv_getRowOrBefore();
+ }
+
+ public function send_getRowOrBefore($tableName, $row, $family)
+ {
+ $args = new \Hbase\Hbase_getRowOrBefore_args();
+ $args->tableName = $tableName;
+ $args->row = $row;
+ $args->family = $family;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getRowOrBefore', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getRowOrBefore', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getRowOrBefore()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getRowOrBefore_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getRowOrBefore_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getRowOrBefore failed: unknown result");
+ }
+
+ public function getRegionInfo($row)
+ {
+ $this->send_getRegionInfo($row);
+ return $this->recv_getRegionInfo();
+ }
+
+ public function send_getRegionInfo($row)
+ {
+ $args = new \Hbase\Hbase_getRegionInfo_args();
+ $args->row = $row;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getRegionInfo', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getRegionInfo', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getRegionInfo()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Hbase\Hbase_getRegionInfo_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Hbase\Hbase_getRegionInfo_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->io !== null) {
+ throw $result->io;
+ }
+ throw new \Exception("getRegionInfo failed: unknown result");
+ }
+
+}
+
+// HELPER FUNCTIONS AND STRUCTURES
+
+class Hbase_enableTable_args {
+ static $_TSPEC;
+
+ public $tableName = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'tableName',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['tableName'])) {
+ $this->tableName = $vals['tableName'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Hbase_enableTable_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->tableName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_enableTable_args');
[... 10551 lines stripped ...]