ThriftHadoopFileSystem.rb
上传用户:quxuerui
上传日期:2018-01-08
资源大小:41811k
文件大小:25k
源码类别:

网格计算

开发平台:

Java

  1. #
  2. # Autogenerated by Thrift
  3. #
  4. # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  5. #
  6. require 'thrift/protocol'
  7. require 'thrift'
  8. require 'hadoopfs_types'
  9. module ThriftHadoopFileSystem
  10.   class Client
  11.     include Thrift::Client
  12.     def setInactivityTimeoutPeriod(periodInSeconds)
  13.       send_setInactivityTimeoutPeriod(periodInSeconds)
  14.       recv_setInactivityTimeoutPeriod()
  15.     end
  16.     def send_setInactivityTimeoutPeriod(periodInSeconds)
  17.       send_message('setInactivityTimeoutPeriod', SetInactivityTimeoutPeriod_args, :periodInSeconds => periodInSeconds)
  18.     end
  19.     def recv_setInactivityTimeoutPeriod()
  20.       result = receive_message(SetInactivityTimeoutPeriod_result)
  21.       return
  22.     end
  23.     def shutdown(status)
  24.       send_shutdown(status)
  25.       recv_shutdown()
  26.     end
  27.     def send_shutdown(status)
  28.       send_message('shutdown', Shutdown_args, :status => status)
  29.     end
  30.     def recv_shutdown()
  31.       result = receive_message(Shutdown_result)
  32.       return
  33.     end
  34.     def create(path)
  35.       send_create(path)
  36.       return recv_create()
  37.     end
  38.     def send_create(path)
  39.       send_message('create', Create_args, :path => path)
  40.     end
  41.     def recv_create()
  42.       result = receive_message(Create_result)
  43.       return result.success unless result.success.nil?
  44.       raise result.ouch unless result.ouch.nil?
  45.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'create failed: unknown result')
  46.     end
  47.     def createFile(path, mode, overwrite, bufferSize, block_replication, blocksize)
  48.       send_createFile(path, mode, overwrite, bufferSize, block_replication, blocksize)
  49.       return recv_createFile()
  50.     end
  51.     def send_createFile(path, mode, overwrite, bufferSize, block_replication, blocksize)
  52.       send_message('createFile', CreateFile_args, :path => path, :mode => mode, :overwrite => overwrite, :bufferSize => bufferSize, :block_replication => block_replication, :blocksize => blocksize)
  53.     end
  54.     def recv_createFile()
  55.       result = receive_message(CreateFile_result)
  56.       return result.success unless result.success.nil?
  57.       raise result.ouch unless result.ouch.nil?
  58.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'createFile failed: unknown result')
  59.     end
  60.     def open(path)
  61.       send_open(path)
  62.       return recv_open()
  63.     end
  64.     def send_open(path)
  65.       send_message('open', Open_args, :path => path)
  66.     end
  67.     def recv_open()
  68.       result = receive_message(Open_result)
  69.       return result.success unless result.success.nil?
  70.       raise result.ouch unless result.ouch.nil?
  71.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'open failed: unknown result')
  72.     end
  73.     def append(path)
  74.       send_append(path)
  75.       return recv_append()
  76.     end
  77.     def send_append(path)
  78.       send_message('append', Append_args, :path => path)
  79.     end
  80.     def recv_append()
  81.       result = receive_message(Append_result)
  82.       return result.success unless result.success.nil?
  83.       raise result.ouch unless result.ouch.nil?
  84.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'append failed: unknown result')
  85.     end
  86.     def write(handle, data)
  87.       send_write(handle, data)
  88.       return recv_write()
  89.     end
  90.     def send_write(handle, data)
  91.       send_message('write', Write_args, :handle => handle, :data => data)
  92.     end
  93.     def recv_write()
  94.       result = receive_message(Write_result)
  95.       return result.success unless result.success.nil?
  96.       raise result.ouch unless result.ouch.nil?
  97.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'write failed: unknown result')
  98.     end
  99.     def read(handle, offset, size)
  100.       send_read(handle, offset, size)
  101.       return recv_read()
  102.     end
  103.     def send_read(handle, offset, size)
  104.       send_message('read', Read_args, :handle => handle, :offset => offset, :size => size)
  105.     end
  106.     def recv_read()
  107.       result = receive_message(Read_result)
  108.       return result.success unless result.success.nil?
  109.       raise result.ouch unless result.ouch.nil?
  110.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'read failed: unknown result')
  111.     end
  112.     def close(out)
  113.       send_close(out)
  114.       return recv_close()
  115.     end
  116.     def send_close(out)
  117.       send_message('close', Close_args, :out => out)
  118.     end
  119.     def recv_close()
  120.       result = receive_message(Close_result)
  121.       return result.success unless result.success.nil?
  122.       raise result.ouch unless result.ouch.nil?
  123.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'close failed: unknown result')
  124.     end
  125.     def rm(path, recursive)
  126.       send_rm(path, recursive)
  127.       return recv_rm()
  128.     end
  129.     def send_rm(path, recursive)
  130.       send_message('rm', Rm_args, :path => path, :recursive => recursive)
  131.     end
  132.     def recv_rm()
  133.       result = receive_message(Rm_result)
  134.       return result.success unless result.success.nil?
  135.       raise result.ouch unless result.ouch.nil?
  136.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'rm failed: unknown result')
  137.     end
  138.     def rename(path, dest)
  139.       send_rename(path, dest)
  140.       return recv_rename()
  141.     end
  142.     def send_rename(path, dest)
  143.       send_message('rename', Rename_args, :path => path, :dest => dest)
  144.     end
  145.     def recv_rename()
  146.       result = receive_message(Rename_result)
  147.       return result.success unless result.success.nil?
  148.       raise result.ouch unless result.ouch.nil?
  149.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'rename failed: unknown result')
  150.     end
  151.     def mkdirs(path)
  152.       send_mkdirs(path)
  153.       return recv_mkdirs()
  154.     end
  155.     def send_mkdirs(path)
  156.       send_message('mkdirs', Mkdirs_args, :path => path)
  157.     end
  158.     def recv_mkdirs()
  159.       result = receive_message(Mkdirs_result)
  160.       return result.success unless result.success.nil?
  161.       raise result.ouch unless result.ouch.nil?
  162.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'mkdirs failed: unknown result')
  163.     end
  164.     def exists(path)
  165.       send_exists(path)
  166.       return recv_exists()
  167.     end
  168.     def send_exists(path)
  169.       send_message('exists', Exists_args, :path => path)
  170.     end
  171.     def recv_exists()
  172.       result = receive_message(Exists_result)
  173.       return result.success unless result.success.nil?
  174.       raise result.ouch unless result.ouch.nil?
  175.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'exists failed: unknown result')
  176.     end
  177.     def stat(path)
  178.       send_stat(path)
  179.       return recv_stat()
  180.     end
  181.     def send_stat(path)
  182.       send_message('stat', Stat_args, :path => path)
  183.     end
  184.     def recv_stat()
  185.       result = receive_message(Stat_result)
  186.       return result.success unless result.success.nil?
  187.       raise result.ouch unless result.ouch.nil?
  188.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'stat failed: unknown result')
  189.     end
  190.     def listStatus(path)
  191.       send_listStatus(path)
  192.       return recv_listStatus()
  193.     end
  194.     def send_listStatus(path)
  195.       send_message('listStatus', ListStatus_args, :path => path)
  196.     end
  197.     def recv_listStatus()
  198.       result = receive_message(ListStatus_result)
  199.       return result.success unless result.success.nil?
  200.       raise result.ouch unless result.ouch.nil?
  201.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'listStatus failed: unknown result')
  202.     end
  203.     def chmod(path, mode)
  204.       send_chmod(path, mode)
  205.       recv_chmod()
  206.     end
  207.     def send_chmod(path, mode)
  208.       send_message('chmod', Chmod_args, :path => path, :mode => mode)
  209.     end
  210.     def recv_chmod()
  211.       result = receive_message(Chmod_result)
  212.       raise result.ouch unless result.ouch.nil?
  213.       return
  214.     end
  215.     def chown(path, owner, group)
  216.       send_chown(path, owner, group)
  217.       recv_chown()
  218.     end
  219.     def send_chown(path, owner, group)
  220.       send_message('chown', Chown_args, :path => path, :owner => owner, :group => group)
  221.     end
  222.     def recv_chown()
  223.       result = receive_message(Chown_result)
  224.       raise result.ouch unless result.ouch.nil?
  225.       return
  226.     end
  227.     def setReplication(path, replication)
  228.       send_setReplication(path, replication)
  229.       recv_setReplication()
  230.     end
  231.     def send_setReplication(path, replication)
  232.       send_message('setReplication', SetReplication_args, :path => path, :replication => replication)
  233.     end
  234.     def recv_setReplication()
  235.       result = receive_message(SetReplication_result)
  236.       raise result.ouch unless result.ouch.nil?
  237.       return
  238.     end
  239.     def getFileBlockLocations(path, start, length)
  240.       send_getFileBlockLocations(path, start, length)
  241.       return recv_getFileBlockLocations()
  242.     end
  243.     def send_getFileBlockLocations(path, start, length)
  244.       send_message('getFileBlockLocations', GetFileBlockLocations_args, :path => path, :start => start, :length => length)
  245.     end
  246.     def recv_getFileBlockLocations()
  247.       result = receive_message(GetFileBlockLocations_result)
  248.       return result.success unless result.success.nil?
  249.       raise result.ouch unless result.ouch.nil?
  250.       raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'getFileBlockLocations failed: unknown result')
  251.     end
  252.   end
  253.   class Processor
  254.     include Thrift::Processor
  255.     def process_setInactivityTimeoutPeriod(seqid, iprot, oprot)
  256.       args = read_args(iprot, SetInactivityTimeoutPeriod_args)
  257.       result = SetInactivityTimeoutPeriod_result.new()
  258.       @handler.setInactivityTimeoutPeriod(args.periodInSeconds)
  259.       write_result(result, oprot, 'setInactivityTimeoutPeriod', seqid)
  260.     end
  261.     def process_shutdown(seqid, iprot, oprot)
  262.       args = read_args(iprot, Shutdown_args)
  263.       result = Shutdown_result.new()
  264.       @handler.shutdown(args.status)
  265.       write_result(result, oprot, 'shutdown', seqid)
  266.     end
  267.     def process_create(seqid, iprot, oprot)
  268.       args = read_args(iprot, Create_args)
  269.       result = Create_result.new()
  270.       begin
  271.         result.success = @handler.create(args.path)
  272.       rescue ThriftIOException => ouch
  273.         result.ouch = ouch
  274.       end
  275.       write_result(result, oprot, 'create', seqid)
  276.     end
  277.     def process_createFile(seqid, iprot, oprot)
  278.       args = read_args(iprot, CreateFile_args)
  279.       result = CreateFile_result.new()
  280.       begin
  281.         result.success = @handler.createFile(args.path, args.mode, args.overwrite, args.bufferSize, args.block_replication, args.blocksize)
  282.       rescue ThriftIOException => ouch
  283.         result.ouch = ouch
  284.       end
  285.       write_result(result, oprot, 'createFile', seqid)
  286.     end
  287.     def process_open(seqid, iprot, oprot)
  288.       args = read_args(iprot, Open_args)
  289.       result = Open_result.new()
  290.       begin
  291.         result.success = @handler.open(args.path)
  292.       rescue ThriftIOException => ouch
  293.         result.ouch = ouch
  294.       end
  295.       write_result(result, oprot, 'open', seqid)
  296.     end
  297.     def process_append(seqid, iprot, oprot)
  298.       args = read_args(iprot, Append_args)
  299.       result = Append_result.new()
  300.       begin
  301.         result.success = @handler.append(args.path)
  302.       rescue ThriftIOException => ouch
  303.         result.ouch = ouch
  304.       end
  305.       write_result(result, oprot, 'append', seqid)
  306.     end
  307.     def process_write(seqid, iprot, oprot)
  308.       args = read_args(iprot, Write_args)
  309.       result = Write_result.new()
  310.       begin
  311.         result.success = @handler.write(args.handle, args.data)
  312.       rescue ThriftIOException => ouch
  313.         result.ouch = ouch
  314.       end
  315.       write_result(result, oprot, 'write', seqid)
  316.     end
  317.     def process_read(seqid, iprot, oprot)
  318.       args = read_args(iprot, Read_args)
  319.       result = Read_result.new()
  320.       begin
  321.         result.success = @handler.read(args.handle, args.offset, args.size)
  322.       rescue ThriftIOException => ouch
  323.         result.ouch = ouch
  324.       end
  325.       write_result(result, oprot, 'read', seqid)
  326.     end
  327.     def process_close(seqid, iprot, oprot)
  328.       args = read_args(iprot, Close_args)
  329.       result = Close_result.new()
  330.       begin
  331.         result.success = @handler.close(args.out)
  332.       rescue ThriftIOException => ouch
  333.         result.ouch = ouch
  334.       end
  335.       write_result(result, oprot, 'close', seqid)
  336.     end
  337.     def process_rm(seqid, iprot, oprot)
  338.       args = read_args(iprot, Rm_args)
  339.       result = Rm_result.new()
  340.       begin
  341.         result.success = @handler.rm(args.path, args.recursive)
  342.       rescue ThriftIOException => ouch
  343.         result.ouch = ouch
  344.       end
  345.       write_result(result, oprot, 'rm', seqid)
  346.     end
  347.     def process_rename(seqid, iprot, oprot)
  348.       args = read_args(iprot, Rename_args)
  349.       result = Rename_result.new()
  350.       begin
  351.         result.success = @handler.rename(args.path, args.dest)
  352.       rescue ThriftIOException => ouch
  353.         result.ouch = ouch
  354.       end
  355.       write_result(result, oprot, 'rename', seqid)
  356.     end
  357.     def process_mkdirs(seqid, iprot, oprot)
  358.       args = read_args(iprot, Mkdirs_args)
  359.       result = Mkdirs_result.new()
  360.       begin
  361.         result.success = @handler.mkdirs(args.path)
  362.       rescue ThriftIOException => ouch
  363.         result.ouch = ouch
  364.       end
  365.       write_result(result, oprot, 'mkdirs', seqid)
  366.     end
  367.     def process_exists(seqid, iprot, oprot)
  368.       args = read_args(iprot, Exists_args)
  369.       result = Exists_result.new()
  370.       begin
  371.         result.success = @handler.exists(args.path)
  372.       rescue ThriftIOException => ouch
  373.         result.ouch = ouch
  374.       end
  375.       write_result(result, oprot, 'exists', seqid)
  376.     end
  377.     def process_stat(seqid, iprot, oprot)
  378.       args = read_args(iprot, Stat_args)
  379.       result = Stat_result.new()
  380.       begin
  381.         result.success = @handler.stat(args.path)
  382.       rescue ThriftIOException => ouch
  383.         result.ouch = ouch
  384.       end
  385.       write_result(result, oprot, 'stat', seqid)
  386.     end
  387.     def process_listStatus(seqid, iprot, oprot)
  388.       args = read_args(iprot, ListStatus_args)
  389.       result = ListStatus_result.new()
  390.       begin
  391.         result.success = @handler.listStatus(args.path)
  392.       rescue ThriftIOException => ouch
  393.         result.ouch = ouch
  394.       end
  395.       write_result(result, oprot, 'listStatus', seqid)
  396.     end
  397.     def process_chmod(seqid, iprot, oprot)
  398.       args = read_args(iprot, Chmod_args)
  399.       result = Chmod_result.new()
  400.       begin
  401.         @handler.chmod(args.path, args.mode)
  402.       rescue ThriftIOException => ouch
  403.         result.ouch = ouch
  404.       end
  405.       write_result(result, oprot, 'chmod', seqid)
  406.     end
  407.     def process_chown(seqid, iprot, oprot)
  408.       args = read_args(iprot, Chown_args)
  409.       result = Chown_result.new()
  410.       begin
  411.         @handler.chown(args.path, args.owner, args.group)
  412.       rescue ThriftIOException => ouch
  413.         result.ouch = ouch
  414.       end
  415.       write_result(result, oprot, 'chown', seqid)
  416.     end
  417.     def process_setReplication(seqid, iprot, oprot)
  418.       args = read_args(iprot, SetReplication_args)
  419.       result = SetReplication_result.new()
  420.       begin
  421.         @handler.setReplication(args.path, args.replication)
  422.       rescue ThriftIOException => ouch
  423.         result.ouch = ouch
  424.       end
  425.       write_result(result, oprot, 'setReplication', seqid)
  426.     end
  427.     def process_getFileBlockLocations(seqid, iprot, oprot)
  428.       args = read_args(iprot, GetFileBlockLocations_args)
  429.       result = GetFileBlockLocations_result.new()
  430.       begin
  431.         result.success = @handler.getFileBlockLocations(args.path, args.start, args.length)
  432.       rescue ThriftIOException => ouch
  433.         result.ouch = ouch
  434.       end
  435.       write_result(result, oprot, 'getFileBlockLocations', seqid)
  436.     end
  437.   end
  438.   # HELPER FUNCTIONS AND STRUCTURES
  439.   class SetInactivityTimeoutPeriod_args
  440.     include Thrift::Struct
  441.     Thrift::Struct.field_accessor self, :periodInSeconds
  442.     FIELDS = {
  443.       1 => {:type => Thrift::Types::I64, :name => 'periodInSeconds'}
  444.     }
  445.   end
  446.   class SetInactivityTimeoutPeriod_result
  447.     include Thrift::Struct
  448.     FIELDS = {
  449.     }
  450.   end
  451.   class Shutdown_args
  452.     include Thrift::Struct
  453.     Thrift::Struct.field_accessor self, :status
  454.     FIELDS = {
  455.       1 => {:type => Thrift::Types::I32, :name => 'status'}
  456.     }
  457.   end
  458.   class Shutdown_result
  459.     include Thrift::Struct
  460.     FIELDS = {
  461.     }
  462.   end
  463.   class Create_args
  464.     include Thrift::Struct
  465.     Thrift::Struct.field_accessor self, :path
  466.     FIELDS = {
  467.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
  468.     }
  469.   end
  470.   class Create_result
  471.     include Thrift::Struct
  472.     Thrift::Struct.field_accessor self, :success, :ouch
  473.     FIELDS = {
  474.       0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle},
  475.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  476.     }
  477.   end
  478.   class CreateFile_args
  479.     include Thrift::Struct
  480.     Thrift::Struct.field_accessor self, :path, :mode, :overwrite, :bufferSize, :block_replication, :blocksize
  481.     FIELDS = {
  482.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
  483.       2 => {:type => Thrift::Types::I16, :name => 'mode'},
  484.       3 => {:type => Thrift::Types::BOOL, :name => 'overwrite'},
  485.       4 => {:type => Thrift::Types::I32, :name => 'bufferSize'},
  486.       5 => {:type => Thrift::Types::I16, :name => 'block_replication'},
  487.       6 => {:type => Thrift::Types::I64, :name => 'blocksize'}
  488.     }
  489.   end
  490.   class CreateFile_result
  491.     include Thrift::Struct
  492.     Thrift::Struct.field_accessor self, :success, :ouch
  493.     FIELDS = {
  494.       0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle},
  495.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  496.     }
  497.   end
  498.   class Open_args
  499.     include Thrift::Struct
  500.     Thrift::Struct.field_accessor self, :path
  501.     FIELDS = {
  502.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
  503.     }
  504.   end
  505.   class Open_result
  506.     include Thrift::Struct
  507.     Thrift::Struct.field_accessor self, :success, :ouch
  508.     FIELDS = {
  509.       0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle},
  510.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  511.     }
  512.   end
  513.   class Append_args
  514.     include Thrift::Struct
  515.     Thrift::Struct.field_accessor self, :path
  516.     FIELDS = {
  517.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
  518.     }
  519.   end
  520.   class Append_result
  521.     include Thrift::Struct
  522.     Thrift::Struct.field_accessor self, :success, :ouch
  523.     FIELDS = {
  524.       0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle},
  525.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  526.     }
  527.   end
  528.   class Write_args
  529.     include Thrift::Struct
  530.     Thrift::Struct.field_accessor self, :handle, :data
  531.     FIELDS = {
  532.       1 => {:type => Thrift::Types::STRUCT, :name => 'handle', :class => ThriftHandle},
  533.       -1 => {:type => Thrift::Types::STRING, :name => 'data'}
  534.     }
  535.   end
  536.   class Write_result
  537.     include Thrift::Struct
  538.     Thrift::Struct.field_accessor self, :success, :ouch
  539.     FIELDS = {
  540.       0 => {:type => Thrift::Types::BOOL, :name => 'success'},
  541.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  542.     }
  543.   end
  544.   class Read_args
  545.     include Thrift::Struct
  546.     Thrift::Struct.field_accessor self, :handle, :offset, :size
  547.     FIELDS = {
  548.       1 => {:type => Thrift::Types::STRUCT, :name => 'handle', :class => ThriftHandle},
  549.       -1 => {:type => Thrift::Types::I64, :name => 'offset'},
  550.       -2 => {:type => Thrift::Types::I32, :name => 'size'}
  551.     }
  552.   end
  553.   class Read_result
  554.     include Thrift::Struct
  555.     Thrift::Struct.field_accessor self, :success, :ouch
  556.     FIELDS = {
  557.       0 => {:type => Thrift::Types::STRING, :name => 'success'},
  558.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  559.     }
  560.   end
  561.   class Close_args
  562.     include Thrift::Struct
  563.     Thrift::Struct.field_accessor self, :out
  564.     FIELDS = {
  565.       1 => {:type => Thrift::Types::STRUCT, :name => 'out', :class => ThriftHandle}
  566.     }
  567.   end
  568.   class Close_result
  569.     include Thrift::Struct
  570.     Thrift::Struct.field_accessor self, :success, :ouch
  571.     FIELDS = {
  572.       0 => {:type => Thrift::Types::BOOL, :name => 'success'},
  573.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  574.     }
  575.   end
  576.   class Rm_args
  577.     include Thrift::Struct
  578.     Thrift::Struct.field_accessor self, :path, :recursive
  579.     FIELDS = {
  580.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
  581.       2 => {:type => Thrift::Types::BOOL, :name => 'recursive'}
  582.     }
  583.   end
  584.   class Rm_result
  585.     include Thrift::Struct
  586.     Thrift::Struct.field_accessor self, :success, :ouch
  587.     FIELDS = {
  588.       0 => {:type => Thrift::Types::BOOL, :name => 'success'},
  589.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  590.     }
  591.   end
  592.   class Rename_args
  593.     include Thrift::Struct
  594.     Thrift::Struct.field_accessor self, :path, :dest
  595.     FIELDS = {
  596.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
  597.       2 => {:type => Thrift::Types::STRUCT, :name => 'dest', :class => Pathname}
  598.     }
  599.   end
  600.   class Rename_result
  601.     include Thrift::Struct
  602.     Thrift::Struct.field_accessor self, :success, :ouch
  603.     FIELDS = {
  604.       0 => {:type => Thrift::Types::BOOL, :name => 'success'},
  605.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  606.     }
  607.   end
  608.   class Mkdirs_args
  609.     include Thrift::Struct
  610.     Thrift::Struct.field_accessor self, :path
  611.     FIELDS = {
  612.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
  613.     }
  614.   end
  615.   class Mkdirs_result
  616.     include Thrift::Struct
  617.     Thrift::Struct.field_accessor self, :success, :ouch
  618.     FIELDS = {
  619.       0 => {:type => Thrift::Types::BOOL, :name => 'success'},
  620.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  621.     }
  622.   end
  623.   class Exists_args
  624.     include Thrift::Struct
  625.     Thrift::Struct.field_accessor self, :path
  626.     FIELDS = {
  627.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
  628.     }
  629.   end
  630.   class Exists_result
  631.     include Thrift::Struct
  632.     Thrift::Struct.field_accessor self, :success, :ouch
  633.     FIELDS = {
  634.       0 => {:type => Thrift::Types::BOOL, :name => 'success'},
  635.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  636.     }
  637.   end
  638.   class Stat_args
  639.     include Thrift::Struct
  640.     Thrift::Struct.field_accessor self, :path
  641.     FIELDS = {
  642.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
  643.     }
  644.   end
  645.   class Stat_result
  646.     include Thrift::Struct
  647.     Thrift::Struct.field_accessor self, :success, :ouch
  648.     FIELDS = {
  649.       0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => FileStatus},
  650.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  651.     }
  652.   end
  653.   class ListStatus_args
  654.     include Thrift::Struct
  655.     Thrift::Struct.field_accessor self, :path
  656.     FIELDS = {
  657.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}
  658.     }
  659.   end
  660.   class ListStatus_result
  661.     include Thrift::Struct
  662.     Thrift::Struct.field_accessor self, :success, :ouch
  663.     FIELDS = {
  664.       0 => {:type => Thrift::Types::LIST, :name => 'success', :element => {:type => Thrift::Types::STRUCT, :class => FileStatus}},
  665.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  666.     }
  667.   end
  668.   class Chmod_args
  669.     include Thrift::Struct
  670.     Thrift::Struct.field_accessor self, :path, :mode
  671.     FIELDS = {
  672.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
  673.       2 => {:type => Thrift::Types::I16, :name => 'mode'}
  674.     }
  675.   end
  676.   class Chmod_result
  677.     include Thrift::Struct
  678.     Thrift::Struct.field_accessor self, :ouch
  679.     FIELDS = {
  680.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  681.     }
  682.   end
  683.   class Chown_args
  684.     include Thrift::Struct
  685.     Thrift::Struct.field_accessor self, :path, :owner, :group
  686.     FIELDS = {
  687.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
  688.       2 => {:type => Thrift::Types::STRING, :name => 'owner'},
  689.       3 => {:type => Thrift::Types::STRING, :name => 'group'}
  690.     }
  691.   end
  692.   class Chown_result
  693.     include Thrift::Struct
  694.     Thrift::Struct.field_accessor self, :ouch
  695.     FIELDS = {
  696.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  697.     }
  698.   end
  699.   class SetReplication_args
  700.     include Thrift::Struct
  701.     Thrift::Struct.field_accessor self, :path, :replication
  702.     FIELDS = {
  703.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
  704.       2 => {:type => Thrift::Types::I16, :name => 'replication'}
  705.     }
  706.   end
  707.   class SetReplication_result
  708.     include Thrift::Struct
  709.     Thrift::Struct.field_accessor self, :ouch
  710.     FIELDS = {
  711.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  712.     }
  713.   end
  714.   class GetFileBlockLocations_args
  715.     include Thrift::Struct
  716.     Thrift::Struct.field_accessor self, :path, :start, :length
  717.     FIELDS = {
  718.       1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname},
  719.       2 => {:type => Thrift::Types::I64, :name => 'start'},
  720.       3 => {:type => Thrift::Types::I64, :name => 'length'}
  721.     }
  722.   end
  723.   class GetFileBlockLocations_result
  724.     include Thrift::Struct
  725.     Thrift::Struct.field_accessor self, :success, :ouch
  726.     FIELDS = {
  727.       0 => {:type => Thrift::Types::LIST, :name => 'success', :element => {:type => Thrift::Types::STRUCT, :class => BlockLocation}},
  728.       1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException}
  729.     }
  730.   end
  731. end