qileilove

          blog已經(jīng)轉移至github,大家請訪問 http://qaseven.github.io/

          Java 讀取Hadoop文件系統(tǒng)文件

           放一個hello的文件到Hadoop 文件系統(tǒng) 根目錄:
            [root@hadoop local]# touch hello
            [root@hadoop local]# vi hello
            [root@hadoop local]# hadoop fs -put hello /
            代碼:
          package hadoop.jack.javacallhadoop;
          import java.io.InputStream;
          import java.net.URL;
          import org.apache.hadoop.conf.Configuration;
          import org.apache.hadoop.fs.FsUrlStreamHandlerFactory;
          import org.apache.hadoop.io.IOUtils;
          public class App1 {
          public static String HDFS_PATH="hdfs://hadoop:9000/hello";
          /**
          * @param args
          */
          public static void main(String[] args) throws Exception{
          URL.setURLStreamHandlerFactory(new FsUrlStreamHandlerFactory());
          final URL url =new URL(HDFS_PATH);
          InputStream in = url.openStream();
          IOUtils.copyBytes(in, System.out, new Configuration());
          }
          }

          posted on 2014-07-24 09:55 順其自然EVO 閱讀(308) 評論(0)  編輯  收藏


          只有注冊用戶登錄后才能發(fā)表評論。


          網(wǎng)站導航:
           
          <2014年7月>
          293012345
          6789101112
          13141516171819
          20212223242526
          272829303112
          3456789

          導航

          統(tǒng)計

          常用鏈接

          留言簿(55)

          隨筆分類

          隨筆檔案

          文章分類

          文章檔案

          搜索

          最新評論

          閱讀排行榜

          評論排行榜

          主站蜘蛛池模板: 休宁县| 吴江市| 霍林郭勒市| 遂川县| 靖安县| 肥东县| 山东省| 阳原县| 陆川县| 桐庐县| 内黄县| 泾阳县| 玉屏| 象州县| 思茅市| 呈贡县| 罗定市| 浦北县| 南汇区| 邢台县| 曲靖市| 长兴县| 莱芜市| 剑河县| 株洲县| 太仓市| 青海省| 姚安县| 舒兰市| 聂荣县| 图们市| 武隆县| 玛多县| 宝应县| 正宁县| 嘉善县| 东辽县| 青浦区| 绍兴市| 遂昌县| 鸡东县|