欢迎投稿

今日深度:

用clojure查看hdfs文件系统,clojure查看hdfs

用clojure查看hdfs文件系统,clojure查看hdfs



(add-classpath "file:///usr/hadoop/hadoop/hadoop-core-0.20.2-cdh3u1.jar")
(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))


(def conf (new Configuration))
(. 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))

www.htsjk.Com true http://www.htsjk.com/Hadoop/31014.html NewsArticle 用clojure查看hdfs文件系统,clojure查看hdfs (add-classpath "file:///usr/hadoop/hadoop/hadoop-core-0.20.2-cdh3u1.jar") (add-classpath "file:///usr/hadoop/hadoop/lib/commons-logging-1.0.4.jar") (import '(java.io IOException)) (import...
相关文章
    暂无相关文章
评论暂时关闭