You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by om...@apache.org on 2008/08/29 06:32:00 UTC
svn commit: r690096 [8/15] - in /hadoop/core/trunk: ./ src/contrib/thriftfs/
src/contrib/thriftfs/gen-cocoa/ src/contrib/thriftfs/gen-cpp/
src/contrib/thriftfs/gen-java/ src/contrib/thriftfs/gen-java/org/
src/contrib/thriftfs/gen-java/org/apache/ src/c...
Added: hadoop/core/trunk/src/contrib/thriftfs/gen-perl/ThriftHadoopFileSystem.pm
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/thriftfs/gen-perl/ThriftHadoopFileSystem.pm?rev=690096&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/thriftfs/gen-perl/ThriftHadoopFileSystem.pm (added)
+++ hadoop/core/trunk/src/contrib/thriftfs/gen-perl/ThriftHadoopFileSystem.pm Thu Aug 28 21:31:57 2008
@@ -0,0 +1,4538 @@
+#
+# 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 Thrift;
+
+use Types;
+
+# HELPER FUNCTIONS AND STRUCTURES
+
+package ThriftHadoopFileSystem_setInactivityTimeoutPeriod_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_setInactivityTimeoutPeriod_args->mk_accessors( qw( periodInSeconds ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{periodInSeconds} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{periodInSeconds}) {
+ $self->{periodInSeconds} = $vals->{periodInSeconds};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_setInactivityTimeoutPeriod_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{periodInSeconds});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_setInactivityTimeoutPeriod_args');
+ if (defined $self->{periodInSeconds}) {
+ $xfer += $output->writeFieldBegin('periodInSeconds', TType::I64, 1);
+ $xfer += $output->writeI64($self->{periodInSeconds});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_setInactivityTimeoutPeriod_result;
+use base('Class::Accessor');
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_setInactivityTimeoutPeriod_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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 = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_setInactivityTimeoutPeriod_result');
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_shutdown_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_shutdown_args->mk_accessors( qw( status ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{status} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{status}) {
+ $self->{status} = $vals->{status};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_shutdown_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{status});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_shutdown_args');
+ if (defined $self->{status}) {
+ $xfer += $output->writeFieldBegin('status', TType::I32, 1);
+ $xfer += $output->writeI32($self->{status});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_shutdown_result;
+use base('Class::Accessor');
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_shutdown_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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 = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_shutdown_result');
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_create_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_create_args->mk_accessors( qw( path ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_create_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_create_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_create_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_create_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_create_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{success} = new ThriftHandle();
+ $xfer += $self->{success}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_create_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $self->{success}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_createFile_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_createFile_args->mk_accessors( qw( path mode overwrite bufferSize block_replication blocksize ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+$self->{mode} = undef;
+$self->{overwrite} = undef;
+$self->{bufferSize} = undef;
+$self->{block_replication} = undef;
+$self->{blocksize} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ if (defined $vals->{mode}) {
+ $self->{mode} = $vals->{mode};
+ }
+ if (defined $vals->{overwrite}) {
+ $self->{overwrite} = $vals->{overwrite};
+ }
+ if (defined $vals->{bufferSize}) {
+ $self->{bufferSize} = $vals->{bufferSize};
+ }
+ if (defined $vals->{block_replication}) {
+ $self->{block_replication} = $vals->{block_replication};
+ }
+ if (defined $vals->{blocksize}) {
+ $self->{blocksize} = $vals->{blocksize};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_createFile_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::I16) {
+ $xfer += $input->readI16(\$self->{mode});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^3$/ && do{ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool(\$self->{overwrite});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^4$/ && do{ if ($ftype == TType::I32) {
+ $xfer += $input->readI32(\$self->{bufferSize});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^5$/ && do{ if ($ftype == TType::I16) {
+ $xfer += $input->readI16(\$self->{block_replication});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^6$/ && do{ if ($ftype == TType::I64) {
+ $xfer += $input->readI64(\$self->{blocksize});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_createFile_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{mode}) {
+ $xfer += $output->writeFieldBegin('mode', TType::I16, 2);
+ $xfer += $output->writeI16($self->{mode});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{overwrite}) {
+ $xfer += $output->writeFieldBegin('overwrite', TType::BOOL, 3);
+ $xfer += $output->writeBool($self->{overwrite});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{bufferSize}) {
+ $xfer += $output->writeFieldBegin('bufferSize', TType::I32, 4);
+ $xfer += $output->writeI32($self->{bufferSize});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{block_replication}) {
+ $xfer += $output->writeFieldBegin('block_replication', TType::I16, 5);
+ $xfer += $output->writeI16($self->{block_replication});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{blocksize}) {
+ $xfer += $output->writeFieldBegin('blocksize', TType::I64, 6);
+ $xfer += $output->writeI64($self->{blocksize});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_createFile_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_createFile_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_createFile_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{success} = new ThriftHandle();
+ $xfer += $self->{success}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_createFile_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $self->{success}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_open_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_open_args->mk_accessors( qw( path ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_open_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_open_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_open_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_open_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_open_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{success} = new ThriftHandle();
+ $xfer += $self->{success}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_open_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $self->{success}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_append_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_append_args->mk_accessors( qw( path ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_append_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_append_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_append_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_append_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_append_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{success} = new ThriftHandle();
+ $xfer += $self->{success}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_append_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $self->{success}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_write_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_write_args->mk_accessors( qw( handle data ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{handle} = undef;
+$self->{data} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{handle}) {
+ $self->{handle} = $vals->{handle};
+ }
+ if (defined $vals->{data}) {
+ $self->{data} = $vals->{data};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_write_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{handle} = new ThriftHandle();
+ $xfer += $self->{handle}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^-1$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{data});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_write_args');
+ if (defined $self->{handle}) {
+ $xfer += $output->writeFieldBegin('handle', TType::STRUCT, 1);
+ $xfer += $self->{handle}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{data}) {
+ $xfer += $output->writeFieldBegin('data', TType::STRING, -1);
+ $xfer += $output->writeString($self->{data});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_write_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_write_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_write_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool(\$self->{success});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_write_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($self->{success});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_read_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_read_args->mk_accessors( qw( handle offset size ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{handle} = undef;
+$self->{offset} = undef;
+$self->{size} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{handle}) {
+ $self->{handle} = $vals->{handle};
+ }
+ if (defined $vals->{offset}) {
+ $self->{offset} = $vals->{offset};
+ }
+ if (defined $vals->{size}) {
+ $self->{size} = $vals->{size};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_read_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{handle} = new ThriftHandle();
+ $xfer += $self->{handle}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^-1$/ && do{ if ($ftype == TType::I64) {
+ $xfer += $input->readI64(\$self->{offset});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^-2$/ && do{ if ($ftype == TType::I32) {
+ $xfer += $input->readI32(\$self->{size});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_read_args');
+ if (defined $self->{handle}) {
+ $xfer += $output->writeFieldBegin('handle', TType::STRUCT, 1);
+ $xfer += $self->{handle}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{offset}) {
+ $xfer += $output->writeFieldBegin('offset', TType::I64, -1);
+ $xfer += $output->writeI64($self->{offset});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{size}) {
+ $xfer += $output->writeFieldBegin('size', TType::I32, -2);
+ $xfer += $output->writeI32($self->{size});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_read_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_read_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_read_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{success});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_read_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($self->{success});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_close_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_close_args->mk_accessors( qw( out ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{out} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{out}) {
+ $self->{out} = $vals->{out};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_close_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{out} = new ThriftHandle();
+ $xfer += $self->{out}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_close_args');
+ if (defined $self->{out}) {
+ $xfer += $output->writeFieldBegin('out', TType::STRUCT, 1);
+ $xfer += $self->{out}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_close_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_close_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_close_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool(\$self->{success});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_close_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($self->{success});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_rm_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_rm_args->mk_accessors( qw( path recursive ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+$self->{recursive} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ if (defined $vals->{recursive}) {
+ $self->{recursive} = $vals->{recursive};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_rm_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool(\$self->{recursive});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_rm_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{recursive}) {
+ $xfer += $output->writeFieldBegin('recursive', TType::BOOL, 2);
+ $xfer += $output->writeBool($self->{recursive});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_rm_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_rm_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_rm_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool(\$self->{success});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_rm_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($self->{success});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_rename_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_rename_args->mk_accessors( qw( path dest ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+$self->{dest} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ if (defined $vals->{dest}) {
+ $self->{dest} = $vals->{dest};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_rename_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{dest} = new Pathname();
+ $xfer += $self->{dest}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_rename_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{dest}) {
+ $xfer += $output->writeFieldBegin('dest', TType::STRUCT, 2);
+ $xfer += $self->{dest}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_rename_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_rename_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_rename_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool(\$self->{success});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_rename_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($self->{success});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_mkdirs_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_mkdirs_args->mk_accessors( qw( path ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_mkdirs_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_mkdirs_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_mkdirs_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_mkdirs_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_mkdirs_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool(\$self->{success});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_mkdirs_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($self->{success});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_exists_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_exists_args->mk_accessors( qw( path ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_exists_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_exists_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_exists_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_exists_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_exists_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool(\$self->{success});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_exists_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
+ $xfer += $output->writeBool($self->{success});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_stat_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_stat_args->mk_accessors( qw( path ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_stat_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_stat_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_stat_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_stat_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_stat_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{success} = new FileStatus();
+ $xfer += $self->{success}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_stat_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $self->{success}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_listStatus_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_listStatus_args->mk_accessors( qw( path ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_listStatus_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_listStatus_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_listStatus_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_listStatus_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_listStatus_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size14 = 0;
+ $self->{success} = [];
+ my $_etype17 = 0;
+ $xfer += $input->readListBegin(\$_etype17, \$_size14);
+ for (my $_i18 = 0; $_i18 < $_size14; ++$_i18)
+ {
+ my $elem19 = undef;
+ $elem19 = new FileStatus();
+ $xfer += $elem19->read($input);
+ push(@{$self->{success}},$elem19);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_listStatus_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+ {
+ $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
+ {
+ foreach my $iter20 (@{$self->{success}})
+ {
+ $xfer += ${iter20}->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_chmod_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_chmod_args->mk_accessors( qw( path mode ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+$self->{mode} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ if (defined $vals->{mode}) {
+ $self->{mode} = $vals->{mode};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_chmod_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::I16) {
+ $xfer += $input->readI16(\$self->{mode});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_chmod_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{mode}) {
+ $xfer += $output->writeFieldBegin('mode', TType::I16, 2);
+ $xfer += $output->writeI16($self->{mode});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_chmod_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_chmod_result->mk_accessors( qw( ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_chmod_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_chmod_result');
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_chown_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_chown_args->mk_accessors( qw( path owner group ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+$self->{owner} = undef;
+$self->{group} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ if (defined $vals->{owner}) {
+ $self->{owner} = $vals->{owner};
+ }
+ if (defined $vals->{group}) {
+ $self->{group} = $vals->{group};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_chown_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{owner});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^3$/ && do{ if ($ftype == TType::STRING) {
+ $xfer += $input->readString(\$self->{group});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_chown_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{owner}) {
+ $xfer += $output->writeFieldBegin('owner', TType::STRING, 2);
+ $xfer += $output->writeString($self->{owner});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{group}) {
+ $xfer += $output->writeFieldBegin('group', TType::STRING, 3);
+ $xfer += $output->writeString($self->{group});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_chown_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_chown_result->mk_accessors( qw( ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_chown_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_chown_result');
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_setReplication_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_setReplication_args->mk_accessors( qw( path replication ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+$self->{replication} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ if (defined $vals->{replication}) {
+ $self->{replication} = $vals->{replication};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_setReplication_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::I16) {
+ $xfer += $input->readI16(\$self->{replication});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_setReplication_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{replication}) {
+ $xfer += $output->writeFieldBegin('replication', TType::I16, 2);
+ $xfer += $output->writeI16($self->{replication});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_setReplication_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_setReplication_result->mk_accessors( qw( ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_setReplication_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_setReplication_result');
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_getFileBlockLocations_args;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_getFileBlockLocations_args->mk_accessors( qw( path start length ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{path} = undef;
+$self->{start} = undef;
+$self->{length} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{path}) {
+ $self->{path} = $vals->{path};
+ }
+ if (defined $vals->{start}) {
+ $self->{start} = $vals->{start};
+ }
+ if (defined $vals->{length}) {
+ $self->{length} = $vals->{length};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_getFileBlockLocations_args';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ 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->{path} = new Pathname();
+ $xfer += $self->{path}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^2$/ && do{ if ($ftype == TType::I64) {
+ $xfer += $input->readI64(\$self->{start});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^3$/ && do{ if ($ftype == TType::I64) {
+ $xfer += $input->readI64(\$self->{length});
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_getFileBlockLocations_args');
+ if (defined $self->{path}) {
+ $xfer += $output->writeFieldBegin('path', TType::STRUCT, 1);
+ $xfer += $self->{path}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{start}) {
+ $xfer += $output->writeFieldBegin('start', TType::I64, 2);
+ $xfer += $output->writeI64($self->{start});
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{length}) {
+ $xfer += $output->writeFieldBegin('length', TType::I64, 3);
+ $xfer += $output->writeI64($self->{length});
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystem_getFileBlockLocations_result;
+use base('Class::Accessor');
+ThriftHadoopFileSystem_getFileBlockLocations_result->mk_accessors( qw( success ) );
+sub new {
+my $classname = shift;
+my $self = {};
+my $vals = shift || {};
+$self->{success} = undef;
+$self->{ouch} = undef;
+ if (UNIVERSAL::isa($vals,'HASH')) {
+ if (defined $vals->{success}) {
+ $self->{success} = $vals->{success};
+ }
+ if (defined $vals->{ouch}) {
+ $self->{ouch} = $vals->{ouch};
+ }
+ }
+return bless($self,$classname);
+}
+
+sub getName {
+ return 'ThriftHadoopFileSystem_getFileBlockLocations_result';
+}
+
+sub read {
+ my $self = shift;
+ my $input = shift;
+ my $xfer = 0;
+ my $fname;
+ my $ftype = 0;
+ my $fid = 0;
+ $xfer += $input->readStructBegin(\$fname);
+ while (1)
+ {
+ $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+ if ($ftype == TType::STOP) {
+ last;
+ }
+ SWITCH: for($fid)
+ {
+ /^0$/ && do{ if ($ftype == TType::LIST) {
+ {
+ my $_size21 = 0;
+ $self->{success} = [];
+ my $_etype24 = 0;
+ $xfer += $input->readListBegin(\$_etype24, \$_size21);
+ for (my $_i25 = 0; $_i25 < $_size21; ++$_i25)
+ {
+ my $elem26 = undef;
+ $elem26 = new BlockLocation();
+ $xfer += $elem26->read($input);
+ push(@{$self->{success}},$elem26);
+ }
+ $xfer += $input->readListEnd();
+ }
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ /^1$/ && do{ if ($ftype == TType::STRUCT) {
+ $self->{ouch} = new ThriftIOException();
+ $xfer += $self->{ouch}->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ last; };
+ $xfer += $input->skip($ftype);
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+}
+
+sub write {
+ my $self = shift;
+ my $output = shift;
+ my $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHadoopFileSystem_getFileBlockLocations_result');
+ if (defined $self->{success}) {
+ $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+ {
+ $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
+ {
+ foreach my $iter27 (@{$self->{success}})
+ {
+ $xfer += ${iter27}->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if (defined $self->{ouch}) {
+ $xfer += $output->writeFieldBegin('ouch', TType::STRUCT, 1);
+ $xfer += $self->{ouch}->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+}
+
+package ThriftHadoopFileSystemIf;
+
+sub setInactivityTimeoutPeriod{
+ my $self = shift;
+ my $periodInSeconds = shift;
+
+ die 'implement interface';
+}
+sub shutdown{
+ my $self = shift;
+ my $status = shift;
+
+ die 'implement interface';
+}
+sub create{
+ my $self = shift;
+ my $path = shift;
+
+ die 'implement interface';
+}
+sub createFile{
+ my $self = shift;
+ my $path = shift;
+ my $mode = shift;
+ my $overwrite = shift;
+ my $bufferSize = shift;
+ my $block_replication = shift;
+ my $blocksize = shift;
+
+ die 'implement interface';
+}
+sub open{
+ my $self = shift;
+ my $path = shift;
+
+ die 'implement interface';
+}
+sub append{
+ my $self = shift;
+ my $path = shift;
+
+ die 'implement interface';
+}
+sub write{
+ my $self = shift;
+ my $handle = shift;
+ my $data = shift;
+
+ die 'implement interface';
+}
+sub read{
+ my $self = shift;
+ my $handle = shift;
+ my $offset = shift;
+ my $size = shift;
+
+ die 'implement interface';
+}
+sub close{
+ my $self = shift;
+ my $out = shift;
+
+ die 'implement interface';
+}
+sub rm{
+ my $self = shift;
+ my $path = shift;
+ my $recursive = shift;
+
+ die 'implement interface';
+}
+sub rename{
+ my $self = shift;
+ my $path = shift;
+ my $dest = shift;
+
+ die 'implement interface';
+}
+sub mkdirs{
+ my $self = shift;
+ my $path = shift;
+
+ die 'implement interface';
+}
+sub exists{
+ my $self = shift;
+ my $path = shift;
+
+ die 'implement interface';
+}
+sub stat{
+ my $self = shift;
+ my $path = shift;
+
+ die 'implement interface';
+}
+sub listStatus{
+ my $self = shift;
+ my $path = shift;
+
+ die 'implement interface';
+}
+sub chmod{
+ my $self = shift;
+ my $path = shift;
+ my $mode = shift;
+
+ die 'implement interface';
+}
+sub chown{
+ my $self = shift;
+ my $path = shift;
+ my $owner = shift;
+ my $group = shift;
+
+ die 'implement interface';
+}
+sub setReplication{
+ my $self = shift;
+ my $path = shift;
+ my $replication = shift;
+
+ die 'implement interface';
+}
+sub getFileBlockLocations{
+ my $self = shift;
+ my $path = shift;
+ my $start = shift;
+ my $length = shift;
+
+ die 'implement interface';
+}
+package ThriftHadoopFileSystemRest;
+
+sub new {
+ my $classname=shift;
+ my $impl =shift;
+ my $self ={ impl => $impl };
+
+ return bless($self,$classname);
+}
+
+sub setInactivityTimeoutPeriod{
+ my $self = shift;
+ my $request = shift;
+
+ my $periodInSeconds = ($request->{'periodInSeconds'}) ? $request->{'periodInSeconds'} : undef;
+ return $self->{impl}->setInactivityTimeoutPeriod($periodInSeconds);
+}
+
+sub shutdown{
+ my $self = shift;
+ my $request = shift;
+
+ my $status = ($request->{'status'}) ? $request->{'status'} : undef;
+ return $self->{impl}->shutdown($status);
+}
+
+sub create{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ return $self->{impl}->create($path);
+}
+
+sub createFile{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ my $mode = ($request->{'mode'}) ? $request->{'mode'} : undef;
+ my $overwrite = ($request->{'overwrite'}) ? $request->{'overwrite'} : undef;
+ my $bufferSize = ($request->{'bufferSize'}) ? $request->{'bufferSize'} : undef;
+ my $block_replication = ($request->{'block_replication'}) ? $request->{'block_replication'} : undef;
+ my $blocksize = ($request->{'blocksize'}) ? $request->{'blocksize'} : undef;
+ return $self->{impl}->createFile($path, $mode, $overwrite, $bufferSize, $block_replication, $blocksize);
+}
+
+sub open{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ return $self->{impl}->open($path);
+}
+
+sub append{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ return $self->{impl}->append($path);
+}
+
+sub write{
+ my $self = shift;
+ my $request = shift;
+
+ my $handle = ($request->{'handle'}) ? $request->{'handle'} : undef;
+ my $data = ($request->{'data'}) ? $request->{'data'} : undef;
+ return $self->{impl}->write($handle, $data);
+}
+
+sub read{
+ my $self = shift;
+ my $request = shift;
+
+ my $handle = ($request->{'handle'}) ? $request->{'handle'} : undef;
+ my $offset = ($request->{'offset'}) ? $request->{'offset'} : undef;
+ my $size = ($request->{'size'}) ? $request->{'size'} : undef;
+ return $self->{impl}->read($handle, $offset, $size);
+}
+
+sub close{
+ my $self = shift;
+ my $request = shift;
+
+ my $out = ($request->{'out'}) ? $request->{'out'} : undef;
+ return $self->{impl}->close($out);
+}
+
+sub rm{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ my $recursive = ($request->{'recursive'}) ? $request->{'recursive'} : undef;
+ return $self->{impl}->rm($path, $recursive);
+}
+
+sub rename{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ my $dest = ($request->{'dest'}) ? $request->{'dest'} : undef;
+ return $self->{impl}->rename($path, $dest);
+}
+
+sub mkdirs{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ return $self->{impl}->mkdirs($path);
+}
+
+sub exists{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ return $self->{impl}->exists($path);
+}
+
+sub stat{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ return $self->{impl}->stat($path);
+}
+
+sub listStatus{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ return $self->{impl}->listStatus($path);
+}
+
+sub chmod{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ my $mode = ($request->{'mode'}) ? $request->{'mode'} : undef;
+ return $self->{impl}->chmod($path, $mode);
+}
+
+sub chown{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ my $owner = ($request->{'owner'}) ? $request->{'owner'} : undef;
+ my $group = ($request->{'group'}) ? $request->{'group'} : undef;
+ return $self->{impl}->chown($path, $owner, $group);
+}
+
+sub setReplication{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ my $replication = ($request->{'replication'}) ? $request->{'replication'} : undef;
+ return $self->{impl}->setReplication($path, $replication);
+}
+
+sub getFileBlockLocations{
+ my $self = shift;
+ my $request = shift;
+
+ my $path = ($request->{'path'}) ? $request->{'path'} : undef;
+ my $start = ($request->{'start'}) ? $request->{'start'} : undef;
+ my $length = ($request->{'length'}) ? $request->{'length'} : undef;
+ return $self->{impl}->getFileBlockLocations($path, $start, $length);
+}
+
+package ThriftHadoopFileSystemClient;
+
+use base('ThriftHadoopFileSystemIf');
+sub new {
+ my $classname = shift;
+ my $input = shift;
+ my $output = shift;
+ my $self = {};
+ $self->{input} = $input;
+ $self->{output} = defined $output ? $output : $input;
+ $self->{seqid} = 0;
+ return bless($self,$classname);
+}
+
+sub setInactivityTimeoutPeriod{
+ my $self = shift;
+ my $periodInSeconds = shift;
+
+ $self->send_setInactivityTimeoutPeriod($periodInSeconds);
+ $self->recv_setInactivityTimeoutPeriod();
+}
+
+sub send_setInactivityTimeoutPeriod{
+ my $self = shift;
+ my $periodInSeconds = shift;
+
+ $self->{output}->writeMessageBegin('setInactivityTimeoutPeriod', TMessageType::CALL, $self->{seqid});
+ my $args = new ThriftHadoopFileSystem_setInactivityTimeoutPeriod_args();
+ $args->{periodInSeconds} = $periodInSeconds;
+ $args->write($self->{output});
+ $self->{output}->writeMessageEnd();
+ $self->{output}->getTransport()->flush();
+}
+
+sub recv_setInactivityTimeoutPeriod{
+ my $self = shift;
+
+ my $rseqid = 0;
+ my $fname;
+ my $mtype = 0;
+
+ $self->{input}->readMessageBegin(\$fname, \$mtype, \$rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ my $x = new TApplicationException();
+ $x->read($self->{input});
+ $self->{input}->readMessageEnd();
+ die $x;
+ }
+ my $result = new ThriftHadoopFileSystem_setInactivityTimeoutPeriod_result();
+ $result->read($self->{input});
+ $self->{input}->readMessageEnd();
+
+ return;
+}
+sub shutdown{
+ my $self = shift;
+ my $status = shift;
+
+ $self->send_shutdown($status);
+ $self->recv_shutdown();
+}
+
+sub send_shutdown{
+ my $self = shift;
+ my $status = shift;
+
+ $self->{output}->writeMessageBegin('shutdown', TMessageType::CALL, $self->{seqid});
+ my $args = new ThriftHadoopFileSystem_shutdown_args();
+ $args->{status} = $status;
+ $args->write($self->{output});
+ $self->{output}->writeMessageEnd();
+ $self->{output}->getTransport()->flush();
+}
+
+sub recv_shutdown{
+ my $self = shift;
+
+ my $rseqid = 0;
+ my $fname;
+ my $mtype = 0;
+
+ $self->{input}->readMessageBegin(\$fname, \$mtype, \$rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ my $x = new TApplicationException();
+ $x->read($self->{input});
+ $self->{input}->readMessageEnd();
+ die $x;
+ }
+ my $result = new ThriftHadoopFileSystem_shutdown_result();
+ $result->read($self->{input});
+ $self->{input}->readMessageEnd();
+
+ return;
+}
+sub create{
+ my $self = shift;
+ my $path = shift;
+
+ $self->send_create($path);
+ return $self->recv_create();
+}
+
+sub send_create{
+ my $self = shift;
+ my $path = shift;
+
+ $self->{output}->writeMessageBegin('create', TMessageType::CALL, $self->{seqid});
+ my $args = new ThriftHadoopFileSystem_create_args();
+ $args->{path} = $path;
+ $args->write($self->{output});
+ $self->{output}->writeMessageEnd();
+ $self->{output}->getTransport()->flush();
+}
+
+sub recv_create{
+ my $self = shift;
+
+ my $rseqid = 0;
+ my $fname;
+ my $mtype = 0;
+
+ $self->{input}->readMessageBegin(\$fname, \$mtype, \$rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ my $x = new TApplicationException();
+ $x->read($self->{input});
+ $self->{input}->readMessageEnd();
+ die $x;
+ }
+ my $result = new ThriftHadoopFileSystem_create_result();
+ $result->read($self->{input});
+ $self->{input}->readMessageEnd();
+
+ if (defined $result->{success} ) {
+ return $result->{success};
+ }
+ if (defined $result->{ouch}) {
+ die $result->{ouch};
+ }
+ die "create failed: unknown result";
+}
+sub createFile{
+ my $self = shift;
+ my $path = shift;
+ my $mode = shift;
+ my $overwrite = shift;
+ my $bufferSize = shift;
+ my $block_replication = shift;
+ my $blocksize = shift;
+
+ $self->send_createFile($path, $mode, $overwrite, $bufferSize, $block_replication, $blocksize);
+ return $self->recv_createFile();
+}
+
+sub send_createFile{
+ my $self = shift;
[... 1092 lines stripped ...]