Module: FileUtils

Defined in:
lib/rake_hdfs/hdfs_fileutils.rb

Class Method Summary collapse

Class Method Details

.happend ⇒ Object 



77
78
79
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 77

def hdfs_append(path, body, options={})
  WebHDFS::FileUtils.append(path,body,options)
end

.hchmod ⇒ Object 



125
126
127
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 125

def hdfs_chmod(mode, list, options={})
  WebHDFS::FileUtils.chmod(mode, list, options)
end

.hchown ⇒ Object 



134
135
136
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 134

def hdfs_chown(user, group, list, options={})
  WebHDFS::FileUtils.chown(user, group, list, options)
end

.hcopy_from_local ⇒ Object 



53
54
55
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 53

def hdfs_copy_from_local(file, path, options={})
  WebHDFS::FileUtils.copy_from_local(file, path, options)
end

.hcopy_from_local_via_stream ⇒ Object 



60
61
62
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 60

def hdfs_copy_from_local_via_stream(file, path, options={})
  WebHDFS::FileUtils.copy_from_local_via_stream(file, path, options)
end

.hcopy_to_local ⇒ Object 



69
70
71
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 69

def hdfs_copy_to_local(path, file, options={})
  WebHDFS::FileUtils.copy_to_local(path, file, options)
end

.hdfs_append(path, body, options = {}) ⇒ Object 



72
73
74
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 72

def hdfs_append(path, body, options={})
  WebHDFS::FileUtils.append(path,body,options)
end

.hdfs_chmod(mode, list, options = {}) ⇒ Object 



119
120
121
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 119

def hdfs_chmod(mode, list, options={})
  WebHDFS::FileUtils.chmod(mode, list, options)
end

.hdfs_chown(user, group, list, options = {}) ⇒ Object 



128
129
130
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 128

def hdfs_chown(user, group, list, options={})
  WebHDFS::FileUtils.chown(user, group, list, options)
end

.hdfs_copy_from_local(file, path, options = {}) ⇒ Object 



48
49
50
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 48

def hdfs_copy_from_local(file, path, options={})
  WebHDFS::FileUtils.copy_from_local(file, path, options)
end

.hdfs_copy_from_local_via_stream(file, path, options = {}) ⇒ Object 



56
57
58
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 56

def hdfs_copy_from_local_via_stream(file, path, options={})
  WebHDFS::FileUtils.copy_from_local_via_stream(file, path, options)
end

.hdfs_copy_to_local(path, file, options = {}) ⇒ Object 



63
64
65
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 63

def hdfs_copy_to_local(path, file, options={})
  WebHDFS::FileUtils.copy_to_local(path, file, options)
end

.hdfs_exist?(path, options = {}) ⇒ Boolean

Returns:

  • (Boolean) 


179
180
181
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 179

def hdfs_exist?(path, options={})
   WebHDFS::FileUtils.exist?(path, options)
end

.hdfs_ls(path, options = {}) ⇒ Object 



163
164
165
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 163

def hdfs_ls(path, options={})
  WebHDFS::FileUtils.ls(path, options)
end

.hdfs_mkdir(list, options = {}) ⇒ Object 



80
81
82
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 80

def hdfs_mkdir(list, options={})
  WebHDFS::FileUtils.mkdir(list, options)
end

.hdfs_mkdir_p ⇒ Object 



89
90
91
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 89

def hdfs_mkdir(list, options={})
  WebHDFS::FileUtils.mkdir(list, options)
end

.hdfs_mtime(path, options = {}) ⇒ Object 



195
196
197
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 195

def hdfs_mtime(path, options={})
  WebHDFS::FileUtils.mtime(path, options)
end

.hdfs_rename(src, dst, options = {}) ⇒ Object 



110
111
112
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 110

def hdfs_rename(src, dst, options={})
  WebHDFS::FileUtils.rename(src, dst, options)
end

.hdfs_rm(list, options = {}) ⇒ Object 



