Advertisement

spark应用加载本地配置文件设置及解析流程

阅读量:

当在Spark集群中提交应用程序时,若需读取位于驱动节点本地的配置文件,例如:

复制代码
    ...
    spark-submit \
     -class ...
     -jars ...
     -jar ...
     file:///yourLocalFilePath/conf.properties
    
    
      
      
      
      
      
      
    

在对这一配置文件进行解析的过程中,常规做法是将其转换为HashMap结构,从而借助键值对的模式实现对配置参数的高效获取。具体实施方式如下:

复制代码
    package com.gendlee1991.utils
    
    
    import java.io.{FileInputStream, FileNotFoundException, InputStreamReader}
    import java.util.Properties
    
    import org.apache.commons.logging.LogFactory
    import org.apache.hadoop.conf.Configuration
    import org.apache.hadoop.fs.{FSDataInp

全部评论 (0)

还没有任何评论哟~