通过hadoopAPI访问文件

<强>

<强>,,readFileByAPI(), <强> ,IOException {

配置配置=,<强> 强,配置();

conf.set (,),

文件系统fs=文件系统。 (参看);

路径路径=,<强> ,路径();

FSDataInputStream fis=fs.open(路径),

<强> []字节=,<强>, [1024],

<强> ,len=1;

ByteArrayOutputStream包=,<强> ,ByteArrayOutputStream ();

<强> ((len=fis.read(字节))!=1){

包。写(0字节,len);

}

系统。 .println(<强> ,字符串(baos.toByteArray ())),

fis.close ();

baos.close ();



}

,

第二种方式:

<强>

<强>,,readFileByAPI2(), <强> ,IOException {

配置配置=,<强> 强,配置();

conf.set (,),

文件系统fs=文件系统。 (参看);

路径路径=,<强> ,路径();

FSDataInputStream fis=fs.open(路径),

,包=,<强> ,ByteArrayOutputStream ();

IOUtils。 copyBytes (fis,包,1024);

系统。 .println(<强> ,字符串(baos.toByteArray ())),

fis.close ();

baos.close ();



}


通过hadoopAPI访问文件