用clojure查看hdfs文件系统,clojure查看hdfs
(add-classpath "file:///usr/hadoop/hadoop/lib/commons-logging-1.0.4.jar")
(import '(java.io IOException))
(import '(org.apache.hadoop.conf Configuration))
(import '(org.apache.hadoop.fs FileSystem))
(import '(org.apache.hadoop.fs FileStatus))
(import '(org.apache.hadoop.fs Path))
(. conf addResource (new Path "/usr/hadoop/hadoop/conf/core-site.xml"))
(println (. conf get "fs.default.name"))
(def hdfs (. FileSystem get conf))
(println (. hdfs getName))
(def rootf (new Path "/"))
(. hdfs exists rootf)
(. hdfs listStatus rootf)
(for [file (. hdfs listStatus rootf)] (. file getPath))
本站文章为和通数据库网友分享或者投稿,欢迎任何形式的转载,但请务必注明出处.
同时文章内容如有侵犯了您的权益,请联系QQ:970679559,我们会在尽快处理。