Class | ThriftHadoopFileSystem::Client |
In: |
lib/thrift/thrift_hadoop_file_system.rb
|
Parent: | Object |
# File lib/thrift/thrift_hadoop_file_system.rb, line 90 def append(path) send_append(path) return recv_append() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 250 def chmod(path, mode) send_chmod(path, mode) recv_chmod() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 265 def chown(path, owner, group) send_chown(path, owner, group) recv_chown() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 138 def close(out) send_close(out) return recv_close() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 42 def create(path) send_create(path) return recv_create() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 58 def createFile(path, mode, overwrite, bufferSize, block_replication, blocksize) send_createFile(path, mode, overwrite, bufferSize, block_replication, blocksize) return recv_createFile() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 202 def exists(path) send_exists(path) return recv_exists() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 295 def getFileBlockLocations(path, start, length) send_getFileBlockLocations(path, start, length) return recv_getFileBlockLocations() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 234 def listStatus(path) send_listStatus(path) return recv_listStatus() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 186 def mkdirs(path) send_mkdirs(path) return recv_mkdirs() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 74 def open(path) send_open(path) return recv_open() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 122 def read(handle, offset, size) send_read(handle, offset, size) return recv_read() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 99 def recv_append() result = receive_message(Append_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'append failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 259 def recv_chmod() result = receive_message(Chmod_result) raise result.ouch unless result.ouch.nil? return end
# File lib/thrift/thrift_hadoop_file_system.rb, line 274 def recv_chown() result = receive_message(Chown_result) raise result.ouch unless result.ouch.nil? return end
# File lib/thrift/thrift_hadoop_file_system.rb, line 147 def recv_close() result = receive_message(Close_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'close failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 51 def recv_create() result = receive_message(Create_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'create failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 67 def recv_createFile() result = receive_message(CreateFile_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'createFile failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 211 def recv_exists() result = receive_message(Exists_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'exists failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 304 def recv_getFileBlockLocations() result = receive_message(GetFileBlockLocations_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getFileBlockLocations failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 243 def recv_listStatus() result = receive_message(ListStatus_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'listStatus failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 195 def recv_mkdirs() result = receive_message(Mkdirs_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'mkdirs failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 83 def recv_open() result = receive_message(Open_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'open failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 131 def recv_read() result = receive_message(Read_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'read failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 179 def recv_rename() result = receive_message(Rename_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'rename failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 163 def recv_rm() result = receive_message(Rm_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'rm failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 23 def recv_setInactivityTimeoutPeriod() result = receive_message(SetInactivityTimeoutPeriod_result) return end
# File lib/thrift/thrift_hadoop_file_system.rb, line 289 def recv_setReplication() result = receive_message(SetReplication_result) raise result.ouch unless result.ouch.nil? return end
# File lib/thrift/thrift_hadoop_file_system.rb, line 37 def recv_shutdown() result = receive_message(Shutdown_result) return end
# File lib/thrift/thrift_hadoop_file_system.rb, line 227 def recv_stat() result = receive_message(Stat_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'stat failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 115 def recv_write() result = receive_message(Write_result) return result.success unless result.success.nil? raise result.ouch unless result.ouch.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'write failed: unknown result') end
# File lib/thrift/thrift_hadoop_file_system.rb, line 170 def rename(path, dest) send_rename(path, dest) return recv_rename() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 154 def rm(path, recursive) send_rm(path, recursive) return recv_rm() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 95 def send_append(path) send_message('append', Append_args, :path => path) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 255 def send_chmod(path, mode) send_message('chmod', Chmod_args, :path => path, :mode => mode) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 270 def send_chown(path, owner, group) send_message('chown', Chown_args, :path => path, :owner => owner, :group => group) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 143 def send_close(out) send_message('close', Close_args, :out => out) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 47 def send_create(path) send_message('create', Create_args, :path => path) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 63 def send_createFile(path, mode, overwrite, bufferSize, block_replication, blocksize) send_message('createFile', CreateFile_args, :path => path, :mode => mode, :overwrite => overwrite, :bufferSize => bufferSize, :block_replication => block_replication, :blocksize => blocksize) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 207 def send_exists(path) send_message('exists', Exists_args, :path => path) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 300 def send_getFileBlockLocations(path, start, length) send_message('getFileBlockLocations', GetFileBlockLocations_args, :path => path, :start => start, :length => length) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 239 def send_listStatus(path) send_message('listStatus', ListStatus_args, :path => path) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 191 def send_mkdirs(path) send_message('mkdirs', Mkdirs_args, :path => path) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 79 def send_open(path) send_message('open', Open_args, :path => path) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 127 def send_read(handle, offset, size) send_message('read', Read_args, :handle => handle, :offset => offset, :size => size) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 175 def send_rename(path, dest) send_message('rename', Rename_args, :path => path, :dest => dest) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 159 def send_rm(path, recursive) send_message('rm', Rm_args, :path => path, :recursive => recursive) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 19 def send_setInactivityTimeoutPeriod(periodInSeconds) send_message('setInactivityTimeoutPeriod', SetInactivityTimeoutPeriod_args, :periodInSeconds => periodInSeconds) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 285 def send_setReplication(path, replication) send_message('setReplication', SetReplication_args, :path => path, :replication => replication) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 33 def send_shutdown(status) send_message('shutdown', Shutdown_args, :status => status) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 223 def send_stat(path) send_message('stat', Stat_args, :path => path) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 111 def send_write(handle, data) send_message('write', Write_args, :handle => handle, :data => data) end
# File lib/thrift/thrift_hadoop_file_system.rb, line 14 def setInactivityTimeoutPeriod(periodInSeconds) send_setInactivityTimeoutPeriod(periodInSeconds) recv_setInactivityTimeoutPeriod() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 280 def setReplication(path, replication) send_setReplication(path, replication) recv_setReplication() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 28 def shutdown(status) send_shutdown(status) recv_shutdown() end
# File lib/thrift/thrift_hadoop_file_system.rb, line 218 def stat(path) send_stat(path) return recv_stat() end