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 [10/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/perl/gen-perl/Hbase/Hbase.pm
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-examples/src/main/perl/gen-perl/Hbase/Hbase.pm?rev=1406339&view=auto
==============================================================================
--- hbase/trunk/hbase-examples/src/main/perl/gen-perl/Hbase/Hbase.pm (added)
+++ hbase/trunk/hbase-examples/src/main/perl/gen-perl/Hbase/Hbase.pm Tue Nov 6 21:22:27 2012
@@ -0,0 +1,12633 @@
+#
+# Autogenerated by Thrift Compiler (0.9.0)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+require 5.6.0;
+use strict;
+use warnings;
+use Thrift;
+
+use Hbase::Types;
+
+# HELPER FUNCTIONS AND STRUCTURES
+
+package Hbase::Hbase_enableTable_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_enableTable_args->mk_accessors( qw( tableName ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_enableTable_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_enableTable_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_enableTable_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_enableTable_result->mk_accessors( qw( ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_enableTable_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_enableTable_result');
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_disableTable_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_disableTable_args->mk_accessors( qw( tableName ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_disableTable_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_disableTable_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_disableTable_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_disableTable_result->mk_accessors( qw( ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_disableTable_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_disableTable_result');
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_isTableEnabled_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_isTableEnabled_args->mk_accessors( qw( tableName ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_isTableEnabled_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_isTableEnabled_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_isTableEnabled_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_isTableEnabled_result->mk_accessors( qw( success ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{success} = undef;
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_isTableEnabled_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool(\$self->{success});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_isTableEnabled_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($self->{success});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_compact_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_compact_args->mk_accessors( qw( tableNameOrRegionName ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableNameOrRegionName} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableNameOrRegionName}) {
+ $self->{tableNameOrRegionName} = $vals->{tableNameOrRegionName};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_compact_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableNameOrRegionName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_compact_args');
+ if (defined $self->{tableNameOrRegionName}) {
+ $xfer += $output->writeFieldBegin('tableNameOrRegionName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableNameOrRegionName});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_compact_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_compact_result->mk_accessors( qw( ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_compact_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_compact_result');
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_majorCompact_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_majorCompact_args->mk_accessors( qw( tableNameOrRegionName ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableNameOrRegionName} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableNameOrRegionName}) {
+ $self->{tableNameOrRegionName} = $vals->{tableNameOrRegionName};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_majorCompact_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableNameOrRegionName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_majorCompact_args');
+ if (defined $self->{tableNameOrRegionName}) {
+ $xfer += $output->writeFieldBegin('tableNameOrRegionName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableNameOrRegionName});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_majorCompact_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_majorCompact_result->mk_accessors( qw( ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_majorCompact_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_majorCompact_result');
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getTableNames_args;
+use base qw(Class::Accessor);
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getTableNames_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getTableNames_args');
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getTableNames_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_getTableNames_result->mk_accessors( qw( success ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{success} = undef;
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getTableNames_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size23 = 0;
+ $self->{success} = [];
+ my $_etype26 = 0;
+ $xfer += $input->readListBegin(\$_etype26, \$_size23);
+ for (my $_i27 = 0; $_i27 < $_size23; ++$_i27)
+ {
+ my $elem28 = undef;
+ $xfer += $input->readString(\$elem28);
+ push(@{$self->{success}},$elem28);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getTableNames_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+ {
+ $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
+ {
+ foreach my $iter29 (@{$self->{success}})
+ {
+ $xfer += $output->writeString($iter29);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getColumnDescriptors_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_getColumnDescriptors_args->mk_accessors( qw( tableName ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getColumnDescriptors_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getColumnDescriptors_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getColumnDescriptors_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_getColumnDescriptors_result->mk_accessors( qw( success ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{success} = undef;
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getColumnDescriptors_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::MAP) {
+ {
+ my $_size30 = 0;
+ $self->{success} = {};
+ my $_ktype31 = 0;
+ my $_vtype32 = 0;
+ $xfer += $input->readMapBegin(\$_ktype31, \$_vtype32, \$_size30);
+ for (my $_i34 = 0; $_i34 < $_size30; ++$_i34)
+ {
+ my $key35 = '';
+ my $val36 = new Hbase::ColumnDescriptor();
+ $xfer += $input->readString(\$key35);
+ $val36 = new Hbase::ColumnDescriptor();
+ $xfer += $val36->read($input);
+ $self->{success}->{$key35} = $val36;
+ }
+ $xfer += $input->readMapEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getColumnDescriptors_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::MAP, 0);
+ {
+ $xfer += $output->writeMapBegin(TType::STRING, TType::STRUCT, scalar(keys %{$self->{success}}));
+ {
+ while( my ($kiter37,$viter38) = each %{$self->{success}})
+ {
+ $xfer += $output->writeString($kiter37);
+ $xfer += ${viter38}->write($output);
+ }
+ }
+ $xfer += $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getTableRegions_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_getTableRegions_args->mk_accessors( qw( tableName ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getTableRegions_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getTableRegions_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getTableRegions_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_getTableRegions_result->mk_accessors( qw( success ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{success} = undef;
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getTableRegions_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size39 = 0;
+ $self->{success} = [];
+ my $_etype42 = 0;
+ $xfer += $input->readListBegin(\$_etype42, \$_size39);
+ for (my $_i43 = 0; $_i43 < $_size39; ++$_i43)
+ {
+ my $elem44 = undef;
+ $elem44 = new Hbase::TRegionInfo();
+ $xfer += $elem44->read($input);
+ push(@{$self->{success}},$elem44);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getTableRegions_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+ {
+ $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
+ {
+ foreach my $iter45 (@{$self->{success}})
+ {
+ $xfer += ${iter45}->write($output);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_createTable_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_createTable_args->mk_accessors( qw( tableName columnFamilies ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ $self->{columnFamilies} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ if (defined $vals->{columnFamilies}) {
+ $self->{columnFamilies} = $vals->{columnFamilies};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_createTable_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size46 = 0;
+ $self->{columnFamilies} = [];
+ my $_etype49 = 0;
+ $xfer += $input->readListBegin(\$_etype49, \$_size46);
+ for (my $_i50 = 0; $_i50 < $_size46; ++$_i50)
+ {
+ my $elem51 = undef;
+ $elem51 = new Hbase::ColumnDescriptor();
+ $xfer += $elem51->read($input);
+ push(@{$self->{columnFamilies}},$elem51);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_createTable_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{columnFamilies}) {
+ $xfer += $output->writeFieldBegin('columnFamilies', TType::LIST, 2);
+ {
+ $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{columnFamilies}}));
+ {
+ foreach my $iter52 (@{$self->{columnFamilies}})
+ {
+ $xfer += ${iter52}->write($output);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_createTable_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_createTable_result->mk_accessors( qw( ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{io} = undef;
+ $self->{ia} = undef;
+ $self->{exist} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ if (defined $vals->{ia}) {
+ $self->{ia} = $vals->{ia};
+ }
+ if (defined $vals->{exist}) {
+ $self->{exist} = $vals->{exist};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_createTable_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ia} = new Hbase::IllegalArgument();
+ $xfer += $self->{ia}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^3$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{exist} = new Hbase::AlreadyExists();
+ $xfer += $self->{exist}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_createTable_result');
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ia}) {
+ $xfer += $output->writeFieldBegin('ia', TType::STRUCT, 2);
+ $xfer += $self->{ia}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{exist}) {
+ $xfer += $output->writeFieldBegin('exist', TType::STRUCT, 3);
+ $xfer += $self->{exist}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_deleteTable_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_deleteTable_args->mk_accessors( qw( tableName ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_deleteTable_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_deleteTable_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_deleteTable_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_deleteTable_result->mk_accessors( qw( ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_deleteTable_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_deleteTable_result');
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_get_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_get_args->mk_accessors( qw( tableName row column attributes ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ $self->{row} = undef;
+ $self->{column} = undef;
+ $self->{attributes} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ if (defined $vals->{row}) {
+ $self->{row} = $vals->{row};
+ }
+ if (defined $vals->{column}) {
+ $self->{column} = $vals->{column};
+ }
+ if (defined $vals->{attributes}) {
+ $self->{attributes} = $vals->{attributes};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_get_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{row});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^3$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{column});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^4$/ && do{ if ($ftype == TType::MAP) {
+ {
+ my $_size53 = 0;
+ $self->{attributes} = {};
+ my $_ktype54 = 0;
+ my $_vtype55 = 0;
+ $xfer += $input->readMapBegin(\$_ktype54, \$_vtype55, \$_size53);
+ for (my $_i57 = 0; $_i57 < $_size53; ++$_i57)
+ {
+ my $key58 = '';
+ my $val59 = '';
+ $xfer += $input->readString(\$key58);
+ $xfer += $input->readString(\$val59);
+ $self->{attributes}->{$key58} = $val59;
+ }
+ $xfer += $input->readMapEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_get_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{row}) {
+ $xfer += $output->writeFieldBegin('row', TType::STRING, 2);
+ $xfer += $output->writeString($self->{row});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{column}) {
+ $xfer += $output->writeFieldBegin('column', TType::STRING, 3);
+ $xfer += $output->writeString($self->{column});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{attributes}) {
+ $xfer += $output->writeFieldBegin('attributes', TType::MAP, 4);
+ {
+ $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{attributes}}));
+ {
+ while( my ($kiter60,$viter61) = each %{$self->{attributes}})
+ {
+ $xfer += $output->writeString($kiter60);
+ $xfer += $output->writeString($viter61);
+ }
+ }
+ $xfer += $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_get_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_get_result->mk_accessors( qw( success ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{success} = undef;
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_get_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size62 = 0;
+ $self->{success} = [];
+ my $_etype65 = 0;
+ $xfer += $input->readListBegin(\$_etype65, \$_size62);
+ for (my $_i66 = 0; $_i66 < $_size62; ++$_i66)
+ {
+ my $elem67 = undef;
+ $elem67 = new Hbase::TCell();
+ $xfer += $elem67->read($input);
+ push(@{$self->{success}},$elem67);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_get_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+ {
+ $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
+ {
+ foreach my $iter68 (@{$self->{success}})
+ {
+ $xfer += ${iter68}->write($output);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getVer_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_getVer_args->mk_accessors( qw( tableName row column numVersions attributes ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ $self->{row} = undef;
+ $self->{column} = undef;
+ $self->{numVersions} = undef;
+ $self->{attributes} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ if (defined $vals->{row}) {
+ $self->{row} = $vals->{row};
+ }
+ if (defined $vals->{column}) {
+ $self->{column} = $vals->{column};
+ }
+ if (defined $vals->{numVersions}) {
+ $self->{numVersions} = $vals->{numVersions};
+ }
+ if (defined $vals->{attributes}) {
+ $self->{attributes} = $vals->{attributes};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getVer_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{row});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^3$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{column});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^4$/ && do{ if ($ftype == TType::I32) {
+ $xfer += $input->readI32(\$self->{numVersions});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^5$/ && do{ if ($ftype == TType::MAP) {
+ {
+ my $_size69 = 0;
+ $self->{attributes} = {};
+ my $_ktype70 = 0;
+ my $_vtype71 = 0;
+ $xfer += $input->readMapBegin(\$_ktype70, \$_vtype71, \$_size69);
+ for (my $_i73 = 0; $_i73 < $_size69; ++$_i73)
+ {
+ my $key74 = '';
+ my $val75 = '';
+ $xfer += $input->readString(\$key74);
+ $xfer += $input->readString(\$val75);
+ $self->{attributes}->{$key74} = $val75;
+ }
+ $xfer += $input->readMapEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getVer_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{row}) {
+ $xfer += $output->writeFieldBegin('row', TType::STRING, 2);
+ $xfer += $output->writeString($self->{row});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{column}) {
+ $xfer += $output->writeFieldBegin('column', TType::STRING, 3);
+ $xfer += $output->writeString($self->{column});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{numVersions}) {
+ $xfer += $output->writeFieldBegin('numVersions', TType::I32, 4);
+ $xfer += $output->writeI32($self->{numVersions});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{attributes}) {
+ $xfer += $output->writeFieldBegin('attributes', TType::MAP, 5);
+ {
+ $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{attributes}}));
+ {
+ while( my ($kiter76,$viter77) = each %{$self->{attributes}})
+ {
+ $xfer += $output->writeString($kiter76);
+ $xfer += $output->writeString($viter77);
+ }
+ }
+ $xfer += $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getVer_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_getVer_result->mk_accessors( qw( success ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{success} = undef;
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getVer_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size78 = 0;
+ $self->{success} = [];
+ my $_etype81 = 0;
+ $xfer += $input->readListBegin(\$_etype81, \$_size78);
+ for (my $_i82 = 0; $_i82 < $_size78; ++$_i82)
+ {
+ my $elem83 = undef;
+ $elem83 = new Hbase::TCell();
+ $xfer += $elem83->read($input);
+ push(@{$self->{success}},$elem83);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getVer_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+ {
+ $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
+ {
+ foreach my $iter84 (@{$self->{success}})
+ {
+ $xfer += ${iter84}->write($output);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getVerTs_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_getVerTs_args->mk_accessors( qw( tableName row column timestamp numVersions attributes ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ $self->{row} = undef;
+ $self->{column} = undef;
+ $self->{timestamp} = undef;
+ $self->{numVersions} = undef;
+ $self->{attributes} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ if (defined $vals->{row}) {
+ $self->{row} = $vals->{row};
+ }
+ if (defined $vals->{column}) {
+ $self->{column} = $vals->{column};
+ }
+ if (defined $vals->{timestamp}) {
+ $self->{timestamp} = $vals->{timestamp};
+ }
+ if (defined $vals->{numVersions}) {
+ $self->{numVersions} = $vals->{numVersions};
+ }
+ if (defined $vals->{attributes}) {
+ $self->{attributes} = $vals->{attributes};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getVerTs_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{row});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^3$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{column});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^4$/ && do{ if ($ftype == TType::I64) {
+ $xfer += $input->readI64(\$self->{timestamp});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^5$/ && do{ if ($ftype == TType::I32) {
+ $xfer += $input->readI32(\$self->{numVersions});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^6$/ && do{ if ($ftype == TType::MAP) {
+ {
+ my $_size85 = 0;
+ $self->{attributes} = {};
+ my $_ktype86 = 0;
+ my $_vtype87 = 0;
+ $xfer += $input->readMapBegin(\$_ktype86, \$_vtype87, \$_size85);
+ for (my $_i89 = 0; $_i89 < $_size85; ++$_i89)
+ {
+ my $key90 = '';
+ my $val91 = '';
+ $xfer += $input->readString(\$key90);
+ $xfer += $input->readString(\$val91);
+ $self->{attributes}->{$key90} = $val91;
+ }
+ $xfer += $input->readMapEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getVerTs_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{row}) {
+ $xfer += $output->writeFieldBegin('row', TType::STRING, 2);
+ $xfer += $output->writeString($self->{row});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{column}) {
+ $xfer += $output->writeFieldBegin('column', TType::STRING, 3);
+ $xfer += $output->writeString($self->{column});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{timestamp}) {
+ $xfer += $output->writeFieldBegin('timestamp', TType::I64, 4);
+ $xfer += $output->writeI64($self->{timestamp});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{numVersions}) {
+ $xfer += $output->writeFieldBegin('numVersions', TType::I32, 5);
+ $xfer += $output->writeI32($self->{numVersions});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{attributes}) {
+ $xfer += $output->writeFieldBegin('attributes', TType::MAP, 6);
+ {
+ $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{attributes}}));
+ {
+ while( my ($kiter92,$viter93) = each %{$self->{attributes}})
+ {
+ $xfer += $output->writeString($kiter92);
+ $xfer += $output->writeString($viter93);
+ }
+ }
+ $xfer += $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getVerTs_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_getVerTs_result->mk_accessors( qw( success ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{success} = undef;
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getVerTs_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size94 = 0;
+ $self->{success} = [];
+ my $_etype97 = 0;
+ $xfer += $input->readListBegin(\$_etype97, \$_size94);
+ for (my $_i98 = 0; $_i98 < $_size94; ++$_i98)
+ {
+ my $elem99 = undef;
+ $elem99 = new Hbase::TCell();
+ $xfer += $elem99->read($input);
+ push(@{$self->{success}},$elem99);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getVerTs_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+ {
+ $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
+ {
+ foreach my $iter100 (@{$self->{success}})
+ {
+ $xfer += ${iter100}->write($output);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getRow_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_getRow_args->mk_accessors( qw( tableName row attributes ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ $self->{row} = undef;
+ $self->{attributes} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ if (defined $vals->{row}) {
+ $self->{row} = $vals->{row};
+ }
+ if (defined $vals->{attributes}) {
+ $self->{attributes} = $vals->{attributes};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getRow_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{row});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^3$/ && do{ if ($ftype == TType::MAP) {
+ {
+ my $_size101 = 0;
+ $self->{attributes} = {};
+ my $_ktype102 = 0;
+ my $_vtype103 = 0;
+ $xfer += $input->readMapBegin(\$_ktype102, \$_vtype103, \$_size101);
+ for (my $_i105 = 0; $_i105 < $_size101; ++$_i105)
+ {
+ my $key106 = '';
+ my $val107 = '';
+ $xfer += $input->readString(\$key106);
+ $xfer += $input->readString(\$val107);
+ $self->{attributes}->{$key106} = $val107;
+ }
+ $xfer += $input->readMapEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getRow_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{row}) {
+ $xfer += $output->writeFieldBegin('row', TType::STRING, 2);
+ $xfer += $output->writeString($self->{row});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{attributes}) {
+ $xfer += $output->writeFieldBegin('attributes', TType::MAP, 3);
+ {
+ $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{attributes}}));
+ {
+ while( my ($kiter108,$viter109) = each %{$self->{attributes}})
+ {
+ $xfer += $output->writeString($kiter108);
+ $xfer += $output->writeString($viter109);
+ }
+ }
+ $xfer += $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getRow_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_getRow_result->mk_accessors( qw( success ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{success} = undef;
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getRow_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size110 = 0;
+ $self->{success} = [];
+ my $_etype113 = 0;
+ $xfer += $input->readListBegin(\$_etype113, \$_size110);
+ for (my $_i114 = 0; $_i114 < $_size110; ++$_i114)
+ {
+ my $elem115 = undef;
+ $elem115 = new Hbase::TRowResult();
+ $xfer += $elem115->read($input);
+ push(@{$self->{success}},$elem115);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getRow_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+ {
+ $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
+ {
+ foreach my $iter116 (@{$self->{success}})
+ {
+ $xfer += ${iter116}->write($output);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getRowWithColumns_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_getRowWithColumns_args->mk_accessors( qw( tableName row columns attributes ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ $self->{row} = undef;
+ $self->{columns} = undef;
+ $self->{attributes} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ if (defined $vals->{row}) {
+ $self->{row} = $vals->{row};
+ }
+ if (defined $vals->{columns}) {
+ $self->{columns} = $vals->{columns};
+ }
+ if (defined $vals->{attributes}) {
+ $self->{attributes} = $vals->{attributes};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getRowWithColumns_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{row});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^3$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size117 = 0;
+ $self->{columns} = [];
+ my $_etype120 = 0;
+ $xfer += $input->readListBegin(\$_etype120, \$_size117);
+ for (my $_i121 = 0; $_i121 < $_size117; ++$_i121)
+ {
+ my $elem122 = undef;
+ $xfer += $input->readString(\$elem122);
+ push(@{$self->{columns}},$elem122);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^4$/ && do{ if ($ftype == TType::MAP) {
+ {
+ my $_size123 = 0;
+ $self->{attributes} = {};
+ my $_ktype124 = 0;
+ my $_vtype125 = 0;
+ $xfer += $input->readMapBegin(\$_ktype124, \$_vtype125, \$_size123);
+ for (my $_i127 = 0; $_i127 < $_size123; ++$_i127)
+ {
+ my $key128 = '';
+ my $val129 = '';
+ $xfer += $input->readString(\$key128);
+ $xfer += $input->readString(\$val129);
+ $self->{attributes}->{$key128} = $val129;
+ }
+ $xfer += $input->readMapEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getRowWithColumns_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{row}) {
+ $xfer += $output->writeFieldBegin('row', TType::STRING, 2);
+ $xfer += $output->writeString($self->{row});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{columns}) {
+ $xfer += $output->writeFieldBegin('columns', TType::LIST, 3);
+ {
+ $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{columns}}));
+ {
+ foreach my $iter130 (@{$self->{columns}})
+ {
+ $xfer += $output->writeString($iter130);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{attributes}) {
+ $xfer += $output->writeFieldBegin('attributes', TType::MAP, 4);
+ {
+ $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{attributes}}));
+ {
+ while( my ($kiter131,$viter132) = each %{$self->{attributes}})
+ {
+ $xfer += $output->writeString($kiter131);
+ $xfer += $output->writeString($viter132);
+ }
+ }
+ $xfer += $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getRowWithColumns_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_getRowWithColumns_result->mk_accessors( qw( success ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{success} = undef;
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getRowWithColumns_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size133 = 0;
+ $self->{success} = [];
+ my $_etype136 = 0;
+ $xfer += $input->readListBegin(\$_etype136, \$_size133);
+ for (my $_i137 = 0; $_i137 < $_size133; ++$_i137)
+ {
+ my $elem138 = undef;
+ $elem138 = new Hbase::TRowResult();
+ $xfer += $elem138->read($input);
+ push(@{$self->{success}},$elem138);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getRowWithColumns_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+ {
+ $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
+ {
+ foreach my $iter139 (@{$self->{success}})
+ {
+ $xfer += ${iter139}->write($output);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getRowTs_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_getRowTs_args->mk_accessors( qw( tableName row timestamp attributes ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ $self->{row} = undef;
+ $self->{timestamp} = undef;
+ $self->{attributes} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ if (defined $vals->{row}) {
+ $self->{row} = $vals->{row};
+ }
+ if (defined $vals->{timestamp}) {
+ $self->{timestamp} = $vals->{timestamp};
+ }
+ if (defined $vals->{attributes}) {
+ $self->{attributes} = $vals->{attributes};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getRowTs_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{row});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^3$/ && do{ if ($ftype == TType::I64) {
+ $xfer += $input->readI64(\$self->{timestamp});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^4$/ && do{ if ($ftype == TType::MAP) {
+ {
+ my $_size140 = 0;
+ $self->{attributes} = {};
+ my $_ktype141 = 0;
+ my $_vtype142 = 0;
+ $xfer += $input->readMapBegin(\$_ktype141, \$_vtype142, \$_size140);
+ for (my $_i144 = 0; $_i144 < $_size140; ++$_i144)
+ {
+ my $key145 = '';
+ my $val146 = '';
+ $xfer += $input->readString(\$key145);
+ $xfer += $input->readString(\$val146);
+ $self->{attributes}->{$key145} = $val146;
+ }
+ $xfer += $input->readMapEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getRowTs_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{row}) {
+ $xfer += $output->writeFieldBegin('row', TType::STRING, 2);
+ $xfer += $output->writeString($self->{row});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{timestamp}) {
+ $xfer += $output->writeFieldBegin('timestamp', TType::I64, 3);
+ $xfer += $output->writeI64($self->{timestamp});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{attributes}) {
+ $xfer += $output->writeFieldBegin('attributes', TType::MAP, 4);
+ {
+ $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{attributes}}));
+ {
+ while( my ($kiter147,$viter148) = each %{$self->{attributes}})
+ {
+ $xfer += $output->writeString($kiter147);
+ $xfer += $output->writeString($viter148);
+ }
+ }
+ $xfer += $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getRowTs_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_getRowTs_result->mk_accessors( qw( success ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{success} = undef;
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getRowTs_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size149 = 0;
+ $self->{success} = [];
+ my $_etype152 = 0;
+ $xfer += $input->readListBegin(\$_etype152, \$_size149);
+ for (my $_i153 = 0; $_i153 < $_size149; ++$_i153)
+ {
+ my $elem154 = undef;
+ $elem154 = new Hbase::TRowResult();
+ $xfer += $elem154->read($input);
+ push(@{$self->{success}},$elem154);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getRowTs_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+ {
+ $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
+ {
+ foreach my $iter155 (@{$self->{success}})
+ {
+ $xfer += ${iter155}->write($output);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getRowWithColumnsTs_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_getRowWithColumnsTs_args->mk_accessors( qw( tableName row columns timestamp attributes ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ $self->{row} = undef;
+ $self->{columns} = undef;
+ $self->{timestamp} = undef;
+ $self->{attributes} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ if (defined $vals->{row}) {
+ $self->{row} = $vals->{row};
+ }
+ if (defined $vals->{columns}) {
+ $self->{columns} = $vals->{columns};
+ }
+ if (defined $vals->{timestamp}) {
+ $self->{timestamp} = $vals->{timestamp};
+ }
+ if (defined $vals->{attributes}) {
+ $self->{attributes} = $vals->{attributes};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getRowWithColumnsTs_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{row});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^3$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size156 = 0;
+ $self->{columns} = [];
+ my $_etype159 = 0;
+ $xfer += $input->readListBegin(\$_etype159, \$_size156);
+ for (my $_i160 = 0; $_i160 < $_size156; ++$_i160)
+ {
+ my $elem161 = undef;
+ $xfer += $input->readString(\$elem161);
+ push(@{$self->{columns}},$elem161);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^4$/ && do{ if ($ftype == TType::I64) {
+ $xfer += $input->readI64(\$self->{timestamp});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^5$/ && do{ if ($ftype == TType::MAP) {
+ {
+ my $_size162 = 0;
+ $self->{attributes} = {};
+ my $_ktype163 = 0;
+ my $_vtype164 = 0;
+ $xfer += $input->readMapBegin(\$_ktype163, \$_vtype164, \$_size162);
+ for (my $_i166 = 0; $_i166 < $_size162; ++$_i166)
+ {
+ my $key167 = '';
+ my $val168 = '';
+ $xfer += $input->readString(\$key167);
+ $xfer += $input->readString(\$val168);
+ $self->{attributes}->{$key167} = $val168;
+ }
+ $xfer += $input->readMapEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getRowWithColumnsTs_args');
+ if (defined $self->{tableName}) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+ $xfer += $output->writeString($self->{tableName});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{row}) {
+ $xfer += $output->writeFieldBegin('row', TType::STRING, 2);
+ $xfer += $output->writeString($self->{row});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{columns}) {
+ $xfer += $output->writeFieldBegin('columns', TType::LIST, 3);
+ {
+ $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{columns}}));
+ {
+ foreach my $iter169 (@{$self->{columns}})
+ {
+ $xfer += $output->writeString($iter169);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{timestamp}) {
+ $xfer += $output->writeFieldBegin('timestamp', TType::I64, 4);
+ $xfer += $output->writeI64($self->{timestamp});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{attributes}) {
+ $xfer += $output->writeFieldBegin('attributes', TType::MAP, 5);
+ {
+ $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{attributes}}));
+ {
+ while( my ($kiter170,$viter171) = each %{$self->{attributes}})
+ {
+ $xfer += $output->writeString($kiter170);
+ $xfer += $output->writeString($viter171);
+ }
+ }
+ $xfer += $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getRowWithColumnsTs_result;
+use base qw(Class::Accessor);
+Hbase::Hbase_getRowWithColumnsTs_result->mk_accessors( qw( success ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{success} = undef;
+ $self->{io} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{io}) {
+ $self->{io} = $vals->{io};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getRowWithColumnsTs_result';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size172 = 0;
+ $self->{success} = [];
+ my $_etype175 = 0;
+ $xfer += $input->readListBegin(\$_etype175, \$_size172);
+ for (my $_i176 = 0; $_i176 < $_size172; ++$_i176)
+ {
+ my $elem177 = undef;
+ $elem177 = new Hbase::TRowResult();
+ $xfer += $elem177->read($input);
+ push(@{$self->{success}},$elem177);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{io} = new Hbase::IOError();
+ $xfer += $self->{io}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my ($self, $output) = @_;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('Hbase_getRowWithColumnsTs_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+ {
+ $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
+ {
+ foreach my $iter178 (@{$self->{success}})
+ {
+ $xfer += ${iter178}->write($output);
+ }
+ }
+ $xfer += $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{io}) {
+ $xfer += $output->writeFieldBegin('io', TType::STRUCT, 1);
+ $xfer += $self->{io}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package Hbase::Hbase_getRows_args;
+use base qw(Class::Accessor);
+Hbase::Hbase_getRows_args->mk_accessors( qw( tableName rows attributes ) );
+
+sub new {
+ my $classname = shift;
+ my $self = {};
+ my $vals = shift || {};
+ $self->{tableName} = undef;
+ $self->{rows} = undef;
+ $self->{attributes} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{tableName}) {
+ $self->{tableName} = $vals->{tableName};
+ }
+ if (defined $vals->{rows}) {
+ $self->{rows} = $vals->{rows};
+ }
+ if (defined $vals->{attributes}) {
+ $self->{attributes} = $vals->{attributes};
+ }
+ }
+ return bless ($self, $classname);
+}
+
+sub getName {
+ return 'Hbase_getRows_args';
+}
+
+sub read {
+ my ($self, $input) = @_;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{tableName});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size179 = 0;
+ $self->{rows} = [];
+ my $_etype182 = 0;
+ $xfer += $input->readListBegin(\$_etype182, \$_size179);
+ for (my $_i183 = 0; $_i183 < $_size179; ++$_i183)
+ {
+ my $elem184 = undef;
[... 9352 lines stripped ...]