# # Autogenerated by Thrift # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # require 5.6.0; use strict; use warnings; use Net::GenThrift::Thrift; package Net::GenCassandra::ConsistencyLevel; use constant ZERO => 0; use constant ONE => 1; use constant QUORUM => 2; use constant DCQUORUM => 3; use constant DCQUORUMSYNC => 4; use constant ALL => 5; use constant ANY => 6; package Net::GenCassandra::AccessLevel; use constant NONE => 0; use constant READONLY => 16; use constant READWRITE => 32; use constant FULL => 64; package Net::GenCassandra::Column; use base qw(Class::Accessor); Net::GenCassandra::Column->mk_accessors( qw( name value timestamp ttl ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{name} = undef; $self->{value} = undef; $self->{timestamp} = undef; $self->{ttl} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{name}) { $self->{name} = $vals->{name}; } if (defined $vals->{value}) { $self->{value} = $vals->{value}; } if (defined $vals->{timestamp}) { $self->{timestamp} = $vals->{timestamp}; } if (defined $vals->{ttl}) { $self->{ttl} = $vals->{ttl}; } } 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; }; /^3$/ && do{ if ($ftype == TType::I64) { $xfer += $input->readI64(\$self->{timestamp}); } else { $xfer += $input->skip($ftype); } last; }; /^4$/ && do{ if ($ftype == TType::I32) { $xfer += $input->readI32(\$self->{ttl}); } 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(); } if (defined $self->{timestamp}) { $xfer += $output->writeFieldBegin('timestamp', TType::I64, 3); $xfer += $output->writeI64($self->{timestamp}); $xfer += $output->writeFieldEnd(); } if (defined $self->{ttl}) { $xfer += $output->writeFieldBegin('ttl', TType::I32, 4); $xfer += $output->writeI32($self->{ttl}); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::SuperColumn; use base qw(Class::Accessor); Net::GenCassandra::SuperColumn->mk_accessors( qw( name columns ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{name} = undef; $self->{columns} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{name}) { $self->{name} = $vals->{name}; } if (defined $vals->{columns}) { $self->{columns} = $vals->{columns}; } } return bless ($self, $classname); } sub getName { return 'SuperColumn'; } 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::LIST) { { my $_size0 = 0; $self->{columns} = []; my $_etype3 = 0; $xfer += $input->readListBegin(\$_etype3, \$_size0); for (my $_i4 = 0; $_i4 < $_size0; ++$_i4) { my $elem5 = undef; $elem5 = new Net::GenCassandra::Column(); $xfer += $elem5->read($input); push(@{$self->{columns}},$elem5); } $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('SuperColumn'); if (defined $self->{name}) { $xfer += $output->writeFieldBegin('name', TType::STRING, 1); $xfer += $output->writeString($self->{name}); $xfer += $output->writeFieldEnd(); } if (defined $self->{columns}) { $xfer += $output->writeFieldBegin('columns', TType::LIST, 2); { $output->writeListBegin(TType::STRUCT, scalar(@{$self->{columns}})); { foreach my $iter6 (@{$self->{columns}}) { $xfer += ${iter6}->write($output); } } $output->writeListEnd(); } $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::ColumnOrSuperColumn; use base qw(Class::Accessor); Net::GenCassandra::ColumnOrSuperColumn->mk_accessors( qw( column super_column ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{column} = undef; $self->{super_column} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{column}) { $self->{column} = $vals->{column}; } if (defined $vals->{super_column}) { $self->{super_column} = $vals->{super_column}; } } return bless ($self, $classname); } sub getName { return 'ColumnOrSuperColumn'; } 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->{column} = new Net::GenCassandra::Column(); $xfer += $self->{column}->read($input); } else { $xfer += $input->skip($ftype); } last; }; /^2$/ && do{ if ($ftype == TType::STRUCT) { $self->{super_column} = new Net::GenCassandra::SuperColumn(); $xfer += $self->{super_column}->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('ColumnOrSuperColumn'); if (defined $self->{column}) { $xfer += $output->writeFieldBegin('column', TType::STRUCT, 1); $xfer += $self->{column}->write($output); $xfer += $output->writeFieldEnd(); } if (defined $self->{super_column}) { $xfer += $output->writeFieldBegin('super_column', TType::STRUCT, 2); $xfer += $self->{super_column}->write($output); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::NotFoundException; use base qw(Net::GenThrift::Thrift::TException); use base qw(Class::Accessor); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; return bless ($self, $classname); } sub getName { return 'NotFoundException'; } sub read { my ($self, $input) = @_; my $xfer = 0; my $fname; my $ftype = 0; my $fid = 0; $xfer += $input->readStructBegin(\$fname); while (1) { $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid); if ($ftype == TType::STOP) { last; } SWITCH: for($fid) { $xfer += $input->skip($ftype); } $xfer += $input->readFieldEnd(); } $xfer += $input->readStructEnd(); return $xfer; } sub write { my ($self, $output) = @_; my $xfer = 0; $xfer += $output->writeStructBegin('NotFoundException'); $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::InvalidRequestException; use base qw(Net::GenThrift::Thrift::TException); use base qw(Class::Accessor); Net::GenCassandra::InvalidRequestException->mk_accessors( qw( why ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{why} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{why}) { $self->{why} = $vals->{why}; } } return bless ($self, $classname); } sub getName { return 'InvalidRequestException'; } 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->{why}); } 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('InvalidRequestException'); if (defined $self->{why}) { $xfer += $output->writeFieldBegin('why', TType::STRING, 1); $xfer += $output->writeString($self->{why}); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::UnavailableException; use base qw(Net::GenThrift::Thrift::TException); use base qw(Class::Accessor); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; return bless ($self, $classname); } sub getName { return 'UnavailableException'; } sub read { my ($self, $input) = @_; my $xfer = 0; my $fname; my $ftype = 0; my $fid = 0; $xfer += $input->readStructBegin(\$fname); while (1) { $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid); if ($ftype == TType::STOP) { last; } SWITCH: for($fid) { $xfer += $input->skip($ftype); } $xfer += $input->readFieldEnd(); } $xfer += $input->readStructEnd(); return $xfer; } sub write { my ($self, $output) = @_; my $xfer = 0; $xfer += $output->writeStructBegin('UnavailableException'); $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::TimedOutException; use base qw(Net::GenThrift::Thrift::TException); use base qw(Class::Accessor); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; return bless ($self, $classname); } sub getName { return 'TimedOutException'; } sub read { my ($self, $input) = @_; my $xfer = 0; my $fname; my $ftype = 0; my $fid = 0; $xfer += $input->readStructBegin(\$fname); while (1) { $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid); if ($ftype == TType::STOP) { last; } SWITCH: for($fid) { $xfer += $input->skip($ftype); } $xfer += $input->readFieldEnd(); } $xfer += $input->readStructEnd(); return $xfer; } sub write { my ($self, $output) = @_; my $xfer = 0; $xfer += $output->writeStructBegin('TimedOutException'); $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::AuthenticationException; use base qw(Net::GenThrift::Thrift::TException); use base qw(Class::Accessor); Net::GenCassandra::AuthenticationException->mk_accessors( qw( why ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{why} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{why}) { $self->{why} = $vals->{why}; } } return bless ($self, $classname); } sub getName { return 'AuthenticationException'; } 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->{why}); } 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('AuthenticationException'); if (defined $self->{why}) { $xfer += $output->writeFieldBegin('why', TType::STRING, 1); $xfer += $output->writeString($self->{why}); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::AuthorizationException; use base qw(Net::GenThrift::Thrift::TException); use base qw(Class::Accessor); Net::GenCassandra::AuthorizationException->mk_accessors( qw( why ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{why} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{why}) { $self->{why} = $vals->{why}; } } return bless ($self, $classname); } sub getName { return 'AuthorizationException'; } 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->{why}); } 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('AuthorizationException'); if (defined $self->{why}) { $xfer += $output->writeFieldBegin('why', TType::STRING, 1); $xfer += $output->writeString($self->{why}); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::ColumnParent; use base qw(Class::Accessor); Net::GenCassandra::ColumnParent->mk_accessors( qw( column_family super_column ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{column_family} = undef; $self->{super_column} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{column_family}) { $self->{column_family} = $vals->{column_family}; } if (defined $vals->{super_column}) { $self->{super_column} = $vals->{super_column}; } } return bless ($self, $classname); } sub getName { return 'ColumnParent'; } 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) { /^3$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{column_family}); } else { $xfer += $input->skip($ftype); } last; }; /^4$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{super_column}); } 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('ColumnParent'); if (defined $self->{column_family}) { $xfer += $output->writeFieldBegin('column_family', TType::STRING, 3); $xfer += $output->writeString($self->{column_family}); $xfer += $output->writeFieldEnd(); } if (defined $self->{super_column}) { $xfer += $output->writeFieldBegin('super_column', TType::STRING, 4); $xfer += $output->writeString($self->{super_column}); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::ColumnPath; use base qw(Class::Accessor); Net::GenCassandra::ColumnPath->mk_accessors( qw( column_family super_column column ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{column_family} = undef; $self->{super_column} = undef; $self->{column} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{column_family}) { $self->{column_family} = $vals->{column_family}; } if (defined $vals->{super_column}) { $self->{super_column} = $vals->{super_column}; } if (defined $vals->{column}) { $self->{column} = $vals->{column}; } } return bless ($self, $classname); } sub getName { return 'ColumnPath'; } 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) { /^3$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{column_family}); } else { $xfer += $input->skip($ftype); } last; }; /^4$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{super_column}); } else { $xfer += $input->skip($ftype); } last; }; /^5$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{column}); } 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('ColumnPath'); if (defined $self->{column_family}) { $xfer += $output->writeFieldBegin('column_family', TType::STRING, 3); $xfer += $output->writeString($self->{column_family}); $xfer += $output->writeFieldEnd(); } if (defined $self->{super_column}) { $xfer += $output->writeFieldBegin('super_column', TType::STRING, 4); $xfer += $output->writeString($self->{super_column}); $xfer += $output->writeFieldEnd(); } if (defined $self->{column}) { $xfer += $output->writeFieldBegin('column', TType::STRING, 5); $xfer += $output->writeString($self->{column}); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::SliceRange; use base qw(Class::Accessor); Net::GenCassandra::SliceRange->mk_accessors( qw( start finish reversed count bitmasks ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{start} = undef; $self->{finish} = undef; $self->{reversed} = 0; $self->{count} = 100; $self->{bitmasks} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{start}) { $self->{start} = $vals->{start}; } if (defined $vals->{finish}) { $self->{finish} = $vals->{finish}; } if (defined $vals->{reversed}) { $self->{reversed} = $vals->{reversed}; } if (defined $vals->{count}) { $self->{count} = $vals->{count}; } if (defined $vals->{bitmasks}) { $self->{bitmasks} = $vals->{bitmasks}; } } return bless ($self, $classname); } sub getName { return 'SliceRange'; } 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->{start}); } else { $xfer += $input->skip($ftype); } last; }; /^2$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{finish}); } else { $xfer += $input->skip($ftype); } last; }; /^3$/ && do{ if ($ftype == TType::BOOL) { $xfer += $input->readBool(\$self->{reversed}); } else { $xfer += $input->skip($ftype); } last; }; /^4$/ && do{ if ($ftype == TType::I32) { $xfer += $input->readI32(\$self->{count}); } else { $xfer += $input->skip($ftype); } last; }; /^5$/ && do{ if ($ftype == TType::LIST) { { my $_size7 = 0; $self->{bitmasks} = []; my $_etype10 = 0; $xfer += $input->readListBegin(\$_etype10, \$_size7); for (my $_i11 = 0; $_i11 < $_size7; ++$_i11) { my $elem12 = undef; $xfer += $input->readString(\$elem12); push(@{$self->{bitmasks}},$elem12); } $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('SliceRange'); if (defined $self->{start}) { $xfer += $output->writeFieldBegin('start', TType::STRING, 1); $xfer += $output->writeString($self->{start}); $xfer += $output->writeFieldEnd(); } if (defined $self->{finish}) { $xfer += $output->writeFieldBegin('finish', TType::STRING, 2); $xfer += $output->writeString($self->{finish}); $xfer += $output->writeFieldEnd(); } if (defined $self->{reversed}) { $xfer += $output->writeFieldBegin('reversed', TType::BOOL, 3); $xfer += $output->writeBool($self->{reversed}); $xfer += $output->writeFieldEnd(); } if (defined $self->{count}) { $xfer += $output->writeFieldBegin('count', TType::I32, 4); $xfer += $output->writeI32($self->{count}); $xfer += $output->writeFieldEnd(); } if (defined $self->{bitmasks}) { $xfer += $output->writeFieldBegin('bitmasks', TType::LIST, 5); { $output->writeListBegin(TType::STRING, scalar(@{$self->{bitmasks}})); { foreach my $iter13 (@{$self->{bitmasks}}) { $xfer += $output->writeString($iter13); } } $output->writeListEnd(); } $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::SlicePredicate; use base qw(Class::Accessor); Net::GenCassandra::SlicePredicate->mk_accessors( qw( column_names slice_range ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{column_names} = undef; $self->{slice_range} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{column_names}) { $self->{column_names} = $vals->{column_names}; } if (defined $vals->{slice_range}) { $self->{slice_range} = $vals->{slice_range}; } } return bless ($self, $classname); } sub getName { return 'SlicePredicate'; } 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::LIST) { { my $_size14 = 0; $self->{column_names} = []; my $_etype17 = 0; $xfer += $input->readListBegin(\$_etype17, \$_size14); for (my $_i18 = 0; $_i18 < $_size14; ++$_i18) { my $elem19 = undef; $xfer += $input->readString(\$elem19); push(@{$self->{column_names}},$elem19); } $xfer += $input->readListEnd(); } } else { $xfer += $input->skip($ftype); } last; }; /^2$/ && do{ if ($ftype == TType::STRUCT) { $self->{slice_range} = new Net::GenCassandra::SliceRange(); $xfer += $self->{slice_range}->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('SlicePredicate'); if (defined $self->{column_names}) { $xfer += $output->writeFieldBegin('column_names', TType::LIST, 1); { $output->writeListBegin(TType::STRING, scalar(@{$self->{column_names}})); { foreach my $iter20 (@{$self->{column_names}}) { $xfer += $output->writeString($iter20); } } $output->writeListEnd(); } $xfer += $output->writeFieldEnd(); } if (defined $self->{slice_range}) { $xfer += $output->writeFieldBegin('slice_range', TType::STRUCT, 2); $xfer += $self->{slice_range}->write($output); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::KeyRange; use base qw(Class::Accessor); Net::GenCassandra::KeyRange->mk_accessors( qw( start_key end_key start_token end_token count ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{start_key} = undef; $self->{end_key} = undef; $self->{start_token} = undef; $self->{end_token} = undef; $self->{count} = 100; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{start_key}) { $self->{start_key} = $vals->{start_key}; } if (defined $vals->{end_key}) { $self->{end_key} = $vals->{end_key}; } if (defined $vals->{start_token}) { $self->{start_token} = $vals->{start_token}; } if (defined $vals->{end_token}) { $self->{end_token} = $vals->{end_token}; } if (defined $vals->{count}) { $self->{count} = $vals->{count}; } } return bless ($self, $classname); } sub getName { return 'KeyRange'; } 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->{start_key}); } else { $xfer += $input->skip($ftype); } last; }; /^2$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{end_key}); } else { $xfer += $input->skip($ftype); } last; }; /^3$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{start_token}); } else { $xfer += $input->skip($ftype); } last; }; /^4$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{end_token}); } else { $xfer += $input->skip($ftype); } last; }; /^5$/ && do{ if ($ftype == TType::I32) { $xfer += $input->readI32(\$self->{count}); } 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('KeyRange'); if (defined $self->{start_key}) { $xfer += $output->writeFieldBegin('start_key', TType::STRING, 1); $xfer += $output->writeString($self->{start_key}); $xfer += $output->writeFieldEnd(); } if (defined $self->{end_key}) { $xfer += $output->writeFieldBegin('end_key', TType::STRING, 2); $xfer += $output->writeString($self->{end_key}); $xfer += $output->writeFieldEnd(); } if (defined $self->{start_token}) { $xfer += $output->writeFieldBegin('start_token', TType::STRING, 3); $xfer += $output->writeString($self->{start_token}); $xfer += $output->writeFieldEnd(); } if (defined $self->{end_token}) { $xfer += $output->writeFieldBegin('end_token', TType::STRING, 4); $xfer += $output->writeString($self->{end_token}); $xfer += $output->writeFieldEnd(); } if (defined $self->{count}) { $xfer += $output->writeFieldBegin('count', TType::I32, 5); $xfer += $output->writeI32($self->{count}); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::KeySlice; use base qw(Class::Accessor); Net::GenCassandra::KeySlice->mk_accessors( qw( key columns ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{key} = undef; $self->{columns} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{key}) { $self->{key} = $vals->{key}; } if (defined $vals->{columns}) { $self->{columns} = $vals->{columns}; } } return bless ($self, $classname); } sub getName { return 'KeySlice'; } 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->{key}); } else { $xfer += $input->skip($ftype); } last; }; /^2$/ && do{ if ($ftype == TType::LIST) { { my $_size21 = 0; $self->{columns} = []; my $_etype24 = 0; $xfer += $input->readListBegin(\$_etype24, \$_size21); for (my $_i25 = 0; $_i25 < $_size21; ++$_i25) { my $elem26 = undef; $elem26 = new Net::GenCassandra::ColumnOrSuperColumn(); $xfer += $elem26->read($input); push(@{$self->{columns}},$elem26); } $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('KeySlice'); if (defined $self->{key}) { $xfer += $output->writeFieldBegin('key', TType::STRING, 1); $xfer += $output->writeString($self->{key}); $xfer += $output->writeFieldEnd(); } if (defined $self->{columns}) { $xfer += $output->writeFieldBegin('columns', TType::LIST, 2); { $output->writeListBegin(TType::STRUCT, scalar(@{$self->{columns}})); { foreach my $iter27 (@{$self->{columns}}) { $xfer += ${iter27}->write($output); } } $output->writeListEnd(); } $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::Deletion; use base qw(Class::Accessor); Net::GenCassandra::Deletion->mk_accessors( qw( timestamp super_column predicate ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{timestamp} = undef; $self->{super_column} = undef; $self->{predicate} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{timestamp}) { $self->{timestamp} = $vals->{timestamp}; } if (defined $vals->{super_column}) { $self->{super_column} = $vals->{super_column}; } if (defined $vals->{predicate}) { $self->{predicate} = $vals->{predicate}; } } return bless ($self, $classname); } sub getName { return 'Deletion'; } 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->{timestamp}); } else { $xfer += $input->skip($ftype); } last; }; /^2$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{super_column}); } else { $xfer += $input->skip($ftype); } last; }; /^3$/ && do{ if ($ftype == TType::STRUCT) { $self->{predicate} = new Net::GenCassandra::SlicePredicate(); $xfer += $self->{predicate}->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('Deletion'); if (defined $self->{timestamp}) { $xfer += $output->writeFieldBegin('timestamp', TType::I64, 1); $xfer += $output->writeI64($self->{timestamp}); $xfer += $output->writeFieldEnd(); } if (defined $self->{super_column}) { $xfer += $output->writeFieldBegin('super_column', TType::STRING, 2); $xfer += $output->writeString($self->{super_column}); $xfer += $output->writeFieldEnd(); } if (defined $self->{predicate}) { $xfer += $output->writeFieldBegin('predicate', TType::STRUCT, 3); $xfer += $self->{predicate}->write($output); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::Mutation; use base qw(Class::Accessor); Net::GenCassandra::Mutation->mk_accessors( qw( column_or_supercolumn deletion ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{column_or_supercolumn} = undef; $self->{deletion} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{column_or_supercolumn}) { $self->{column_or_supercolumn} = $vals->{column_or_supercolumn}; } if (defined $vals->{deletion}) { $self->{deletion} = $vals->{deletion}; } } return bless ($self, $classname); } sub getName { return 'Mutation'; } 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->{column_or_supercolumn} = new Net::GenCassandra::ColumnOrSuperColumn(); $xfer += $self->{column_or_supercolumn}->read($input); } else { $xfer += $input->skip($ftype); } last; }; /^2$/ && do{ if ($ftype == TType::STRUCT) { $self->{deletion} = new Net::GenCassandra::Deletion(); $xfer += $self->{deletion}->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('Mutation'); if (defined $self->{column_or_supercolumn}) { $xfer += $output->writeFieldBegin('column_or_supercolumn', TType::STRUCT, 1); $xfer += $self->{column_or_supercolumn}->write($output); $xfer += $output->writeFieldEnd(); } if (defined $self->{deletion}) { $xfer += $output->writeFieldBegin('deletion', TType::STRUCT, 2); $xfer += $self->{deletion}->write($output); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::TokenRange; use base qw(Class::Accessor); Net::GenCassandra::TokenRange->mk_accessors( qw( start_token end_token endpoints ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{start_token} = undef; $self->{end_token} = undef; $self->{endpoints} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{start_token}) { $self->{start_token} = $vals->{start_token}; } if (defined $vals->{end_token}) { $self->{end_token} = $vals->{end_token}; } if (defined $vals->{endpoints}) { $self->{endpoints} = $vals->{endpoints}; } } return bless ($self, $classname); } sub getName { return 'TokenRange'; } 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->{start_token}); } else { $xfer += $input->skip($ftype); } last; }; /^2$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{end_token}); } else { $xfer += $input->skip($ftype); } last; }; /^3$/ && do{ if ($ftype == TType::LIST) { { my $_size28 = 0; $self->{endpoints} = []; my $_etype31 = 0; $xfer += $input->readListBegin(\$_etype31, \$_size28); for (my $_i32 = 0; $_i32 < $_size28; ++$_i32) { my $elem33 = undef; $xfer += $input->readString(\$elem33); push(@{$self->{endpoints}},$elem33); } $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('TokenRange'); if (defined $self->{start_token}) { $xfer += $output->writeFieldBegin('start_token', TType::STRING, 1); $xfer += $output->writeString($self->{start_token}); $xfer += $output->writeFieldEnd(); } if (defined $self->{end_token}) { $xfer += $output->writeFieldBegin('end_token', TType::STRING, 2); $xfer += $output->writeString($self->{end_token}); $xfer += $output->writeFieldEnd(); } if (defined $self->{endpoints}) { $xfer += $output->writeFieldBegin('endpoints', TType::LIST, 3); { $output->writeListBegin(TType::STRING, scalar(@{$self->{endpoints}})); { foreach my $iter34 (@{$self->{endpoints}}) { $xfer += $output->writeString($iter34); } } $output->writeListEnd(); } $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::AuthenticationRequest; use base qw(Class::Accessor); Net::GenCassandra::AuthenticationRequest->mk_accessors( qw( credentials ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{credentials} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{credentials}) { $self->{credentials} = $vals->{credentials}; } } return bless ($self, $classname); } sub getName { return 'AuthenticationRequest'; } 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 $_size35 = 0; $self->{credentials} = {}; my $_ktype36 = 0; my $_vtype37 = 0; $xfer += $input->readMapBegin(\$_ktype36, \$_vtype37, \$_size35); for (my $_i39 = 0; $_i39 < $_size35; ++$_i39) { my $key40 = ''; my $val41 = ''; $xfer += $input->readString(\$key40); $xfer += $input->readString(\$val41); $self->{credentials}->{$key40} = $val41; } $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('AuthenticationRequest'); if (defined $self->{credentials}) { $xfer += $output->writeFieldBegin('credentials', TType::MAP, 1); { $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{credentials}})); { while( my ($kiter42,$viter43) = each %{$self->{credentials}}) { $xfer += $output->writeString($kiter42); $xfer += $output->writeString($viter43); } } $output->writeMapEnd(); } $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::CfDef; use base qw(Class::Accessor); Net::GenCassandra::CfDef->mk_accessors( qw( table name column_type comparator_type subcomparator_type comment row_cache_size preload_row_cache key_cache_size ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{table} = undef; $self->{name} = undef; $self->{column_type} = "Standard"; $self->{comparator_type} = "BytesType"; $self->{subcomparator_type} = ""; $self->{comment} = ""; $self->{row_cache_size} = 0; $self->{preload_row_cache} = 0; $self->{key_cache_size} = 200000; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{table}) { $self->{table} = $vals->{table}; } if (defined $vals->{name}) { $self->{name} = $vals->{name}; } if (defined $vals->{column_type}) { $self->{column_type} = $vals->{column_type}; } if (defined $vals->{comparator_type}) { $self->{comparator_type} = $vals->{comparator_type}; } if (defined $vals->{subcomparator_type}) { $self->{subcomparator_type} = $vals->{subcomparator_type}; } if (defined $vals->{comment}) { $self->{comment} = $vals->{comment}; } if (defined $vals->{row_cache_size}) { $self->{row_cache_size} = $vals->{row_cache_size}; } if (defined $vals->{preload_row_cache}) { $self->{preload_row_cache} = $vals->{preload_row_cache}; } if (defined $vals->{key_cache_size}) { $self->{key_cache_size} = $vals->{key_cache_size}; } } return bless ($self, $classname); } sub getName { return 'CfDef'; } 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->{name}); } else { $xfer += $input->skip($ftype); } last; }; /^3$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{column_type}); } else { $xfer += $input->skip($ftype); } last; }; /^4$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{comparator_type}); } else { $xfer += $input->skip($ftype); } last; }; /^5$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{subcomparator_type}); } else { $xfer += $input->skip($ftype); } last; }; /^6$/ && do{ if ($ftype == TType::STRING) { $xfer += $input->readString(\$self->{comment}); } else { $xfer += $input->skip($ftype); } last; }; /^7$/ && do{ if ($ftype == TType::DOUBLE) { $xfer += $input->readDouble(\$self->{row_cache_size}); } else { $xfer += $input->skip($ftype); } last; }; /^8$/ && do{ if ($ftype == TType::BOOL) { $xfer += $input->readBool(\$self->{preload_row_cache}); } else { $xfer += $input->skip($ftype); } last; }; /^9$/ && do{ if ($ftype == TType::DOUBLE) { $xfer += $input->readDouble(\$self->{key_cache_size}); } 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('CfDef'); if (defined $self->{table}) { $xfer += $output->writeFieldBegin('table', TType::STRING, 1); $xfer += $output->writeString($self->{table}); $xfer += $output->writeFieldEnd(); } if (defined $self->{name}) { $xfer += $output->writeFieldBegin('name', TType::STRING, 2); $xfer += $output->writeString($self->{name}); $xfer += $output->writeFieldEnd(); } if (defined $self->{column_type}) { $xfer += $output->writeFieldBegin('column_type', TType::STRING, 3); $xfer += $output->writeString($self->{column_type}); $xfer += $output->writeFieldEnd(); } if (defined $self->{comparator_type}) { $xfer += $output->writeFieldBegin('comparator_type', TType::STRING, 4); $xfer += $output->writeString($self->{comparator_type}); $xfer += $output->writeFieldEnd(); } if (defined $self->{subcomparator_type}) { $xfer += $output->writeFieldBegin('subcomparator_type', TType::STRING, 5); $xfer += $output->writeString($self->{subcomparator_type}); $xfer += $output->writeFieldEnd(); } if (defined $self->{comment}) { $xfer += $output->writeFieldBegin('comment', TType::STRING, 6); $xfer += $output->writeString($self->{comment}); $xfer += $output->writeFieldEnd(); } if (defined $self->{row_cache_size}) { $xfer += $output->writeFieldBegin('row_cache_size', TType::DOUBLE, 7); $xfer += $output->writeDouble($self->{row_cache_size}); $xfer += $output->writeFieldEnd(); } if (defined $self->{preload_row_cache}) { $xfer += $output->writeFieldBegin('preload_row_cache', TType::BOOL, 8); $xfer += $output->writeBool($self->{preload_row_cache}); $xfer += $output->writeFieldEnd(); } if (defined $self->{key_cache_size}) { $xfer += $output->writeFieldBegin('key_cache_size', TType::DOUBLE, 9); $xfer += $output->writeDouble($self->{key_cache_size}); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } package Net::GenCassandra::KsDef; use base qw(Class::Accessor); Net::GenCassandra::KsDef->mk_accessors( qw( name strategy_class replication_factor cf_defs ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; $self->{name} = undef; $self->{strategy_class} = undef; $self->{replication_factor} = undef; $self->{cf_defs} = undef; if (UNIVERSAL::isa($vals,'HASH')) { if (defined $vals->{name}) { $self->{name} = $vals->{name}; } if (defined $vals->{strategy_class}) { $self->{strategy_class} = $vals->{strategy_class}; } if (defined $vals->{replication_factor}) { $self->{replication_factor} = $vals->{replication_factor}; } if (defined $vals->{cf_defs}) { $self->{cf_defs} = $vals->{cf_defs}; } } return bless ($self, $classname); } sub getName { return 'KsDef'; } 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->{strategy_class}); } else { $xfer += $input->skip($ftype); } last; }; /^3$/ && do{ if ($ftype == TType::I32) { $xfer += $input->readI32(\$self->{replication_factor}); } else { $xfer += $input->skip($ftype); } last; }; /^5$/ && do{ if ($ftype == TType::LIST) { { my $_size44 = 0; $self->{cf_defs} = []; my $_etype47 = 0; $xfer += $input->readListBegin(\$_etype47, \$_size44); for (my $_i48 = 0; $_i48 < $_size44; ++$_i48) { my $elem49 = undef; $elem49 = new Net::GenCassandra::CfDef(); $xfer += $elem49->read($input); push(@{$self->{cf_defs}},$elem49); } $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('KsDef'); if (defined $self->{name}) { $xfer += $output->writeFieldBegin('name', TType::STRING, 1); $xfer += $output->writeString($self->{name}); $xfer += $output->writeFieldEnd(); } if (defined $self->{strategy_class}) { $xfer += $output->writeFieldBegin('strategy_class', TType::STRING, 2); $xfer += $output->writeString($self->{strategy_class}); $xfer += $output->writeFieldEnd(); } if (defined $self->{replication_factor}) { $xfer += $output->writeFieldBegin('replication_factor', TType::I32, 3); $xfer += $output->writeI32($self->{replication_factor}); $xfer += $output->writeFieldEnd(); } if (defined $self->{cf_defs}) { $xfer += $output->writeFieldBegin('cf_defs', TType::LIST, 5); { $output->writeListBegin(TType::STRUCT, scalar(@{$self->{cf_defs}})); { foreach my $iter50 (@{$self->{cf_defs}}) { $xfer += ${iter50}->write($output); } } $output->writeListEnd(); } $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } 1;