国产 无码 综合区,色欲AV无码国产永久播放,无码天堂亚洲国产AV,国产日韩欧美女同一区二区

記錄Java讀取hdfs上的文件全過程

這篇具有很好參考價(jià)值的文章主要介紹了記錄Java讀取hdfs上的文件全過程。希望對(duì)大家有所幫助。如果存在錯(cuò)誤或未考慮完全的地方,請(qǐng)大家不吝賜教,您也可以點(diǎn)擊"舉報(bào)違法"按鈕提交疑問。

文章目錄

前言

一、項(xiàng)目大體流程

二、詳細(xì)步驟

1.在idea里面創(chuàng)建空項(xiàng)目(小白也能看懂)

2.導(dǎo)入所需的jar包

2.輸入代碼后就可以實(shí)現(xiàn)了

總結(jié)


前言

? ? ? ? 跟著白哥學(xué)Java,今天就來分享一下Java如何上傳文件到hdfs上面,


提示:以下是一點(diǎn)見解

一、項(xiàng)目大體流程

? ? ? ? 我們想要上傳到hdfs,首先就得知道hdfs是什么東西:

? ? ? ? 本質(zhì):HDFS的中文翻譯是Hadoop分布式文件系統(tǒng)(Hadoop Distributed File System)。它本質(zhì)還是程序,主要還是以樹狀目錄結(jié)構(gòu)來管理文件(和linux類似,/表示根路徑),且可以運(yùn)行在多個(gè)節(jié)點(diǎn)上(即分布式)。

? ? ? ? 解決的問題:存儲(chǔ)海量離線數(shù)據(jù)(如TB、PB、ZB級(jí)別的數(shù)據(jù)),并且保證數(shù)據(jù)高可用,支持高并發(fā)訪問。注:不適合將大量的小文件存到HDFS。(主要原因:HDFS的NameNode進(jìn)程在內(nèi)存中存儲(chǔ)文件的元數(shù)據(jù),故文件越多,消耗的內(nèi)存就越大。大量的小文件,耗盡NameNode節(jié)點(diǎn)的內(nèi)存,而實(shí)際存的文件總量卻很小,HDFS存海量數(shù)據(jù)的優(yōu)勢(shì)沒有發(fā)揮出來)

? ? ? ? 架構(gòu):HDFS的架構(gòu)如下,其中在Linux端的詳細(xì)部署就不一一贅述了

java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

?我們的項(xiàng)目構(gòu)成如下:

java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

二、詳細(xì)步驟

1.在idea里面創(chuàng)建空項(xiàng)目(小白也能看懂)

圖解(示例):

java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

?java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

?注意:一般idea會(huì)自帶一個(gè)jdk是20以上的,如果版本不和心意,也可以點(diǎn)下載,選擇合適的jdkjava 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

?java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

?java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

?java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop?java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

?好的,這樣子我們就得到一個(gè)空項(xiàng)目了java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

2.導(dǎo)入所需的jar包

????????新建一個(gè)項(xiàng)目后,將HDFS相關(guān)的jar包引入到項(xiàng)目中,目的是調(diào)用HDFS提供的相關(guān)的類、方法。我們現(xiàn)在將所需要的jar依賴導(dǎo)入進(jìn)來,接下來要進(jìn)行導(dǎo)包:

java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

java 讀hdfs,java基礎(chǔ)+進(jìn)階,java,開發(fā)語(yǔ)言,ide,hdfs,hadoop

2.輸入代碼后就可以實(shí)現(xiàn)了

 public static void main(String[] args) throws IOException {
        if(args.length == 0){
            System.out.println("創(chuàng)建失敗,請(qǐng)傳入一個(gè)路徑參數(shù)指定要讀取的文件");
            return;
        }
        String feilePath = args[0];
        System.out.println("傳入的名字是:"+feilePath);

        //1.創(chuàng)建詞匯表Configuration類型的對(duì)象
        Configuration conf =  new Configuration();
        conf.set("fs.defaultFS","hdfs://20210322045-master:9000");

        FileSystem fs = FileSystem.get(conf);
        FSDataInputStream fsDataInputStream = fs.open(new Path(feilePath));
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(fsDataInputStream));

        //讀取文件第一行字符串,如果返回null,表明已經(jīng)讀取到文件的末尾
        String nextLine = bufferedReader.readLine();

        //如果沒有讀取到末尾,則繼續(xù)讀取
        while (null != nextLine){
            //將讀取到的數(shù)據(jù)輸出到控制臺(tái)
            System.out.println(nextLine);
            nextLine = bufferedReader.readLine();
        }
        fs.close();
    }

圖解(示例):

該處使用的url網(wǎng)絡(luò)請(qǐng)求的數(shù)據(jù)。


總結(jié)