95
96
97
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 95

def hdfs_rm(list, options={})
  WebHDFS::FileUtils.rm(list, options)
end

.hdfs_rmr(list, options = {}) ⇒ Object 



102
103
104
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 102

def hdfs_rmr(list, options={})
  WebHDFS::FileUtils.rmr(list, options)
end

.hdfs_set_atime(list, time, options = {}) ⇒ Object 



145
146
147
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 145

def hdfs_set_atime(list, time, options={})
  WebHDFS::FileUtils.set_atime(list, time, options)
end

.hdfs_set_mtime(list, time, options = {}) ⇒ Object 



154
155
156
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 154

def  hdfs_set_mtime(list, time, options={})
  WebHDFS::FileUtils.set_mtime(list, time, options)
end

.hdfs_set_repl_factor(list, num, options = {}) ⇒ Object 



137
138
139
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 137

def hdfs_set_repl_factor(list, num, options={})
  WebHDFS::FileUtils.set_repl_factor(list, num, options)
end

.hdfs_stat(path, options = {}) ⇒ Object 



171
172
173
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 171

def hdfs_stat(path, options={})
  WebHDFS::FileUtils.stat(path, options)
end

.hdfs_uptodate?(new, old_list, options = {}) ⇒ Boolean

Returns:

  • (Boolean) 


187
188
189
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 187

def hdfs_uptodate?(new, old_list, options={})
   WebHDFS::FileUtils.uptodate?(new, old_list, options)
end

.hexist? ⇒ Boolean

Returns:

  • (Boolean) 


184
185
186
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 184

def hdfs_exist?(path, options={})
   WebHDFS::FileUtils.exist?(path, options)
end

.hls ⇒ Object 



168
169
170
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 168

def hdfs_ls(path, options={})
  WebHDFS::FileUtils.ls(path, options)
end

.hmkdir ⇒ Object 



86
87
88
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 86

def hdfs_mkdir(list, options={})
  WebHDFS::FileUtils.mkdir(list, options)
end

.hmkdir_p ⇒ Object 



92
93
94
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 92

def hdfs_mkdir(list, options={})
  WebHDFS::FileUtils.mkdir(list, options)
end

.hmtime ⇒ Object 



200
201
202
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 200

def hdfs_mtime(path, options={})
  WebHDFS::FileUtils.mtime(path, options)
end

.hrename ⇒ Object 



116
117
118
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 116

def hdfs_rename(src, dst, options={})
  WebHDFS::FileUtils.rename(src, dst, options)
end

.hrm ⇒ Object 



99
100
101
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 99

def hdfs_rm(list, options={})
  WebHDFS::FileUtils.rm(list, options)
end

.hrmr ⇒ Object 



107
108
109
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 107

def hdfs_rmr(list, options={})
  WebHDFS::FileUtils.rmr(list, options)
end

.hset_atime ⇒ Object 



151
152
153
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 151

def hdfs_set_atime(list, time, options={})
  WebHDFS::FileUtils.set_atime(list, time, options)
end

.hset_mtime ⇒ Object 



160
161
162
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 160

def  hdfs_set_mtime(list, time, options={})
  WebHDFS::FileUtils.set_mtime(list, time, options)
end

.hset_repl_factor ⇒ Object 



142
143
144
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 142

def hdfs_set_repl_factor(list, num, options={})
  WebHDFS::FileUtils.set_repl_factor(list, num, options)
end

.hstat ⇒ Object 



176
177
178
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 176

def hdfs_stat(path, options={})
  WebHDFS::FileUtils.stat(path, options)
end

.huptodate? ⇒ Boolean

Returns:

  • (Boolean) 


192
193
194
 
# File 'lib/rake_hdfs/hdfs_fileutils.rb', line 192

def hdfs_uptodate?(new, old_list, options={})
   WebHDFS::FileUtils.uptodate?(new, old_list, options)
end