对于有大数据开发经验的同学,应该知道,我们经常会涉及到在运行job的时候,我们可能会从命令行手动传递参数,同时也可能使用某个外部的配置文件配置参数,然后在job任务中进行数据读取。
在flink中,我们经常使用到的参数读取工具类是ParameterTool,在flink的job开发中,我们一般采用如下的方式读取参数,例如:
#从命令行读取参数: ParameterTool parameters = ParameterTool.fromArgs(args); #从文件中读取参数: String propertiesFilePath = "/config/config1.properties"; ParameterTool tool = ParameterTool.fromPropertiesFile(propertiesFilePath);
这里的文件我们一般是放在本地的,目前不支持读取hdfs上的文件。读取进来之后,我们想要获取想要的值,使用tool.getXXX方法即可,例如:
int a = tool.getInt("a");
还没有评论,来说两句吧...