提示:這里對(duì)文章進(jìn)行總結(jié):
例如:以上就是今天要講的內(nèi)容,本文僅僅簡(jiǎn)單介紹了pandas的使用,而pandas提供了大量能使我們快速便捷地處理數(shù)據(jù)的函數(shù)和方法。文章來源地址http://www.zghlxwxcb.cn/news/detail-692975.html

到了這里,關(guān)于記錄Java讀取hdfs上的文件全過程的文章就介紹完了。如果您還想了解更多內(nèi)容,請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!

本文來自互聯(lián)網(wǎng)用戶投稿,該文觀點(diǎn)僅代表作者本人,不代表本站立場(chǎng)。本站僅提供信息存儲(chǔ)空間服務(wù),不擁有所有權(quán),不承擔(dān)相關(guān)法律責(zé)任。如若轉(zhuǎn)載,請(qǐng)注明出處: 如若內(nèi)容造成侵權(quán)/違法違規(guī)/事實(shí)不符,請(qǐng)點(diǎn)擊違法舉報(bào)進(jìn)行投訴反饋,一經(jīng)查實(shí),立即刪除!

領(lǐng)支付寶紅包贊助服務(wù)器費(fèi)用

相關(guān)文章

  • ShaderToy著色器移植到Three.js全過程記錄

    ShaderToy著色器移植到Three.js全過程記錄

    推薦:用 NSDT設(shè)計(jì)器 快速搭建可編程3D場(chǎng)景。 作為 Publicis Pixelpark Innovationlab 研究的一部分,我們研究了如何將較低底層的語(yǔ)言用于網(wǎng)絡(luò)技術(shù)。 顯而易見的選擇似乎是 asm.js 或 WebAssembly。 但你也可以使用 WebGL 著色器來解決面向機(jī)器的問題。 著色器使用類似于 C/C++ 的語(yǔ)言進(jìn)行

    2024年02月13日
    瀏覽(24)
  • OpenWRT LEDE在Ubuntu22.04 編譯全過程記錄

    注, feeds用法 查看更新的訂閱源信息,index file feeds/packages.index 【問題1】m4 編譯錯(cuò)誤 解決,參考博文 【問題2】 freadahead 異常 解決,參考博文 注意 : 參考博文中的 _IO_IN_BAXKUP 應(yīng)該為 _IO_IN_BACKUP ,否則會(huì)導(dǎo)致下述報(bào)錯(cuò),此文為正確寫法 【問題3】 bison-3.0.4 相關(guān)錯(cuò)誤 解決,參考

    2024年02月12日
    瀏覽(41)
  • 記錄一次云原生線上服務(wù)數(shù)據(jù)遷移全過程

    記錄一次云原生線上服務(wù)數(shù)據(jù)遷移全過程

    校園 e 站,一群大學(xué)生在畢業(yè)前夕,為打破信息差而開發(fā)的一個(gè)校園論壇。一個(gè)從零到一全靠一群大學(xué)生的滿腔熱忱而打造的一個(gè)前后端分離以小程序?yàn)樽罱K展示載體的一個(gè)微服務(wù)架構(gòu)體系的 App。并發(fā)量的初始定位為 w 級(jí),使用到多級(jí)緩存、數(shù)據(jù)分庫(kù)等等前沿技術(shù),當(dāng)然這也

    2024年02月04日
    瀏覽(19)
  • 記錄在linux上使用科大訊飛的語(yǔ)音識(shí)別的全過程

    記錄在linux上使用科大訊飛的語(yǔ)音識(shí)別的全過程

    ? ? ? ? 1.網(wǎng)址訊飛開放平臺(tái)-以語(yǔ)音交互為核心的人工智能開放平臺(tái) (xfyun.cn)。 ? ? ? ? 2.登錄上述網(wǎng)站。 ? ? ? ? 3.點(diǎn)擊控制臺(tái),創(chuàng)建應(yīng)用。 ? ? ? ? 4.再在網(wǎng)頁(yè)中找到語(yǔ)音聽寫功能,就是本次需要使用到的語(yǔ)音轉(zhuǎn)文字功能,有很多入口可以進(jìn)入,進(jìn)入后請(qǐng)自行查看相關(guān)介

    2024年04月13日
    瀏覽(15)
  • 記錄--『uni-app、小程序』藍(lán)牙連接、讀寫數(shù)據(jù)全過程

    記錄--『uni-app、小程序』藍(lán)牙連接、讀寫數(shù)據(jù)全過程

    這里給大家分享我在網(wǎng)上總結(jié)出來的一些知識(shí),希望對(duì)大家有所幫助 這是一次真實(shí)的 藍(lán)牙收發(fā)數(shù)據(jù) 的全過程講解。 本文使用 uni-app + Vue3 的方式進(jìn)行開發(fā),以手機(jī)app的方式運(yùn)行(微信小程序同樣可行)。 uni-app 提供了 藍(lán)牙 和 低功耗藍(lán)牙 的 api ,和微信小程序提供的 api 是一樣

    2024年01月21日
    瀏覽(28)
  • Python Apex YOLO V5 6.2 目標(biāo)檢測(cè) 全過程記錄

    Python Apex YOLO V5 6.2 目標(biāo)檢測(cè) 全過程記錄

    博文目錄 效果展示 Python YOLO V5 實(shí)時(shí)截屏與目標(biāo)檢測(cè) GitHub Windows Python PyCharm 開發(fā)環(huán)境搭建 Windows Python PyTorch CUDA 11.7 TensorRT 環(huán)境配置 先根據(jù)上述兩篇文章將開發(fā)環(huán)境和虛擬環(huán)境都創(chuàng)建好, 然后下載 YOLO V5 6.2 或 YOLO V5 7.0 (最新) 的源碼, 用 PyCharm 打開, 選擇剛剛創(chuàng)建的虛擬環(huán)境 W

    2024年02月03日
    瀏覽(57)
  • (小白全過程記錄)Ubuntu下偽分布式Hadoop環(huán)境搭建

    (小白全過程記錄)Ubuntu下偽分布式Hadoop環(huán)境搭建

    目錄 0.準(zhǔn)備 1.Hadoop偽分布式環(huán)境搭建 2.安裝ssh,配置ssh無密碼登錄 3.通過拖拽的方式將文件從windows傳到linux桌面 5.安裝hadoop 6.修改hadoop環(huán)境變量 7.修改配置文件 core-site.xml 8.修改配置文件hdfs-site.xml文件 9.執(zhí)行NameNode的格式化 10.開啟NameNode和DataNode守護(hù)進(jìn)程 11.訪問web頁(yè)面 12.關(guān)閉

    2024年02月03日
    瀏覽(27)
  • 研一小白記錄第一次在實(shí)驗(yàn)室服務(wù)器上跑深度學(xué)習(xí)的代碼全過程(實(shí)驗(yàn)室服務(wù)器上跑代碼詳細(xì)全過程哦)

    研一小白記錄第一次在實(shí)驗(yàn)室服務(wù)器上跑深度學(xué)習(xí)的代碼全過程(實(shí)驗(yàn)室服務(wù)器上跑代碼詳細(xì)全過程哦)

    你在服務(wù)器上跑過代碼嗎?哇~你跑過!是啥樣的...每回見別人跑都會(huì)問并且羨慕會(huì)在大服務(wù)器上跑代碼的哈哈哈在研究生剛開學(xué)前還甚至不知道什么是服務(wù)器,更是無法想象在除了自己能看得見摸得著的電腦屏幕之外跑代碼的樣子。直到有天開會(huì)自己坐在了一個(gè)大大的“黑箱

    2024年02月02日
    瀏覽(31)
  • 在CentOS上用yum方式安裝MySQL8真實(shí)全過程記錄(順利版本)

    在CentOS上用yum方式安裝MySQL8真實(shí)全過程記錄(順利版本)

    此文參考我前面的文章《在CentOS上用yum方式安裝MySQL8過程記錄》,之前比較曲折,現(xiàn)在再安裝一臺(tái)mysql。 因?yàn)橹昂芏嗫右呀?jīng)走過,加上這臺(tái)Linux之前沒安裝過MYSQL,所以整個(gè)過程算是非常順利。 安裝環(huán)境:centos7 mysql版本:8.0.35 (為方便理解,以下為完整過程 ) 然后直接使

    2024年02月07日
    瀏覽(26)
  • 【基于Ubuntu20.04的Autoware.universe安裝過程】方案二:雙系統(tǒng) | 詳細(xì)記錄 | 全過程圖文 by.Akaxi

    【基于Ubuntu20.04的Autoware.universe安裝過程】方案二:雙系統(tǒng) | 詳細(xì)記錄 | 全過程圖文 by.Akaxi

    目錄 一、Autoware.universe背景 Part-1:安裝雙系統(tǒng)教程 二、查看Windows引導(dǎo)方式 三、制作安裝盤 四、設(shè)置電腦配置 1.關(guān)閉bitlocker 2.壓縮硬盤分區(qū) 3.關(guān)閉Secure Boot 4.關(guān)閉intel RST 5.BIOS設(shè)置U盤引導(dǎo) 五、安裝Ubuntu20.04 1.ventoy引導(dǎo) 2.安裝配置 3.安裝類型 4.完成安裝 Part-2:在Ubuntu20.04上安裝

    2024年04月11日
    瀏覽(29)

覺得文章有用就打賞一下文章作者

支付寶掃一掃打賞

博客贊助

微信掃一掃打賞

請(qǐng)作者喝杯咖啡吧~博客贊助

支付寶掃一掃領(lǐng)取紅包,優(yōu)惠每天領(lǐng)

二維碼1

領(lǐng)取紅包

二維碼2

領(lǐng)紅包