建站
咨詢
售后
建站咨詢
新聞中心
/**
成都創(chuàng)新互聯(lián)服務(wù)項(xiàng)目包括港口網(wǎng)站建設(shè)、港口網(wǎng)站制作、港口網(wǎng)頁制作以及港口網(wǎng)絡(luò)營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，港口網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到港口省份的部分城市，未來相信會繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！
* 通過Hadoop api訪問
* @throws IOException
*/
@Test
public void readFileByAPI() throws IOException{
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://192.168.75.201:8020/");
FileSystem fs = FileSystem.get(conf);
Path path = new Path("/user/index.html");
FSDataInputStream fis =fs.open(path);
byte[] bytes = new byte[1024];
int len = -1;
ByteArrayOutputStream baos = new ByteArrayOutputStream();
while((len = fis.read(bytes))!=-1){
baos.write(bytes, 0, len);
}
System.out.println(new String(baos.toByteArray()));
fis.close();
baos.close();
}
第二種方式：
/**
* 通過hadoop api訪問
* @throws IOException
*/
@Test
public void readFileByAPI2() throws IOException{
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://192.168.75.201:8020/");
FileSystem fs = FileSystem.get(conf);
Path path = new Path("/user/index.html");
FSDataInputStream fis =fs.open(path);
ByteArrayOutputStream baos = new ByteArrayOutputStream();
IOUtils.copyBytes(fis, baos, 1024);
System.out.println(new String(baos.toByteArray()));
fis.close();
baos.close();
}
分享文章：通過hadoopAPI訪問文件
新聞來源：http://fisionsoft.com.cn/article/ijsjie.html
