MAPREDUCE服务 MRS-读Alluxio文件:代码样例

时间：2024-10-18 17:22:20

MAPREDUCE服务 MRS 开发Alluxio应用

代码样例

/**
* read file
* @throws java.io.IOException
*/
private void read() throws IOException {
	AlluxioURI path = new AlluxioURI(testFilePath);
	FileInStream in = null;
	try{
		in = fSystem.openFile(path);
		byte[] buffer = new byte[1024];
		int len;
		String content = "";
		while((len = in.read(buffer)) != -1){
			String bufferStr = new String(buffer,0, len);
			content += bufferStr;
		}
		System.out.println(content);
	}
	catch (Exception e){
		System.out.println("Failed to read file. Exception:" + e);
	}
	finally {
		close(in);
	}
}

上一篇：MAPREDUCE服务 MRS-准备MapReduce开发和运行环境:准备开发环境

下一篇：MAPREDUCE服务 MRS-Flink应用开发简介:基本概念