blob: 713fd987410a7ae5849f4e48aa2bdd9bf106ffe3 [file] [log] [blame]
#
# 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;
package Blur::ErrorType;
use constant UNKNOWN => 0;
use constant QUERY_CANCEL => 1;
use constant QUERY_TIMEOUT => 2;
use constant BACK_PRESSURE => 3;
use constant REQUEST_TIMEOUT => 4;
package Blur::ScoreType;
use constant SUPER => 0;
use constant AGGREGATE => 1;
use constant BEST => 2;
use constant CONSTANT => 3;
package Blur::QueryState;
use constant RUNNING => 0;
use constant INTERRUPTED => 1;
use constant COMPLETE => 2;
use constant BACK_PRESSURE_INTERRUPTED => 3;
package Blur::Status;
use constant NOT_FOUND => 0;
use constant FOUND => 1;
package Blur::RowMutationType;
use constant DELETE_ROW => 0;
use constant REPLACE_ROW => 1;
use constant UPDATE_ROW => 2;
package Blur::RecordMutationType;
use constant DELETE_ENTIRE_RECORD => 0;
use constant REPLACE_ENTIRE_RECORD => 1;
use constant REPLACE_COLUMNS => 2;
use constant APPEND_COLUMN_VALUES => 3;
package Blur::ShardState;
use constant OPENING => 0;
use constant OPEN => 1;
use constant OPENING_ERROR => 2;
use constant CLOSING => 3;
use constant CLOSED => 4;
use constant CLOSING_ERROR => 5;
package Blur::Level;
use constant OFF => 0;
use constant FATAL => 1;
use constant ERROR => 2;
use constant WARN => 3;
use constant INFO => 4;
use constant DEBUG => 5;
use constant TRACE => 6;
use constant ALL => 7;
package Blur::BlurObjectType;
use constant MAP => 0;
use constant LIST => 1;
use constant NAME => 2;
use constant VALUE => 3;
package Blur::CommandStatusState;
use constant RUNNING => 0;
use constant INTERRUPTED => 1;
use constant COMPLETE => 2;
package Blur::BlurException;
use base qw(Thrift::TException);
use base qw(Class::Accessor);
Blur::BlurException->mk_accessors( qw( message stackTraceStr errorType ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{message} = undef;
$self->{stackTraceStr} = undef;
$self->{errorType} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{message}) {
$self->{message} = $vals->{message};
}
if (defined $vals->{stackTraceStr}) {
$self->{stackTraceStr} = $vals->{stackTraceStr};
}
if (defined $vals->{errorType}) {
$self->{errorType} = $vals->{errorType};
}
}
return bless ($self, $classname);
}
sub getName {
return 'BlurException';
}
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->{message});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{stackTraceStr});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{errorType});
} 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('BlurException');
if (defined $self->{message}) {
$xfer += $output->writeFieldBegin('message', TType::STRING, 1);
$xfer += $output->writeString($self->{message});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{stackTraceStr}) {
$xfer += $output->writeFieldBegin('stackTraceStr', TType::STRING, 2);
$xfer += $output->writeString($self->{stackTraceStr});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{errorType}) {
$xfer += $output->writeFieldBegin('errorType', TType::I32, 3);
$xfer += $output->writeI32($self->{errorType});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::TimeoutException;
use base qw(Thrift::TException);
use base qw(Class::Accessor);
Blur::TimeoutException->mk_accessors( qw( instanceExecutionId ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{instanceExecutionId} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{instanceExecutionId}) {
$self->{instanceExecutionId} = $vals->{instanceExecutionId};
}
}
return bless ($self, $classname);
}
sub getName {
return 'TimeoutException';
}
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::I64) {
$xfer += $input->readI64(\$self->{instanceExecutionId});
} 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('TimeoutException');
if (defined $self->{instanceExecutionId}) {
$xfer += $output->writeFieldBegin('instanceExecutionId', TType::I64, 1);
$xfer += $output->writeI64($self->{instanceExecutionId});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::User;
use base qw(Class::Accessor);
Blur::User->mk_accessors( qw( username attributes ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{username} = undef;
$self->{attributes} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{username}) {
$self->{username} = $vals->{username};
}
if (defined $vals->{attributes}) {
$self->{attributes} = $vals->{attributes};
}
}
return bless ($self, $classname);
}
sub getName {
return 'User';
}
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->{username});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::MAP) {
{
my $_size0 = 0;
$self->{attributes} = {};
my $_ktype1 = 0;
my $_vtype2 = 0;
$xfer += $input->readMapBegin(\$_ktype1, \$_vtype2, \$_size0);
for (my $_i4 = 0; $_i4 < $_size0; ++$_i4)
{
my $key5 = '';
my $val6 = '';
$xfer += $input->readString(\$key5);
$xfer += $input->readString(\$val6);
$self->{attributes}->{$key5} = $val6;
}
$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('User');
if (defined $self->{username}) {
$xfer += $output->writeFieldBegin('username', TType::STRING, 1);
$xfer += $output->writeString($self->{username});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{attributes}) {
$xfer += $output->writeFieldBegin('attributes', TType::MAP, 2);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{attributes}}));
{
while( my ($kiter7,$viter8) = each %{$self->{attributes}})
{
$xfer += $output->writeString($kiter7);
$xfer += $output->writeString($viter8);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Column;
use base qw(Class::Accessor);
Blur::Column->mk_accessors( qw( name value ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{name} = undef;
$self->{value} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{name}) {
$self->{name} = $vals->{name};
}
if (defined $vals->{value}) {
$self->{value} = $vals->{value};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Column';
}
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->{name});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{value});
} 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('Column');
if (defined $self->{name}) {
$xfer += $output->writeFieldBegin('name', TType::STRING, 1);
$xfer += $output->writeString($self->{name});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{value}) {
$xfer += $output->writeFieldBegin('value', TType::STRING, 2);
$xfer += $output->writeString($self->{value});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Record;
use base qw(Class::Accessor);
Blur::Record->mk_accessors( qw( recordId family columns ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{recordId} = undef;
$self->{family} = undef;
$self->{columns} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{recordId}) {
$self->{recordId} = $vals->{recordId};
}
if (defined $vals->{family}) {
$self->{family} = $vals->{family};
}
if (defined $vals->{columns}) {
$self->{columns} = $vals->{columns};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Record';
}
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->{recordId});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{family});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::LIST) {
{
my $_size9 = 0;
$self->{columns} = [];
my $_etype12 = 0;
$xfer += $input->readListBegin(\$_etype12, \$_size9);
for (my $_i13 = 0; $_i13 < $_size9; ++$_i13)
{
my $elem14 = undef;
$elem14 = new Blur::Column();
$xfer += $elem14->read($input);
push(@{$self->{columns}},$elem14);
}
$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('Record');
if (defined $self->{recordId}) {
$xfer += $output->writeFieldBegin('recordId', TType::STRING, 1);
$xfer += $output->writeString($self->{recordId});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{family}) {
$xfer += $output->writeFieldBegin('family', TType::STRING, 2);
$xfer += $output->writeString($self->{family});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{columns}) {
$xfer += $output->writeFieldBegin('columns', TType::LIST, 3);
{
$xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{columns}}));
{
foreach my $iter15 (@{$self->{columns}})
{
$xfer += ${iter15}->write($output);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Row;
use base qw(Class::Accessor);
Blur::Row->mk_accessors( qw( id records ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{id} = undef;
$self->{records} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{id}) {
$self->{id} = $vals->{id};
}
if (defined $vals->{records}) {
$self->{records} = $vals->{records};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Row';
}
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->{id});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::LIST) {
{
my $_size16 = 0;
$self->{records} = [];
my $_etype19 = 0;
$xfer += $input->readListBegin(\$_etype19, \$_size16);
for (my $_i20 = 0; $_i20 < $_size16; ++$_i20)
{
my $elem21 = undef;
$elem21 = new Blur::Record();
$xfer += $elem21->read($input);
push(@{$self->{records}},$elem21);
}
$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('Row');
if (defined $self->{id}) {
$xfer += $output->writeFieldBegin('id', TType::STRING, 1);
$xfer += $output->writeString($self->{id});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{records}) {
$xfer += $output->writeFieldBegin('records', TType::LIST, 2);
{
$xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{records}}));
{
foreach my $iter22 (@{$self->{records}})
{
$xfer += ${iter22}->write($output);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Query;
use base qw(Class::Accessor);
Blur::Query->mk_accessors( qw( query rowQuery scoreType rowFilter recordFilter ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{query} = undef;
$self->{rowQuery} = 1;
$self->{scoreType} = 0;
$self->{rowFilter} = undef;
$self->{recordFilter} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{query}) {
$self->{query} = $vals->{query};
}
if (defined $vals->{rowQuery}) {
$self->{rowQuery} = $vals->{rowQuery};
}
if (defined $vals->{scoreType}) {
$self->{scoreType} = $vals->{scoreType};
}
if (defined $vals->{rowFilter}) {
$self->{rowFilter} = $vals->{rowFilter};
}
if (defined $vals->{recordFilter}) {
$self->{recordFilter} = $vals->{recordFilter};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Query';
}
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->{query});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{rowQuery});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{scoreType});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{rowFilter});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{recordFilter});
} 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('Query');
if (defined $self->{query}) {
$xfer += $output->writeFieldBegin('query', TType::STRING, 1);
$xfer += $output->writeString($self->{query});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{rowQuery}) {
$xfer += $output->writeFieldBegin('rowQuery', TType::BOOL, 2);
$xfer += $output->writeBool($self->{rowQuery});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{scoreType}) {
$xfer += $output->writeFieldBegin('scoreType', TType::I32, 3);
$xfer += $output->writeI32($self->{scoreType});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{rowFilter}) {
$xfer += $output->writeFieldBegin('rowFilter', TType::STRING, 4);
$xfer += $output->writeString($self->{rowFilter});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{recordFilter}) {
$xfer += $output->writeFieldBegin('recordFilter', TType::STRING, 5);
$xfer += $output->writeString($self->{recordFilter});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::HighlightOptions;
use base qw(Class::Accessor);
Blur::HighlightOptions->mk_accessors( qw( query preTag postTag ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{query} = undef;
$self->{preTag} = "<<<";
$self->{postTag} = ">>>";
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{query}) {
$self->{query} = $vals->{query};
}
if (defined $vals->{preTag}) {
$self->{preTag} = $vals->{preTag};
}
if (defined $vals->{postTag}) {
$self->{postTag} = $vals->{postTag};
}
}
return bless ($self, $classname);
}
sub getName {
return 'HighlightOptions';
}
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->{query} = new Blur::Query();
$xfer += $self->{query}->read($input);
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{preTag});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{postTag});
} 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('HighlightOptions');
if (defined $self->{query}) {
$xfer += $output->writeFieldBegin('query', TType::STRUCT, 1);
$xfer += $self->{query}->write($output);
$xfer += $output->writeFieldEnd();
}
if (defined $self->{preTag}) {
$xfer += $output->writeFieldBegin('preTag', TType::STRING, 2);
$xfer += $output->writeString($self->{preTag});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{postTag}) {
$xfer += $output->writeFieldBegin('postTag', TType::STRING, 3);
$xfer += $output->writeString($self->{postTag});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Selector;
use base qw(Class::Accessor);
Blur::Selector->mk_accessors( qw( recordOnly locationId rowId recordId columnFamiliesToFetch columnsToFetch startRecord maxRecordsToFetch highlightOptions orderOfFamiliesToFetch ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{recordOnly} = undef;
$self->{locationId} = undef;
$self->{rowId} = undef;
$self->{recordId} = undef;
$self->{columnFamiliesToFetch} = undef;
$self->{columnsToFetch} = undef;
$self->{startRecord} = 0;
$self->{maxRecordsToFetch} = 1000;
$self->{highlightOptions} = undef;
$self->{orderOfFamiliesToFetch} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{recordOnly}) {
$self->{recordOnly} = $vals->{recordOnly};
}
if (defined $vals->{locationId}) {
$self->{locationId} = $vals->{locationId};
}
if (defined $vals->{rowId}) {
$self->{rowId} = $vals->{rowId};
}
if (defined $vals->{recordId}) {
$self->{recordId} = $vals->{recordId};
}
if (defined $vals->{columnFamiliesToFetch}) {
$self->{columnFamiliesToFetch} = $vals->{columnFamiliesToFetch};
}
if (defined $vals->{columnsToFetch}) {
$self->{columnsToFetch} = $vals->{columnsToFetch};
}
if (defined $vals->{startRecord}) {
$self->{startRecord} = $vals->{startRecord};
}
if (defined $vals->{maxRecordsToFetch}) {
$self->{maxRecordsToFetch} = $vals->{maxRecordsToFetch};
}
if (defined $vals->{highlightOptions}) {
$self->{highlightOptions} = $vals->{highlightOptions};
}
if (defined $vals->{orderOfFamiliesToFetch}) {
$self->{orderOfFamiliesToFetch} = $vals->{orderOfFamiliesToFetch};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Selector';
}
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::BOOL) {
$xfer += $input->readBool(\$self->{recordOnly});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{locationId});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{rowId});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{recordId});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::SET) {
{
my $_size23 = 0;
$self->{columnFamiliesToFetch} = {};
my $_etype26 = 0;
$xfer += $input->readSetBegin(\$_etype26, \$_size23);
for (my $_i27 = 0; $_i27 < $_size23; ++$_i27)
{
my $elem28 = undef;
$xfer += $input->readString(\$elem28);
$self->{columnFamiliesToFetch}->{$elem28} = 1;
}
$xfer += $input->readSetEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^6$/ && do{ if ($ftype == TType::MAP) {
{
my $_size29 = 0;
$self->{columnsToFetch} = {};
my $_ktype30 = 0;
my $_vtype31 = 0;
$xfer += $input->readMapBegin(\$_ktype30, \$_vtype31, \$_size29);
for (my $_i33 = 0; $_i33 < $_size29; ++$_i33)
{
my $key34 = '';
my $val35 = [];
$xfer += $input->readString(\$key34);
{
my $_size36 = 0;
$val35 = {};
my $_etype39 = 0;
$xfer += $input->readSetBegin(\$_etype39, \$_size36);
for (my $_i40 = 0; $_i40 < $_size36; ++$_i40)
{
my $elem41 = undef;
$xfer += $input->readString(\$elem41);
$val35->{$elem41} = 1;
}
$xfer += $input->readSetEnd();
}
$self->{columnsToFetch}->{$key34} = $val35;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^8$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{startRecord});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^9$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{maxRecordsToFetch});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^10$/ && do{ if ($ftype == TType::STRUCT) {
$self->{highlightOptions} = new Blur::HighlightOptions();
$xfer += $self->{highlightOptions}->read($input);
} else {
$xfer += $input->skip($ftype);
}
last; };
/^11$/ && do{ if ($ftype == TType::LIST) {
{
my $_size42 = 0;
$self->{orderOfFamiliesToFetch} = [];
my $_etype45 = 0;
$xfer += $input->readListBegin(\$_etype45, \$_size42);
for (my $_i46 = 0; $_i46 < $_size42; ++$_i46)
{
my $elem47 = undef;
$xfer += $input->readString(\$elem47);
push(@{$self->{orderOfFamiliesToFetch}},$elem47);
}
$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('Selector');
if (defined $self->{recordOnly}) {
$xfer += $output->writeFieldBegin('recordOnly', TType::BOOL, 1);
$xfer += $output->writeBool($self->{recordOnly});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{locationId}) {
$xfer += $output->writeFieldBegin('locationId', TType::STRING, 2);
$xfer += $output->writeString($self->{locationId});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{rowId}) {
$xfer += $output->writeFieldBegin('rowId', TType::STRING, 3);
$xfer += $output->writeString($self->{rowId});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{recordId}) {
$xfer += $output->writeFieldBegin('recordId', TType::STRING, 4);
$xfer += $output->writeString($self->{recordId});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{columnFamiliesToFetch}) {
$xfer += $output->writeFieldBegin('columnFamiliesToFetch', TType::SET, 5);
{
$xfer += $output->writeSetBegin(TType::STRING, scalar(@{$self->{columnFamiliesToFetch}}));
{
foreach my $iter48 (@{$self->{columnFamiliesToFetch}})
{
$xfer += $output->writeString($iter48);
}
}
$xfer += $output->writeSetEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{columnsToFetch}) {
$xfer += $output->writeFieldBegin('columnsToFetch', TType::MAP, 6);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::SET, scalar(keys %{$self->{columnsToFetch}}));
{
while( my ($kiter49,$viter50) = each %{$self->{columnsToFetch}})
{
$xfer += $output->writeString($kiter49);
{
$xfer += $output->writeSetBegin(TType::STRING, scalar(@{${viter50}}));
{
foreach my $iter51 (@{${viter50}})
{
$xfer += $output->writeString($iter51);
}
}
$xfer += $output->writeSetEnd();
}
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{startRecord}) {
$xfer += $output->writeFieldBegin('startRecord', TType::I32, 8);
$xfer += $output->writeI32($self->{startRecord});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{maxRecordsToFetch}) {
$xfer += $output->writeFieldBegin('maxRecordsToFetch', TType::I32, 9);
$xfer += $output->writeI32($self->{maxRecordsToFetch});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{highlightOptions}) {
$xfer += $output->writeFieldBegin('highlightOptions', TType::STRUCT, 10);
$xfer += $self->{highlightOptions}->write($output);
$xfer += $output->writeFieldEnd();
}
if (defined $self->{orderOfFamiliesToFetch}) {
$xfer += $output->writeFieldBegin('orderOfFamiliesToFetch', TType::LIST, 11);
{
$xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{orderOfFamiliesToFetch}}));
{
foreach my $iter52 (@{$self->{orderOfFamiliesToFetch}})
{
$xfer += $output->writeString($iter52);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::FetchRowResult;
use base qw(Class::Accessor);
Blur::FetchRowResult->mk_accessors( qw( row startRecord maxRecordsToFetch moreRecordsToFetch totalRecords ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{row} = undef;
$self->{startRecord} = -1;
$self->{maxRecordsToFetch} = -1;
$self->{moreRecordsToFetch} = 0;
$self->{totalRecords} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{row}) {
$self->{row} = $vals->{row};
}
if (defined $vals->{startRecord}) {
$self->{startRecord} = $vals->{startRecord};
}
if (defined $vals->{maxRecordsToFetch}) {
$self->{maxRecordsToFetch} = $vals->{maxRecordsToFetch};
}
if (defined $vals->{moreRecordsToFetch}) {
$self->{moreRecordsToFetch} = $vals->{moreRecordsToFetch};
}
if (defined $vals->{totalRecords}) {
$self->{totalRecords} = $vals->{totalRecords};
}
}
return bless ($self, $classname);
}
sub getName {
return 'FetchRowResult';
}
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->{row} = new Blur::Row();
$xfer += $self->{row}->read($input);
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{startRecord});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{maxRecordsToFetch});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{moreRecordsToFetch});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{totalRecords});
} 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('FetchRowResult');
if (defined $self->{row}) {
$xfer += $output->writeFieldBegin('row', TType::STRUCT, 1);
$xfer += $self->{row}->write($output);
$xfer += $output->writeFieldEnd();
}
if (defined $self->{startRecord}) {
$xfer += $output->writeFieldBegin('startRecord', TType::I32, 2);
$xfer += $output->writeI32($self->{startRecord});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{maxRecordsToFetch}) {
$xfer += $output->writeFieldBegin('maxRecordsToFetch', TType::I32, 3);
$xfer += $output->writeI32($self->{maxRecordsToFetch});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{moreRecordsToFetch}) {
$xfer += $output->writeFieldBegin('moreRecordsToFetch', TType::BOOL, 4);
$xfer += $output->writeBool($self->{moreRecordsToFetch});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{totalRecords}) {
$xfer += $output->writeFieldBegin('totalRecords', TType::I32, 5);
$xfer += $output->writeI32($self->{totalRecords});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::FetchRecordResult;
use base qw(Class::Accessor);
Blur::FetchRecordResult->mk_accessors( qw( rowid record ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{rowid} = undef;
$self->{record} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{rowid}) {
$self->{rowid} = $vals->{rowid};
}
if (defined $vals->{record}) {
$self->{record} = $vals->{record};
}
}
return bless ($self, $classname);
}
sub getName {
return 'FetchRecordResult';
}
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->{rowid});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRUCT) {
$self->{record} = new Blur::Record();
$xfer += $self->{record}->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('FetchRecordResult');
if (defined $self->{rowid}) {
$xfer += $output->writeFieldBegin('rowid', TType::STRING, 1);
$xfer += $output->writeString($self->{rowid});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{record}) {
$xfer += $output->writeFieldBegin('record', TType::STRUCT, 2);
$xfer += $self->{record}->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::FetchResult;
use base qw(Class::Accessor);
Blur::FetchResult->mk_accessors( qw( exists deleted table rowResult recordResult ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{exists} = undef;
$self->{deleted} = undef;
$self->{table} = undef;
$self->{rowResult} = undef;
$self->{recordResult} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{exists}) {
$self->{exists} = $vals->{exists};
}
if (defined $vals->{deleted}) {
$self->{deleted} = $vals->{deleted};
}
if (defined $vals->{table}) {
$self->{table} = $vals->{table};
}
if (defined $vals->{rowResult}) {
$self->{rowResult} = $vals->{rowResult};
}
if (defined $vals->{recordResult}) {
$self->{recordResult} = $vals->{recordResult};
}
}
return bless ($self, $classname);
}
sub getName {
return 'FetchResult';
}
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::BOOL) {
$xfer += $input->readBool(\$self->{exists});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{deleted});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{table});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::STRUCT) {
$self->{rowResult} = new Blur::FetchRowResult();
$xfer += $self->{rowResult}->read($input);
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::STRUCT) {
$self->{recordResult} = new Blur::FetchRecordResult();
$xfer += $self->{recordResult}->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('FetchResult');
if (defined $self->{exists}) {
$xfer += $output->writeFieldBegin('exists', TType::BOOL, 1);
$xfer += $output->writeBool($self->{exists});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{deleted}) {
$xfer += $output->writeFieldBegin('deleted', TType::BOOL, 2);
$xfer += $output->writeBool($self->{deleted});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{table}) {
$xfer += $output->writeFieldBegin('table', TType::STRING, 3);
$xfer += $output->writeString($self->{table});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{rowResult}) {
$xfer += $output->writeFieldBegin('rowResult', TType::STRUCT, 4);
$xfer += $self->{rowResult}->write($output);
$xfer += $output->writeFieldEnd();
}
if (defined $self->{recordResult}) {
$xfer += $output->writeFieldBegin('recordResult', TType::STRUCT, 5);
$xfer += $self->{recordResult}->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Facet;
use base qw(Class::Accessor);
Blur::Facet->mk_accessors( qw( queryStr minimumNumberOfBlurResults ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{queryStr} = undef;
$self->{minimumNumberOfBlurResults} = 9223372036854775807;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{queryStr}) {
$self->{queryStr} = $vals->{queryStr};
}
if (defined $vals->{minimumNumberOfBlurResults}) {
$self->{minimumNumberOfBlurResults} = $vals->{minimumNumberOfBlurResults};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Facet';
}
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->{queryStr});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{minimumNumberOfBlurResults});
} 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('Facet');
if (defined $self->{queryStr}) {
$xfer += $output->writeFieldBegin('queryStr', TType::STRING, 1);
$xfer += $output->writeString($self->{queryStr});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{minimumNumberOfBlurResults}) {
$xfer += $output->writeFieldBegin('minimumNumberOfBlurResults', TType::I64, 2);
$xfer += $output->writeI64($self->{minimumNumberOfBlurResults});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::SortField;
use base qw(Class::Accessor);
Blur::SortField->mk_accessors( qw( family column reverse ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{family} = undef;
$self->{column} = undef;
$self->{reverse} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{family}) {
$self->{family} = $vals->{family};
}
if (defined $vals->{column}) {
$self->{column} = $vals->{column};
}
if (defined $vals->{reverse}) {
$self->{reverse} = $vals->{reverse};
}
}
return bless ($self, $classname);
}
sub getName {
return 'SortField';
}
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->{family});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{column});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{reverse});
} 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('SortField');
if (defined $self->{family}) {
$xfer += $output->writeFieldBegin('family', TType::STRING, 1);
$xfer += $output->writeString($self->{family});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{column}) {
$xfer += $output->writeFieldBegin('column', TType::STRING, 2);
$xfer += $output->writeString($self->{column});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{reverse}) {
$xfer += $output->writeFieldBegin('reverse', TType::BOOL, 3);
$xfer += $output->writeBool($self->{reverse});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::BlurQuery;
use base qw(Class::Accessor);
Blur::BlurQuery->mk_accessors( qw( query facets selector useCacheIfPresent start fetch minimumNumberOfResults maxQueryTime uuid userContext cacheResult startTime sortFields rowId ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{query} = undef;
$self->{facets} = undef;
$self->{selector} = undef;
$self->{useCacheIfPresent} = 1;
$self->{start} = 0;
$self->{fetch} = 10;
$self->{minimumNumberOfResults} = 9223372036854775807;
$self->{maxQueryTime} = 9223372036854775807;
$self->{uuid} = undef;
$self->{userContext} = undef;
$self->{cacheResult} = 1;
$self->{startTime} = 0;
$self->{sortFields} = undef;
$self->{rowId} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{query}) {
$self->{query} = $vals->{query};
}
if (defined $vals->{facets}) {
$self->{facets} = $vals->{facets};
}
if (defined $vals->{selector}) {
$self->{selector} = $vals->{selector};
}
if (defined $vals->{useCacheIfPresent}) {
$self->{useCacheIfPresent} = $vals->{useCacheIfPresent};
}
if (defined $vals->{start}) {
$self->{start} = $vals->{start};
}
if (defined $vals->{fetch}) {
$self->{fetch} = $vals->{fetch};
}
if (defined $vals->{minimumNumberOfResults}) {
$self->{minimumNumberOfResults} = $vals->{minimumNumberOfResults};
}
if (defined $vals->{maxQueryTime}) {
$self->{maxQueryTime} = $vals->{maxQueryTime};
}
if (defined $vals->{uuid}) {
$self->{uuid} = $vals->{uuid};
}
if (defined $vals->{userContext}) {
$self->{userContext} = $vals->{userContext};
}
if (defined $vals->{cacheResult}) {
$self->{cacheResult} = $vals->{cacheResult};
}
if (defined $vals->{startTime}) {
$self->{startTime} = $vals->{startTime};
}
if (defined $vals->{sortFields}) {
$self->{sortFields} = $vals->{sortFields};
}
if (defined $vals->{rowId}) {
$self->{rowId} = $vals->{rowId};
}
}
return bless ($self, $classname);
}
sub getName {
return 'BlurQuery';
}
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->{query} = new Blur::Query();
$xfer += $self->{query}->read($input);
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::LIST) {
{
my $_size53 = 0;
$self->{facets} = [];
my $_etype56 = 0;
$xfer += $input->readListBegin(\$_etype56, \$_size53);
for (my $_i57 = 0; $_i57 < $_size53; ++$_i57)
{
my $elem58 = undef;
$elem58 = new Blur::Facet();
$xfer += $elem58->read($input);
push(@{$self->{facets}},$elem58);
}
$xfer += $input->readListEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::STRUCT) {
$self->{selector} = new Blur::Selector();
$xfer += $self->{selector}->read($input);
} else {
$xfer += $input->skip($ftype);
}
last; };
/^6$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{useCacheIfPresent});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^7$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{start});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^8$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{fetch});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^9$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{minimumNumberOfResults});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^10$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{maxQueryTime});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^11$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{uuid});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^12$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{userContext});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^13$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{cacheResult});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^14$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{startTime});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^15$/ && do{ if ($ftype == TType::LIST) {
{
my $_size59 = 0;
$self->{sortFields} = [];
my $_etype62 = 0;
$xfer += $input->readListBegin(\$_etype62, \$_size59);
for (my $_i63 = 0; $_i63 < $_size59; ++$_i63)
{
my $elem64 = undef;
$elem64 = new Blur::SortField();
$xfer += $elem64->read($input);
push(@{$self->{sortFields}},$elem64);
}
$xfer += $input->readListEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^16$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{rowId});
} 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('BlurQuery');
if (defined $self->{query}) {
$xfer += $output->writeFieldBegin('query', TType::STRUCT, 1);
$xfer += $self->{query}->write($output);
$xfer += $output->writeFieldEnd();
}
if (defined $self->{facets}) {
$xfer += $output->writeFieldBegin('facets', TType::LIST, 3);
{
$xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{facets}}));
{
foreach my $iter65 (@{$self->{facets}})
{
$xfer += ${iter65}->write($output);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{selector}) {
$xfer += $output->writeFieldBegin('selector', TType::STRUCT, 4);
$xfer += $self->{selector}->write($output);
$xfer += $output->writeFieldEnd();
}
if (defined $self->{useCacheIfPresent}) {
$xfer += $output->writeFieldBegin('useCacheIfPresent', TType::BOOL, 6);
$xfer += $output->writeBool($self->{useCacheIfPresent});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{start}) {
$xfer += $output->writeFieldBegin('start', TType::I64, 7);
$xfer += $output->writeI64($self->{start});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{fetch}) {
$xfer += $output->writeFieldBegin('fetch', TType::I32, 8);
$xfer += $output->writeI32($self->{fetch});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{minimumNumberOfResults}) {
$xfer += $output->writeFieldBegin('minimumNumberOfResults', TType::I64, 9);
$xfer += $output->writeI64($self->{minimumNumberOfResults});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{maxQueryTime}) {
$xfer += $output->writeFieldBegin('maxQueryTime', TType::I64, 10);
$xfer += $output->writeI64($self->{maxQueryTime});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{uuid}) {
$xfer += $output->writeFieldBegin('uuid', TType::STRING, 11);
$xfer += $output->writeString($self->{uuid});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{userContext}) {
$xfer += $output->writeFieldBegin('userContext', TType::STRING, 12);
$xfer += $output->writeString($self->{userContext});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{cacheResult}) {
$xfer += $output->writeFieldBegin('cacheResult', TType::BOOL, 13);
$xfer += $output->writeBool($self->{cacheResult});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{startTime}) {
$xfer += $output->writeFieldBegin('startTime', TType::I64, 14);
$xfer += $output->writeI64($self->{startTime});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{sortFields}) {
$xfer += $output->writeFieldBegin('sortFields', TType::LIST, 15);
{
$xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{sortFields}}));
{
foreach my $iter66 (@{$self->{sortFields}})
{
$xfer += ${iter66}->write($output);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{rowId}) {
$xfer += $output->writeFieldBegin('rowId', TType::STRING, 16);
$xfer += $output->writeString($self->{rowId});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::SortFieldResult;
use base qw(Class::Accessor);
Blur::SortFieldResult->mk_accessors( qw( nullValue stringValue intValue longValue doubleValue binaryValue ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{nullValue} = undef;
$self->{stringValue} = undef;
$self->{intValue} = undef;
$self->{longValue} = undef;
$self->{doubleValue} = undef;
$self->{binaryValue} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{nullValue}) {
$self->{nullValue} = $vals->{nullValue};
}
if (defined $vals->{stringValue}) {
$self->{stringValue} = $vals->{stringValue};
}
if (defined $vals->{intValue}) {
$self->{intValue} = $vals->{intValue};
}
if (defined $vals->{longValue}) {
$self->{longValue} = $vals->{longValue};
}
if (defined $vals->{doubleValue}) {
$self->{doubleValue} = $vals->{doubleValue};
}
if (defined $vals->{binaryValue}) {
$self->{binaryValue} = $vals->{binaryValue};
}
}
return bless ($self, $classname);
}
sub getName {
return 'SortFieldResult';
}
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::BOOL) {
$xfer += $input->readBool(\$self->{nullValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{stringValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{intValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{longValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::DOUBLE) {
$xfer += $input->readDouble(\$self->{doubleValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^6$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{binaryValue});
} 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('SortFieldResult');
if (defined $self->{nullValue}) {
$xfer += $output->writeFieldBegin('nullValue', TType::BOOL, 1);
$xfer += $output->writeBool($self->{nullValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{stringValue}) {
$xfer += $output->writeFieldBegin('stringValue', TType::STRING, 2);
$xfer += $output->writeString($self->{stringValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{intValue}) {
$xfer += $output->writeFieldBegin('intValue', TType::I32, 3);
$xfer += $output->writeI32($self->{intValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{longValue}) {
$xfer += $output->writeFieldBegin('longValue', TType::I64, 4);
$xfer += $output->writeI64($self->{longValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{doubleValue}) {
$xfer += $output->writeFieldBegin('doubleValue', TType::DOUBLE, 5);
$xfer += $output->writeDouble($self->{doubleValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{binaryValue}) {
$xfer += $output->writeFieldBegin('binaryValue', TType::STRING, 6);
$xfer += $output->writeString($self->{binaryValue});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::BlurResult;
use base qw(Class::Accessor);
Blur::BlurResult->mk_accessors( qw( locationId score fetchResult sortFieldResults ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{locationId} = undef;
$self->{score} = undef;
$self->{fetchResult} = undef;
$self->{sortFieldResults} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{locationId}) {
$self->{locationId} = $vals->{locationId};
}
if (defined $vals->{score}) {
$self->{score} = $vals->{score};
}
if (defined $vals->{fetchResult}) {
$self->{fetchResult} = $vals->{fetchResult};
}
if (defined $vals->{sortFieldResults}) {
$self->{sortFieldResults} = $vals->{sortFieldResults};
}
}
return bless ($self, $classname);
}
sub getName {
return 'BlurResult';
}
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->{locationId});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::DOUBLE) {
$xfer += $input->readDouble(\$self->{score});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::STRUCT) {
$self->{fetchResult} = new Blur::FetchResult();
$xfer += $self->{fetchResult}->read($input);
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::LIST) {
{
my $_size67 = 0;
$self->{sortFieldResults} = [];
my $_etype70 = 0;
$xfer += $input->readListBegin(\$_etype70, \$_size67);
for (my $_i71 = 0; $_i71 < $_size67; ++$_i71)
{
my $elem72 = undef;
$elem72 = new Blur::SortFieldResult();
$xfer += $elem72->read($input);
push(@{$self->{sortFieldResults}},$elem72);
}
$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('BlurResult');
if (defined $self->{locationId}) {
$xfer += $output->writeFieldBegin('locationId', TType::STRING, 1);
$xfer += $output->writeString($self->{locationId});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{score}) {
$xfer += $output->writeFieldBegin('score', TType::DOUBLE, 2);
$xfer += $output->writeDouble($self->{score});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{fetchResult}) {
$xfer += $output->writeFieldBegin('fetchResult', TType::STRUCT, 3);
$xfer += $self->{fetchResult}->write($output);
$xfer += $output->writeFieldEnd();
}
if (defined $self->{sortFieldResults}) {
$xfer += $output->writeFieldBegin('sortFieldResults', TType::LIST, 4);
{
$xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{sortFieldResults}}));
{
foreach my $iter73 (@{$self->{sortFieldResults}})
{
$xfer += ${iter73}->write($output);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::BlurResults;
use base qw(Class::Accessor);
Blur::BlurResults->mk_accessors( qw( totalResults shardInfo results facetCounts exceptions query ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{totalResults} = 0;
$self->{shardInfo} = undef;
$self->{results} = undef;
$self->{facetCounts} = undef;
$self->{exceptions} = undef;
$self->{query} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{totalResults}) {
$self->{totalResults} = $vals->{totalResults};
}
if (defined $vals->{shardInfo}) {
$self->{shardInfo} = $vals->{shardInfo};
}
if (defined $vals->{results}) {
$self->{results} = $vals->{results};
}
if (defined $vals->{facetCounts}) {
$self->{facetCounts} = $vals->{facetCounts};
}
if (defined $vals->{exceptions}) {
$self->{exceptions} = $vals->{exceptions};
}
if (defined $vals->{query}) {
$self->{query} = $vals->{query};
}
}
return bless ($self, $classname);
}
sub getName {
return 'BlurResults';
}
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::I64) {
$xfer += $input->readI64(\$self->{totalResults});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::MAP) {
{
my $_size74 = 0;
$self->{shardInfo} = {};
my $_ktype75 = 0;
my $_vtype76 = 0;
$xfer += $input->readMapBegin(\$_ktype75, \$_vtype76, \$_size74);
for (my $_i78 = 0; $_i78 < $_size74; ++$_i78)
{
my $key79 = '';
my $val80 = 0;
$xfer += $input->readString(\$key79);
$xfer += $input->readI64(\$val80);
$self->{shardInfo}->{$key79} = $val80;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::LIST) {
{
my $_size81 = 0;
$self->{results} = [];
my $_etype84 = 0;
$xfer += $input->readListBegin(\$_etype84, \$_size81);
for (my $_i85 = 0; $_i85 < $_size81; ++$_i85)
{
my $elem86 = undef;
$elem86 = new Blur::BlurResult();
$xfer += $elem86->read($input);
push(@{$self->{results}},$elem86);
}
$xfer += $input->readListEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::LIST) {
{
my $_size87 = 0;
$self->{facetCounts} = [];
my $_etype90 = 0;
$xfer += $input->readListBegin(\$_etype90, \$_size87);
for (my $_i91 = 0; $_i91 < $_size87; ++$_i91)
{
my $elem92 = undef;
$xfer += $input->readI64(\$elem92);
push(@{$self->{facetCounts}},$elem92);
}
$xfer += $input->readListEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::LIST) {
{
my $_size93 = 0;
$self->{exceptions} = [];
my $_etype96 = 0;
$xfer += $input->readListBegin(\$_etype96, \$_size93);
for (my $_i97 = 0; $_i97 < $_size93; ++$_i97)
{
my $elem98 = undef;
$elem98 = new Blur::BlurException();
$xfer += $elem98->read($input);
push(@{$self->{exceptions}},$elem98);
}
$xfer += $input->readListEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^6$/ && do{ if ($ftype == TType::STRUCT) {
$self->{query} = new Blur::BlurQuery();
$xfer += $self->{query}->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('BlurResults');
if (defined $self->{totalResults}) {
$xfer += $output->writeFieldBegin('totalResults', TType::I64, 1);
$xfer += $output->writeI64($self->{totalResults});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{shardInfo}) {
$xfer += $output->writeFieldBegin('shardInfo', TType::MAP, 2);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::I64, scalar(keys %{$self->{shardInfo}}));
{
while( my ($kiter99,$viter100) = each %{$self->{shardInfo}})
{
$xfer += $output->writeString($kiter99);
$xfer += $output->writeI64($viter100);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{results}) {
$xfer += $output->writeFieldBegin('results', TType::LIST, 3);
{
$xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{results}}));
{
foreach my $iter101 (@{$self->{results}})
{
$xfer += ${iter101}->write($output);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{facetCounts}) {
$xfer += $output->writeFieldBegin('facetCounts', TType::LIST, 4);
{
$xfer += $output->writeListBegin(TType::I64, scalar(@{$self->{facetCounts}}));
{
foreach my $iter102 (@{$self->{facetCounts}})
{
$xfer += $output->writeI64($iter102);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{exceptions}) {
$xfer += $output->writeFieldBegin('exceptions', TType::LIST, 5);
{
$xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{exceptions}}));
{
foreach my $iter103 (@{$self->{exceptions}})
{
$xfer += ${iter103}->write($output);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{query}) {
$xfer += $output->writeFieldBegin('query', TType::STRUCT, 6);
$xfer += $self->{query}->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::RecordMutation;
use base qw(Class::Accessor);
Blur::RecordMutation->mk_accessors( qw( recordMutationType record ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{recordMutationType} = 1;
$self->{record} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{recordMutationType}) {
$self->{recordMutationType} = $vals->{recordMutationType};
}
if (defined $vals->{record}) {
$self->{record} = $vals->{record};
}
}
return bless ($self, $classname);
}
sub getName {
return 'RecordMutation';
}
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::I32) {
$xfer += $input->readI32(\$self->{recordMutationType});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRUCT) {
$self->{record} = new Blur::Record();
$xfer += $self->{record}->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('RecordMutation');
if (defined $self->{recordMutationType}) {
$xfer += $output->writeFieldBegin('recordMutationType', TType::I32, 1);
$xfer += $output->writeI32($self->{recordMutationType});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{record}) {
$xfer += $output->writeFieldBegin('record', TType::STRUCT, 2);
$xfer += $self->{record}->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::RowMutation;
use base qw(Class::Accessor);
Blur::RowMutation->mk_accessors( qw( table rowId rowMutationType recordMutations ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{table} = undef;
$self->{rowId} = undef;
$self->{rowMutationType} = 1;
$self->{recordMutations} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{table}) {
$self->{table} = $vals->{table};
}
if (defined $vals->{rowId}) {
$self->{rowId} = $vals->{rowId};
}
if (defined $vals->{rowMutationType}) {
$self->{rowMutationType} = $vals->{rowMutationType};
}
if (defined $vals->{recordMutations}) {
$self->{recordMutations} = $vals->{recordMutations};
}
}
return bless ($self, $classname);
}
sub getName {
return 'RowMutation';
}
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->{table});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{rowId});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{rowMutationType});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::LIST) {
{
my $_size104 = 0;
$self->{recordMutations} = [];
my $_etype107 = 0;
$xfer += $input->readListBegin(\$_etype107, \$_size104);
for (my $_i108 = 0; $_i108 < $_size104; ++$_i108)
{
my $elem109 = undef;
$elem109 = new Blur::RecordMutation();
$xfer += $elem109->read($input);
push(@{$self->{recordMutations}},$elem109);
}
$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('RowMutation');
if (defined $self->{table}) {
$xfer += $output->writeFieldBegin('table', TType::STRING, 1);
$xfer += $output->writeString($self->{table});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{rowId}) {
$xfer += $output->writeFieldBegin('rowId', TType::STRING, 2);
$xfer += $output->writeString($self->{rowId});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{rowMutationType}) {
$xfer += $output->writeFieldBegin('rowMutationType', TType::I32, 4);
$xfer += $output->writeI32($self->{rowMutationType});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{recordMutations}) {
$xfer += $output->writeFieldBegin('recordMutations', TType::LIST, 5);
{
$xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{recordMutations}}));
{
foreach my $iter110 (@{$self->{recordMutations}})
{
$xfer += ${iter110}->write($output);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::CpuTime;
use base qw(Class::Accessor);
Blur::CpuTime->mk_accessors( qw( cpuTime realTime ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{cpuTime} = undef;
$self->{realTime} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{cpuTime}) {
$self->{cpuTime} = $vals->{cpuTime};
}
if (defined $vals->{realTime}) {
$self->{realTime} = $vals->{realTime};
}
}
return bless ($self, $classname);
}
sub getName {
return 'CpuTime';
}
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::I64) {
$xfer += $input->readI64(\$self->{cpuTime});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{realTime});
} 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('CpuTime');
if (defined $self->{cpuTime}) {
$xfer += $output->writeFieldBegin('cpuTime', TType::I64, 1);
$xfer += $output->writeI64($self->{cpuTime});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{realTime}) {
$xfer += $output->writeFieldBegin('realTime', TType::I64, 2);
$xfer += $output->writeI64($self->{realTime});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::BlurQueryStatus;
use base qw(Class::Accessor);
Blur::BlurQueryStatus->mk_accessors( qw( query cpuTimes completeShards totalShards state uuid status user ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{query} = undef;
$self->{cpuTimes} = undef;
$self->{completeShards} = undef;
$self->{totalShards} = undef;
$self->{state} = undef;
$self->{uuid} = undef;
$self->{status} = undef;
$self->{user} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{query}) {
$self->{query} = $vals->{query};
}
if (defined $vals->{cpuTimes}) {
$self->{cpuTimes} = $vals->{cpuTimes};
}
if (defined $vals->{completeShards}) {
$self->{completeShards} = $vals->{completeShards};
}
if (defined $vals->{totalShards}) {
$self->{totalShards} = $vals->{totalShards};
}
if (defined $vals->{state}) {
$self->{state} = $vals->{state};
}
if (defined $vals->{uuid}) {
$self->{uuid} = $vals->{uuid};
}
if (defined $vals->{status}) {
$self->{status} = $vals->{status};
}
if (defined $vals->{user}) {
$self->{user} = $vals->{user};
}
}
return bless ($self, $classname);
}
sub getName {
return 'BlurQueryStatus';
}
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->{query} = new Blur::BlurQuery();
$xfer += $self->{query}->read($input);
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::MAP) {
{
my $_size111 = 0;
$self->{cpuTimes} = {};
my $_ktype112 = 0;
my $_vtype113 = 0;
$xfer += $input->readMapBegin(\$_ktype112, \$_vtype113, \$_size111);
for (my $_i115 = 0; $_i115 < $_size111; ++$_i115)
{
my $key116 = '';
my $val117 = new Blur::CpuTime();
$xfer += $input->readString(\$key116);
$val117 = new Blur::CpuTime();
$xfer += $val117->read($input);
$self->{cpuTimes}->{$key116} = $val117;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{completeShards});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{totalShards});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{state});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^6$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{uuid});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^7$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{status});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^8$/ && do{ if ($ftype == TType::STRUCT) {
$self->{user} = new Blur::User();
$xfer += $self->{user}->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('BlurQueryStatus');
if (defined $self->{query}) {
$xfer += $output->writeFieldBegin('query', TType::STRUCT, 1);
$xfer += $self->{query}->write($output);
$xfer += $output->writeFieldEnd();
}
if (defined $self->{cpuTimes}) {
$xfer += $output->writeFieldBegin('cpuTimes', TType::MAP, 2);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::STRUCT, scalar(keys %{$self->{cpuTimes}}));
{
while( my ($kiter118,$viter119) = each %{$self->{cpuTimes}})
{
$xfer += $output->writeString($kiter118);
$xfer += ${viter119}->write($output);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{completeShards}) {
$xfer += $output->writeFieldBegin('completeShards', TType::I32, 3);
$xfer += $output->writeI32($self->{completeShards});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{totalShards}) {
$xfer += $output->writeFieldBegin('totalShards', TType::I32, 4);
$xfer += $output->writeI32($self->{totalShards});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{state}) {
$xfer += $output->writeFieldBegin('state', TType::I32, 5);
$xfer += $output->writeI32($self->{state});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{uuid}) {
$xfer += $output->writeFieldBegin('uuid', TType::STRING, 6);
$xfer += $output->writeString($self->{uuid});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{status}) {
$xfer += $output->writeFieldBegin('status', TType::I32, 7);
$xfer += $output->writeI32($self->{status});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{user}) {
$xfer += $output->writeFieldBegin('user', TType::STRUCT, 8);
$xfer += $self->{user}->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::TableStats;
use base qw(Class::Accessor);
Blur::TableStats->mk_accessors( qw( tableName bytes recordCount rowCount segmentImportPendingCount segmentImportInProgressCount ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{tableName} = undef;
$self->{bytes} = undef;
$self->{recordCount} = undef;
$self->{rowCount} = undef;
$self->{segmentImportPendingCount} = 0;
$self->{segmentImportInProgressCount} = 0;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{tableName}) {
$self->{tableName} = $vals->{tableName};
}
if (defined $vals->{bytes}) {
$self->{bytes} = $vals->{bytes};
}
if (defined $vals->{recordCount}) {
$self->{recordCount} = $vals->{recordCount};
}
if (defined $vals->{rowCount}) {
$self->{rowCount} = $vals->{rowCount};
}
if (defined $vals->{segmentImportPendingCount}) {
$self->{segmentImportPendingCount} = $vals->{segmentImportPendingCount};
}
if (defined $vals->{segmentImportInProgressCount}) {
$self->{segmentImportInProgressCount} = $vals->{segmentImportInProgressCount};
}
}
return bless ($self, $classname);
}
sub getName {
return 'TableStats';
}
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::I64) {
$xfer += $input->readI64(\$self->{bytes});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{recordCount});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{rowCount});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{segmentImportPendingCount});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^6$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{segmentImportInProgressCount});
} 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('TableStats');
if (defined $self->{tableName}) {
$xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
$xfer += $output->writeString($self->{tableName});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{bytes}) {
$xfer += $output->writeFieldBegin('bytes', TType::I64, 2);
$xfer += $output->writeI64($self->{bytes});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{recordCount}) {
$xfer += $output->writeFieldBegin('recordCount', TType::I64, 3);
$xfer += $output->writeI64($self->{recordCount});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{rowCount}) {
$xfer += $output->writeFieldBegin('rowCount', TType::I64, 4);
$xfer += $output->writeI64($self->{rowCount});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{segmentImportPendingCount}) {
$xfer += $output->writeFieldBegin('segmentImportPendingCount', TType::I64, 5);
$xfer += $output->writeI64($self->{segmentImportPendingCount});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{segmentImportInProgressCount}) {
$xfer += $output->writeFieldBegin('segmentImportInProgressCount', TType::I64, 6);
$xfer += $output->writeI64($self->{segmentImportInProgressCount});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::ColumnDefinition;
use base qw(Class::Accessor);
Blur::ColumnDefinition->mk_accessors( qw( family columnName subColumnName fieldLessIndexed fieldType properties sortable multiValueField ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{family} = undef;
$self->{columnName} = undef;
$self->{subColumnName} = undef;
$self->{fieldLessIndexed} = undef;
$self->{fieldType} = undef;
$self->{properties} = undef;
$self->{sortable} = undef;
$self->{multiValueField} = 1;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{family}) {
$self->{family} = $vals->{family};
}
if (defined $vals->{columnName}) {
$self->{columnName} = $vals->{columnName};
}
if (defined $vals->{subColumnName}) {
$self->{subColumnName} = $vals->{subColumnName};
}
if (defined $vals->{fieldLessIndexed}) {
$self->{fieldLessIndexed} = $vals->{fieldLessIndexed};
}
if (defined $vals->{fieldType}) {
$self->{fieldType} = $vals->{fieldType};
}
if (defined $vals->{properties}) {
$self->{properties} = $vals->{properties};
}
if (defined $vals->{sortable}) {
$self->{sortable} = $vals->{sortable};
}
if (defined $vals->{multiValueField}) {
$self->{multiValueField} = $vals->{multiValueField};
}
}
return bless ($self, $classname);
}
sub getName {
return 'ColumnDefinition';
}
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->{family});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{columnName});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{subColumnName});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{fieldLessIndexed});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{fieldType});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^6$/ && do{ if ($ftype == TType::MAP) {
{
my $_size120 = 0;
$self->{properties} = {};
my $_ktype121 = 0;
my $_vtype122 = 0;
$xfer += $input->readMapBegin(\$_ktype121, \$_vtype122, \$_size120);
for (my $_i124 = 0; $_i124 < $_size120; ++$_i124)
{
my $key125 = '';
my $val126 = '';
$xfer += $input->readString(\$key125);
$xfer += $input->readString(\$val126);
$self->{properties}->{$key125} = $val126;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^7$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{sortable});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^8$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{multiValueField});
} 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('ColumnDefinition');
if (defined $self->{family}) {
$xfer += $output->writeFieldBegin('family', TType::STRING, 1);
$xfer += $output->writeString($self->{family});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{columnName}) {
$xfer += $output->writeFieldBegin('columnName', TType::STRING, 2);
$xfer += $output->writeString($self->{columnName});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{subColumnName}) {
$xfer += $output->writeFieldBegin('subColumnName', TType::STRING, 3);
$xfer += $output->writeString($self->{subColumnName});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{fieldLessIndexed}) {
$xfer += $output->writeFieldBegin('fieldLessIndexed', TType::BOOL, 4);
$xfer += $output->writeBool($self->{fieldLessIndexed});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{fieldType}) {
$xfer += $output->writeFieldBegin('fieldType', TType::STRING, 5);
$xfer += $output->writeString($self->{fieldType});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{properties}) {
$xfer += $output->writeFieldBegin('properties', TType::MAP, 6);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{properties}}));
{
while( my ($kiter127,$viter128) = each %{$self->{properties}})
{
$xfer += $output->writeString($kiter127);
$xfer += $output->writeString($viter128);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{sortable}) {
$xfer += $output->writeFieldBegin('sortable', TType::BOOL, 7);
$xfer += $output->writeBool($self->{sortable});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{multiValueField}) {
$xfer += $output->writeFieldBegin('multiValueField', TType::BOOL, 8);
$xfer += $output->writeBool($self->{multiValueField});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Schema;
use base qw(Class::Accessor);
Blur::Schema->mk_accessors( qw( table families ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{table} = undef;
$self->{families} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{table}) {
$self->{table} = $vals->{table};
}
if (defined $vals->{families}) {
$self->{families} = $vals->{families};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Schema';
}
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->{table});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::MAP) {
{
my $_size129 = 0;
$self->{families} = {};
my $_ktype130 = 0;
my $_vtype131 = 0;
$xfer += $input->readMapBegin(\$_ktype130, \$_vtype131, \$_size129);
for (my $_i133 = 0; $_i133 < $_size129; ++$_i133)
{
my $key134 = '';
my $val135 = [];
$xfer += $input->readString(\$key134);
{
my $_size136 = 0;
$val135 = {};
my $_ktype137 = 0;
my $_vtype138 = 0;
$xfer += $input->readMapBegin(\$_ktype137, \$_vtype138, \$_size136);
for (my $_i140 = 0; $_i140 < $_size136; ++$_i140)
{
my $key141 = '';
my $val142 = new Blur::ColumnDefinition();
$xfer += $input->readString(\$key141);
$val142 = new Blur::ColumnDefinition();
$xfer += $val142->read($input);
$val135->{$key141} = $val142;
}
$xfer += $input->readMapEnd();
}
$self->{families}->{$key134} = $val135;
}
$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('Schema');
if (defined $self->{table}) {
$xfer += $output->writeFieldBegin('table', TType::STRING, 1);
$xfer += $output->writeString($self->{table});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{families}) {
$xfer += $output->writeFieldBegin('families', TType::MAP, 2);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::MAP, scalar(keys %{$self->{families}}));
{
while( my ($kiter143,$viter144) = each %{$self->{families}})
{
$xfer += $output->writeString($kiter143);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::STRUCT, scalar(keys %{${viter144}}));
{
while( my ($kiter145,$viter146) = each %{${viter144}})
{
$xfer += $output->writeString($kiter145);
$xfer += ${viter146}->write($output);
}
}
$xfer += $output->writeMapEnd();
}
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::TableDescriptor;
use base qw(Class::Accessor);
Blur::TableDescriptor->mk_accessors( qw( enabled shardCount tableUri cluster name similarityClass blockCaching blockCachingFileTypes readOnly preCacheCols tableProperties strictTypes defaultMissingFieldType defaultMissingFieldLessIndexing defaultMissingFieldProps ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{enabled} = 1;
$self->{shardCount} = 1;
$self->{tableUri} = undef;
$self->{cluster} = "default";
$self->{name} = undef;
$self->{similarityClass} = undef;
$self->{blockCaching} = 1;
$self->{blockCachingFileTypes} = undef;
$self->{readOnly} = 0;
$self->{preCacheCols} = undef;
$self->{tableProperties} = undef;
$self->{strictTypes} = 0;
$self->{defaultMissingFieldType} = "text";
$self->{defaultMissingFieldLessIndexing} = 1;
$self->{defaultMissingFieldProps} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{enabled}) {
$self->{enabled} = $vals->{enabled};
}
if (defined $vals->{shardCount}) {
$self->{shardCount} = $vals->{shardCount};
}
if (defined $vals->{tableUri}) {
$self->{tableUri} = $vals->{tableUri};
}
if (defined $vals->{cluster}) {
$self->{cluster} = $vals->{cluster};
}
if (defined $vals->{name}) {
$self->{name} = $vals->{name};
}
if (defined $vals->{similarityClass}) {
$self->{similarityClass} = $vals->{similarityClass};
}
if (defined $vals->{blockCaching}) {
$self->{blockCaching} = $vals->{blockCaching};
}
if (defined $vals->{blockCachingFileTypes}) {
$self->{blockCachingFileTypes} = $vals->{blockCachingFileTypes};
}
if (defined $vals->{readOnly}) {
$self->{readOnly} = $vals->{readOnly};
}
if (defined $vals->{preCacheCols}) {
$self->{preCacheCols} = $vals->{preCacheCols};
}
if (defined $vals->{tableProperties}) {
$self->{tableProperties} = $vals->{tableProperties};
}
if (defined $vals->{strictTypes}) {
$self->{strictTypes} = $vals->{strictTypes};
}
if (defined $vals->{defaultMissingFieldType}) {
$self->{defaultMissingFieldType} = $vals->{defaultMissingFieldType};
}
if (defined $vals->{defaultMissingFieldLessIndexing}) {
$self->{defaultMissingFieldLessIndexing} = $vals->{defaultMissingFieldLessIndexing};
}
if (defined $vals->{defaultMissingFieldProps}) {
$self->{defaultMissingFieldProps} = $vals->{defaultMissingFieldProps};
}
}
return bless ($self, $classname);
}
sub getName {
return 'TableDescriptor';
}
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::BOOL) {
$xfer += $input->readBool(\$self->{enabled});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{shardCount});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{tableUri});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^7$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{cluster});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^8$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{name});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^9$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{similarityClass});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^10$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{blockCaching});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^11$/ && do{ if ($ftype == TType::SET) {
{
my $_size147 = 0;
$self->{blockCachingFileTypes} = {};
my $_etype150 = 0;
$xfer += $input->readSetBegin(\$_etype150, \$_size147);
for (my $_i151 = 0; $_i151 < $_size147; ++$_i151)
{
my $elem152 = undef;
$xfer += $input->readString(\$elem152);
$self->{blockCachingFileTypes}->{$elem152} = 1;
}
$xfer += $input->readSetEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^12$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{readOnly});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^13$/ && do{ if ($ftype == TType::LIST) {
{
my $_size153 = 0;
$self->{preCacheCols} = [];
my $_etype156 = 0;
$xfer += $input->readListBegin(\$_etype156, \$_size153);
for (my $_i157 = 0; $_i157 < $_size153; ++$_i157)
{
my $elem158 = undef;
$xfer += $input->readString(\$elem158);
push(@{$self->{preCacheCols}},$elem158);
}
$xfer += $input->readListEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^14$/ && do{ if ($ftype == TType::MAP) {
{
my $_size159 = 0;
$self->{tableProperties} = {};
my $_ktype160 = 0;
my $_vtype161 = 0;
$xfer += $input->readMapBegin(\$_ktype160, \$_vtype161, \$_size159);
for (my $_i163 = 0; $_i163 < $_size159; ++$_i163)
{
my $key164 = '';
my $val165 = '';
$xfer += $input->readString(\$key164);
$xfer += $input->readString(\$val165);
$self->{tableProperties}->{$key164} = $val165;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^15$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{strictTypes});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^16$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{defaultMissingFieldType});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^17$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{defaultMissingFieldLessIndexing});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^18$/ && do{ if ($ftype == TType::MAP) {
{
my $_size166 = 0;
$self->{defaultMissingFieldProps} = {};
my $_ktype167 = 0;
my $_vtype168 = 0;
$xfer += $input->readMapBegin(\$_ktype167, \$_vtype168, \$_size166);
for (my $_i170 = 0; $_i170 < $_size166; ++$_i170)
{
my $key171 = '';
my $val172 = '';
$xfer += $input->readString(\$key171);
$xfer += $input->readString(\$val172);
$self->{defaultMissingFieldProps}->{$key171} = $val172;
}
$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('TableDescriptor');
if (defined $self->{enabled}) {
$xfer += $output->writeFieldBegin('enabled', TType::BOOL, 1);
$xfer += $output->writeBool($self->{enabled});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{shardCount}) {
$xfer += $output->writeFieldBegin('shardCount', TType::I32, 3);
$xfer += $output->writeI32($self->{shardCount});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{tableUri}) {
$xfer += $output->writeFieldBegin('tableUri', TType::STRING, 4);
$xfer += $output->writeString($self->{tableUri});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{cluster}) {
$xfer += $output->writeFieldBegin('cluster', TType::STRING, 7);
$xfer += $output->writeString($self->{cluster});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{name}) {
$xfer += $output->writeFieldBegin('name', TType::STRING, 8);
$xfer += $output->writeString($self->{name});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{similarityClass}) {
$xfer += $output->writeFieldBegin('similarityClass', TType::STRING, 9);
$xfer += $output->writeString($self->{similarityClass});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{blockCaching}) {
$xfer += $output->writeFieldBegin('blockCaching', TType::BOOL, 10);
$xfer += $output->writeBool($self->{blockCaching});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{blockCachingFileTypes}) {
$xfer += $output->writeFieldBegin('blockCachingFileTypes', TType::SET, 11);
{
$xfer += $output->writeSetBegin(TType::STRING, scalar(@{$self->{blockCachingFileTypes}}));
{
foreach my $iter173 (@{$self->{blockCachingFileTypes}})
{
$xfer += $output->writeString($iter173);
}
}
$xfer += $output->writeSetEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{readOnly}) {
$xfer += $output->writeFieldBegin('readOnly', TType::BOOL, 12);
$xfer += $output->writeBool($self->{readOnly});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{preCacheCols}) {
$xfer += $output->writeFieldBegin('preCacheCols', TType::LIST, 13);
{
$xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{preCacheCols}}));
{
foreach my $iter174 (@{$self->{preCacheCols}})
{
$xfer += $output->writeString($iter174);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{tableProperties}) {
$xfer += $output->writeFieldBegin('tableProperties', TType::MAP, 14);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{tableProperties}}));
{
while( my ($kiter175,$viter176) = each %{$self->{tableProperties}})
{
$xfer += $output->writeString($kiter175);
$xfer += $output->writeString($viter176);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{strictTypes}) {
$xfer += $output->writeFieldBegin('strictTypes', TType::BOOL, 15);
$xfer += $output->writeBool($self->{strictTypes});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{defaultMissingFieldType}) {
$xfer += $output->writeFieldBegin('defaultMissingFieldType', TType::STRING, 16);
$xfer += $output->writeString($self->{defaultMissingFieldType});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{defaultMissingFieldLessIndexing}) {
$xfer += $output->writeFieldBegin('defaultMissingFieldLessIndexing', TType::BOOL, 17);
$xfer += $output->writeBool($self->{defaultMissingFieldLessIndexing});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{defaultMissingFieldProps}) {
$xfer += $output->writeFieldBegin('defaultMissingFieldProps', TType::MAP, 18);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{defaultMissingFieldProps}}));
{
while( my ($kiter177,$viter178) = each %{$self->{defaultMissingFieldProps}})
{
$xfer += $output->writeString($kiter177);
$xfer += $output->writeString($viter178);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Metric;
use base qw(Class::Accessor);
Blur::Metric->mk_accessors( qw( name strMap longMap doubleMap ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{name} = undef;
$self->{strMap} = undef;
$self->{longMap} = undef;
$self->{doubleMap} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{name}) {
$self->{name} = $vals->{name};
}
if (defined $vals->{strMap}) {
$self->{strMap} = $vals->{strMap};
}
if (defined $vals->{longMap}) {
$self->{longMap} = $vals->{longMap};
}
if (defined $vals->{doubleMap}) {
$self->{doubleMap} = $vals->{doubleMap};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Metric';
}
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->{name});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::MAP) {
{
my $_size179 = 0;
$self->{strMap} = {};
my $_ktype180 = 0;
my $_vtype181 = 0;
$xfer += $input->readMapBegin(\$_ktype180, \$_vtype181, \$_size179);
for (my $_i183 = 0; $_i183 < $_size179; ++$_i183)
{
my $key184 = '';
my $val185 = '';
$xfer += $input->readString(\$key184);
$xfer += $input->readString(\$val185);
$self->{strMap}->{$key184} = $val185;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::MAP) {
{
my $_size186 = 0;
$self->{longMap} = {};
my $_ktype187 = 0;
my $_vtype188 = 0;
$xfer += $input->readMapBegin(\$_ktype187, \$_vtype188, \$_size186);
for (my $_i190 = 0; $_i190 < $_size186; ++$_i190)
{
my $key191 = '';
my $val192 = 0;
$xfer += $input->readString(\$key191);
$xfer += $input->readI64(\$val192);
$self->{longMap}->{$key191} = $val192;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::MAP) {
{
my $_size193 = 0;
$self->{doubleMap} = {};
my $_ktype194 = 0;
my $_vtype195 = 0;
$xfer += $input->readMapBegin(\$_ktype194, \$_vtype195, \$_size193);
for (my $_i197 = 0; $_i197 < $_size193; ++$_i197)
{
my $key198 = '';
my $val199 = 0.0;
$xfer += $input->readString(\$key198);
$xfer += $input->readDouble(\$val199);
$self->{doubleMap}->{$key198} = $val199;
}
$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('Metric');
if (defined $self->{name}) {
$xfer += $output->writeFieldBegin('name', TType::STRING, 1);
$xfer += $output->writeString($self->{name});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{strMap}) {
$xfer += $output->writeFieldBegin('strMap', TType::MAP, 2);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{strMap}}));
{
while( my ($kiter200,$viter201) = each %{$self->{strMap}})
{
$xfer += $output->writeString($kiter200);
$xfer += $output->writeString($viter201);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{longMap}) {
$xfer += $output->writeFieldBegin('longMap', TType::MAP, 3);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::I64, scalar(keys %{$self->{longMap}}));
{
while( my ($kiter202,$viter203) = each %{$self->{longMap}})
{
$xfer += $output->writeString($kiter202);
$xfer += $output->writeI64($viter203);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{doubleMap}) {
$xfer += $output->writeFieldBegin('doubleMap', TType::MAP, 4);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::DOUBLE, scalar(keys %{$self->{doubleMap}}));
{
while( my ($kiter204,$viter205) = each %{$self->{doubleMap}})
{
$xfer += $output->writeString($kiter204);
$xfer += $output->writeDouble($viter205);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Value;
use base qw(Class::Accessor);
Blur::Value->mk_accessors( qw( stringValue intValue shortValue longValue doubleValue floatValue binaryValue booleanValue nullValue ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{stringValue} = undef;
$self->{intValue} = undef;
$self->{shortValue} = undef;
$self->{longValue} = undef;
$self->{doubleValue} = undef;
$self->{floatValue} = undef;
$self->{binaryValue} = undef;
$self->{booleanValue} = undef;
$self->{nullValue} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{stringValue}) {
$self->{stringValue} = $vals->{stringValue};
}
if (defined $vals->{intValue}) {
$self->{intValue} = $vals->{intValue};
}
if (defined $vals->{shortValue}) {
$self->{shortValue} = $vals->{shortValue};
}
if (defined $vals->{longValue}) {
$self->{longValue} = $vals->{longValue};
}
if (defined $vals->{doubleValue}) {
$self->{doubleValue} = $vals->{doubleValue};
}
if (defined $vals->{floatValue}) {
$self->{floatValue} = $vals->{floatValue};
}
if (defined $vals->{binaryValue}) {
$self->{binaryValue} = $vals->{binaryValue};
}
if (defined $vals->{booleanValue}) {
$self->{booleanValue} = $vals->{booleanValue};
}
if (defined $vals->{nullValue}) {
$self->{nullValue} = $vals->{nullValue};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Value';
}
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->{stringValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{intValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::I16) {
$xfer += $input->readI16(\$self->{shortValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::I64) {
$xfer += $input->readI64(\$self->{longValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::DOUBLE) {
$xfer += $input->readDouble(\$self->{doubleValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^6$/ && do{ if ($ftype == TType::DOUBLE) {
$xfer += $input->readDouble(\$self->{floatValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^7$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{binaryValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^8$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{booleanValue});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^9$/ && do{ if ($ftype == TType::BOOL) {
$xfer += $input->readBool(\$self->{nullValue});
} 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('Value');
if (defined $self->{stringValue}) {
$xfer += $output->writeFieldBegin('stringValue', TType::STRING, 1);
$xfer += $output->writeString($self->{stringValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{intValue}) {
$xfer += $output->writeFieldBegin('intValue', TType::I32, 2);
$xfer += $output->writeI32($self->{intValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{shortValue}) {
$xfer += $output->writeFieldBegin('shortValue', TType::I16, 3);
$xfer += $output->writeI16($self->{shortValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{longValue}) {
$xfer += $output->writeFieldBegin('longValue', TType::I64, 4);
$xfer += $output->writeI64($self->{longValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{doubleValue}) {
$xfer += $output->writeFieldBegin('doubleValue', TType::DOUBLE, 5);
$xfer += $output->writeDouble($self->{doubleValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{floatValue}) {
$xfer += $output->writeFieldBegin('floatValue', TType::DOUBLE, 6);
$xfer += $output->writeDouble($self->{floatValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{binaryValue}) {
$xfer += $output->writeFieldBegin('binaryValue', TType::STRING, 7);
$xfer += $output->writeString($self->{binaryValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{booleanValue}) {
$xfer += $output->writeFieldBegin('booleanValue', TType::BOOL, 8);
$xfer += $output->writeBool($self->{booleanValue});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{nullValue}) {
$xfer += $output->writeFieldBegin('nullValue', TType::BOOL, 9);
$xfer += $output->writeBool($self->{nullValue});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Shard;
use base qw(Class::Accessor);
Blur::Shard->mk_accessors( qw( table shard ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{table} = undef;
$self->{shard} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{table}) {
$self->{table} = $vals->{table};
}
if (defined $vals->{shard}) {
$self->{shard} = $vals->{shard};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Shard';
}
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->{table});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{shard});
} 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('Shard');
if (defined $self->{table}) {
$xfer += $output->writeFieldBegin('table', TType::STRING, 1);
$xfer += $output->writeString($self->{table});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{shard}) {
$xfer += $output->writeFieldBegin('shard', TType::STRING, 2);
$xfer += $output->writeString($self->{shard});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Server;
use base qw(Class::Accessor);
Blur::Server->mk_accessors( qw( server ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{server} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{server}) {
$self->{server} = $vals->{server};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Server';
}
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->{server});
} 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('Server');
if (defined $self->{server}) {
$xfer += $output->writeFieldBegin('server', TType::STRING, 1);
$xfer += $output->writeString($self->{server});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::BlurPackedObject;
use base qw(Class::Accessor);
Blur::BlurPackedObject->mk_accessors( qw( parentId type value ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{parentId} = undef;
$self->{type} = undef;
$self->{value} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{parentId}) {
$self->{parentId} = $vals->{parentId};
}
if (defined $vals->{type}) {
$self->{type} = $vals->{type};
}
if (defined $vals->{value}) {
$self->{value} = $vals->{value};
}
}
return bless ($self, $classname);
}
sub getName {
return 'BlurPackedObject';
}
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::I32) {
$xfer += $input->readI32(\$self->{parentId});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::I32) {
$xfer += $input->readI32(\$self->{type});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::STRUCT) {
$self->{value} = new Blur::Value();
$xfer += $self->{value}->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('BlurPackedObject');
if (defined $self->{parentId}) {
$xfer += $output->writeFieldBegin('parentId', TType::I32, 1);
$xfer += $output->writeI32($self->{parentId});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{type}) {
$xfer += $output->writeFieldBegin('type', TType::I32, 2);
$xfer += $output->writeI32($self->{type});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{value}) {
$xfer += $output->writeFieldBegin('value', TType::STRUCT, 3);
$xfer += $self->{value}->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::ValueObject;
use base qw(Class::Accessor);
Blur::ValueObject->mk_accessors( qw( value blurObject ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{value} = undef;
$self->{blurObject} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{value}) {
$self->{value} = $vals->{value};
}
if (defined $vals->{blurObject}) {
$self->{blurObject} = $vals->{blurObject};
}
}
return bless ($self, $classname);
}
sub getName {
return 'ValueObject';
}
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->{value} = new Blur::Value();
$xfer += $self->{value}->read($input);
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::LIST) {
{
my $_size206 = 0;
$self->{blurObject} = [];
my $_etype209 = 0;
$xfer += $input->readListBegin(\$_etype209, \$_size206);
for (my $_i210 = 0; $_i210 < $_size206; ++$_i210)
{
my $elem211 = undef;
$elem211 = new Blur::BlurPackedObject();
$xfer += $elem211->read($input);
push(@{$self->{blurObject}},$elem211);
}
$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('ValueObject');
if (defined $self->{value}) {
$xfer += $output->writeFieldBegin('value', TType::STRUCT, 1);
$xfer += $self->{value}->write($output);
$xfer += $output->writeFieldEnd();
}
if (defined $self->{blurObject}) {
$xfer += $output->writeFieldBegin('blurObject', TType::LIST, 2);
{
$xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{blurObject}}));
{
foreach my $iter212 (@{$self->{blurObject}})
{
$xfer += ${iter212}->write($output);
}
}
$xfer += $output->writeListEnd();
}
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Response;
use base qw(Class::Accessor);
Blur::Response->mk_accessors( qw( shardToValue serverToValue value ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{shardToValue} = undef;
$self->{serverToValue} = undef;
$self->{value} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{shardToValue}) {
$self->{shardToValue} = $vals->{shardToValue};
}
if (defined $vals->{serverToValue}) {
$self->{serverToValue} = $vals->{serverToValue};
}
if (defined $vals->{value}) {
$self->{value} = $vals->{value};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Response';
}
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::MAP) {
{
my $_size213 = 0;
$self->{shardToValue} = {};
my $_ktype214 = 0;
my $_vtype215 = 0;
$xfer += $input->readMapBegin(\$_ktype214, \$_vtype215, \$_size213);
for (my $_i217 = 0; $_i217 < $_size213; ++$_i217)
{
my $key218 = new Blur::Shard();
my $val219 = new Blur::ValueObject();
$key218 = new Blur::Shard();
$xfer += $key218->read($input);
$val219 = new Blur::ValueObject();
$xfer += $val219->read($input);
$self->{shardToValue}->{$key218} = $val219;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::MAP) {
{
my $_size220 = 0;
$self->{serverToValue} = {};
my $_ktype221 = 0;
my $_vtype222 = 0;
$xfer += $input->readMapBegin(\$_ktype221, \$_vtype222, \$_size220);
for (my $_i224 = 0; $_i224 < $_size220; ++$_i224)
{
my $key225 = new Blur::Server();
my $val226 = new Blur::ValueObject();
$key225 = new Blur::Server();
$xfer += $key225->read($input);
$val226 = new Blur::ValueObject();
$xfer += $val226->read($input);
$self->{serverToValue}->{$key225} = $val226;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::STRUCT) {
$self->{value} = new Blur::ValueObject();
$xfer += $self->{value}->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('Response');
if (defined $self->{shardToValue}) {
$xfer += $output->writeFieldBegin('shardToValue', TType::MAP, 1);
{
$xfer += $output->writeMapBegin(TType::STRUCT, TType::STRUCT, scalar(keys %{$self->{shardToValue}}));
{
while( my ($kiter227,$viter228) = each %{$self->{shardToValue}})
{
$xfer += ${kiter227}->write($output);
$xfer += ${viter228}->write($output);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{serverToValue}) {
$xfer += $output->writeFieldBegin('serverToValue', TType::MAP, 2);
{
$xfer += $output->writeMapBegin(TType::STRUCT, TType::STRUCT, scalar(keys %{$self->{serverToValue}}));
{
while( my ($kiter229,$viter230) = each %{$self->{serverToValue}})
{
$xfer += ${kiter229}->write($output);
$xfer += ${viter230}->write($output);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{value}) {
$xfer += $output->writeFieldBegin('value', TType::STRUCT, 3);
$xfer += $self->{value}->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::Arguments;
use base qw(Class::Accessor);
Blur::Arguments->mk_accessors( qw( values ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{values} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{values}) {
$self->{values} = $vals->{values};
}
}
return bless ($self, $classname);
}
sub getName {
return 'Arguments';
}
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::MAP) {
{
my $_size231 = 0;
$self->{values} = {};
my $_ktype232 = 0;
my $_vtype233 = 0;
$xfer += $input->readMapBegin(\$_ktype232, \$_vtype233, \$_size231);
for (my $_i235 = 0; $_i235 < $_size231; ++$_i235)
{
my $key236 = '';
my $val237 = new Blur::ValueObject();
$xfer += $input->readString(\$key236);
$val237 = new Blur::ValueObject();
$xfer += $val237->read($input);
$self->{values}->{$key236} = $val237;
}
$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('Arguments');
if (defined $self->{values}) {
$xfer += $output->writeFieldBegin('values', TType::MAP, 1);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::STRUCT, scalar(keys %{$self->{values}}));
{
while( my ($kiter238,$viter239) = each %{$self->{values}})
{
$xfer += $output->writeString($kiter238);
$xfer += ${viter239}->write($output);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::CommandStatus;
use base qw(Class::Accessor);
Blur::CommandStatus->mk_accessors( qw( executionId commandName arguments serverStateMap user ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{executionId} = undef;
$self->{commandName} = undef;
$self->{arguments} = undef;
$self->{serverStateMap} = undef;
$self->{user} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{executionId}) {
$self->{executionId} = $vals->{executionId};
}
if (defined $vals->{commandName}) {
$self->{commandName} = $vals->{commandName};
}
if (defined $vals->{arguments}) {
$self->{arguments} = $vals->{arguments};
}
if (defined $vals->{serverStateMap}) {
$self->{serverStateMap} = $vals->{serverStateMap};
}
if (defined $vals->{user}) {
$self->{user} = $vals->{user};
}
}
return bless ($self, $classname);
}
sub getName {
return 'CommandStatus';
}
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->{executionId});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{commandName});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::STRUCT) {
$self->{arguments} = new Blur::Arguments();
$xfer += $self->{arguments}->read($input);
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::MAP) {
{
my $_size240 = 0;
$self->{serverStateMap} = {};
my $_ktype241 = 0;
my $_vtype242 = 0;
$xfer += $input->readMapBegin(\$_ktype241, \$_vtype242, \$_size240);
for (my $_i244 = 0; $_i244 < $_size240; ++$_i244)
{
my $key245 = '';
my $val246 = [];
$xfer += $input->readString(\$key245);
{
my $_size247 = 0;
$val246 = {};
my $_ktype248 = 0;
my $_vtype249 = 0;
$xfer += $input->readMapBegin(\$_ktype248, \$_vtype249, \$_size247);
for (my $_i251 = 0; $_i251 < $_size247; ++$_i251)
{
my $key252 = 0;
my $val253 = 0;
$xfer += $input->readI32(\$key252);
$xfer += $input->readI64(\$val253);
$val246->{$key252} = $val253;
}
$xfer += $input->readMapEnd();
}
$self->{serverStateMap}->{$key245} = $val246;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::STRUCT) {
$self->{user} = new Blur::User();
$xfer += $self->{user}->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('CommandStatus');
if (defined $self->{executionId}) {
$xfer += $output->writeFieldBegin('executionId', TType::STRING, 1);
$xfer += $output->writeString($self->{executionId});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{commandName}) {
$xfer += $output->writeFieldBegin('commandName', TType::STRING, 2);
$xfer += $output->writeString($self->{commandName});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{arguments}) {
$xfer += $output->writeFieldBegin('arguments', TType::STRUCT, 3);
$xfer += $self->{arguments}->write($output);
$xfer += $output->writeFieldEnd();
}
if (defined $self->{serverStateMap}) {
$xfer += $output->writeFieldBegin('serverStateMap', TType::MAP, 4);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::MAP, scalar(keys %{$self->{serverStateMap}}));
{
while( my ($kiter254,$viter255) = each %{$self->{serverStateMap}})
{
$xfer += $output->writeString($kiter254);
{
$xfer += $output->writeMapBegin(TType::I32, TType::I64, scalar(keys %{${viter255}}));
{
while( my ($kiter256,$viter257) = each %{${viter255}})
{
$xfer += $output->writeI32($kiter256);
$xfer += $output->writeI64($viter257);
}
}
$xfer += $output->writeMapEnd();
}
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{user}) {
$xfer += $output->writeFieldBegin('user', TType::STRUCT, 5);
$xfer += $self->{user}->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::ArgumentDescriptor;
use base qw(Class::Accessor);
Blur::ArgumentDescriptor->mk_accessors( qw( name type description ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{name} = undef;
$self->{type} = undef;
$self->{description} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{name}) {
$self->{name} = $vals->{name};
}
if (defined $vals->{type}) {
$self->{type} = $vals->{type};
}
if (defined $vals->{description}) {
$self->{description} = $vals->{description};
}
}
return bless ($self, $classname);
}
sub getName {
return 'ArgumentDescriptor';
}
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->{name});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{type});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{description});
} 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('ArgumentDescriptor');
if (defined $self->{name}) {
$xfer += $output->writeFieldBegin('name', TType::STRING, 1);
$xfer += $output->writeString($self->{name});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{type}) {
$xfer += $output->writeFieldBegin('type', TType::STRING, 2);
$xfer += $output->writeString($self->{type});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{description}) {
$xfer += $output->writeFieldBegin('description', TType::STRING, 3);
$xfer += $output->writeString($self->{description});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
package Blur::CommandDescriptor;
use base qw(Class::Accessor);
Blur::CommandDescriptor->mk_accessors( qw( commandName description requiredArguments optionalArguments returnType version ) );
sub new {
my $classname = shift;
my $self = {};
my $vals = shift || {};
$self->{commandName} = undef;
$self->{description} = undef;
$self->{requiredArguments} = undef;
$self->{optionalArguments} = undef;
$self->{returnType} = undef;
$self->{version} = undef;
if (UNIVERSAL::isa($vals,'HASH')) {
if (defined $vals->{commandName}) {
$self->{commandName} = $vals->{commandName};
}
if (defined $vals->{description}) {
$self->{description} = $vals->{description};
}
if (defined $vals->{requiredArguments}) {
$self->{requiredArguments} = $vals->{requiredArguments};
}
if (defined $vals->{optionalArguments}) {
$self->{optionalArguments} = $vals->{optionalArguments};
}
if (defined $vals->{returnType}) {
$self->{returnType} = $vals->{returnType};
}
if (defined $vals->{version}) {
$self->{version} = $vals->{version};
}
}
return bless ($self, $classname);
}
sub getName {
return 'CommandDescriptor';
}
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->{commandName});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^2$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{description});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^3$/ && do{ if ($ftype == TType::MAP) {
{
my $_size258 = 0;
$self->{requiredArguments} = {};
my $_ktype259 = 0;
my $_vtype260 = 0;
$xfer += $input->readMapBegin(\$_ktype259, \$_vtype260, \$_size258);
for (my $_i262 = 0; $_i262 < $_size258; ++$_i262)
{
my $key263 = '';
my $val264 = new Blur::ArgumentDescriptor();
$xfer += $input->readString(\$key263);
$val264 = new Blur::ArgumentDescriptor();
$xfer += $val264->read($input);
$self->{requiredArguments}->{$key263} = $val264;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^4$/ && do{ if ($ftype == TType::MAP) {
{
my $_size265 = 0;
$self->{optionalArguments} = {};
my $_ktype266 = 0;
my $_vtype267 = 0;
$xfer += $input->readMapBegin(\$_ktype266, \$_vtype267, \$_size265);
for (my $_i269 = 0; $_i269 < $_size265; ++$_i269)
{
my $key270 = '';
my $val271 = new Blur::ArgumentDescriptor();
$xfer += $input->readString(\$key270);
$val271 = new Blur::ArgumentDescriptor();
$xfer += $val271->read($input);
$self->{optionalArguments}->{$key270} = $val271;
}
$xfer += $input->readMapEnd();
}
} else {
$xfer += $input->skip($ftype);
}
last; };
/^5$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{returnType});
} else {
$xfer += $input->skip($ftype);
}
last; };
/^6$/ && do{ if ($ftype == TType::STRING) {
$xfer += $input->readString(\$self->{version});
} 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('CommandDescriptor');
if (defined $self->{commandName}) {
$xfer += $output->writeFieldBegin('commandName', TType::STRING, 1);
$xfer += $output->writeString($self->{commandName});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{description}) {
$xfer += $output->writeFieldBegin('description', TType::STRING, 2);
$xfer += $output->writeString($self->{description});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{requiredArguments}) {
$xfer += $output->writeFieldBegin('requiredArguments', TType::MAP, 3);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::STRUCT, scalar(keys %{$self->{requiredArguments}}));
{
while( my ($kiter272,$viter273) = each %{$self->{requiredArguments}})
{
$xfer += $output->writeString($kiter272);
$xfer += ${viter273}->write($output);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{optionalArguments}) {
$xfer += $output->writeFieldBegin('optionalArguments', TType::MAP, 4);
{
$xfer += $output->writeMapBegin(TType::STRING, TType::STRUCT, scalar(keys %{$self->{optionalArguments}}));
{
while( my ($kiter274,$viter275) = each %{$self->{optionalArguments}})
{
$xfer += $output->writeString($kiter274);
$xfer += ${viter275}->write($output);
}
}
$xfer += $output->writeMapEnd();
}
$xfer += $output->writeFieldEnd();
}
if (defined $self->{returnType}) {
$xfer += $output->writeFieldBegin('returnType', TType::STRING, 5);
$xfer += $output->writeString($self->{returnType});
$xfer += $output->writeFieldEnd();
}
if (defined $self->{version}) {
$xfer += $output->writeFieldBegin('version', TType::STRING, 6);
$xfer += $output->writeString($self->{version});
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
}
1;