文档首页 > > 开发指南> Alluxio应用开发> 开发程序> Alluxio初始化

Alluxio初始化

分享
更新时间: 2020/03/20 GMT+08:00

功能简介

在使用Alluxio提供的API之前,需要先进行Alluxio初始化操作。过程为:

  1. 加载HDFS服务配置文件。
  2. 实例化Filesystem。
  3. 使用HDFS的API。

代码样例

如下是代码片段,详细代码请参考ExampleClient类。

/**
* load configurations from alluxio-site.properties
* @throws IOException
*/
private void loadConf() throws IOException {
InputStream fileInputStream = null;
alluxioConf = new Properties();
File propertiesFile = new File(PATH_TO_ALLUXIO_SITE_PROPERTIES);
try {
fileInputStream = new FileInputStream(propertiesFile);
alluxioConf.load(fileInputStream);
} catch (FileNotFoundException e) {
System.out.println(PATH_TO_ALLUXIO_SITE_PROPERTIES + "does not exist. Exception: " + e);
} catch (IOException e) {
System.out.println("Failed to load configuration file. Exception: " + e);
} finally{
close(fileInputStream);
}
}

/**
* build Alluxio instance
*/
private void instanceBuild() throws IOException {
// get filesystem
InstancedConfiguration conf = new InstancedConfiguration(ConfigurationUtils.defaults());
conf.set(PropertyKey.MASTER_RPC_ADDRESSES, alluxioConf.get("alluxio.master.rpc.addresses"));
FileSystemContext fsContext = FileSystemContext.create(conf);
fSystem = FileSystem.Factory.create(fsContext);
}
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问