首页 > 其他分享 >【Flink】关于ParameterTool

【Flink】关于ParameterTool

时间:2023-03-17 22:15:26浏览次数:36  
标签:配置文件 Flink parameterTool 获取 关于 ParameterTool properties

1. ParameterTool简介

ParameterTool是Flink提供的读取程序启动参数,配置文件,环境变量以及Flink自身配置参数等配置的一个工具类。

2.ParameterTool使用实例

2.1 从启动参数中获取配置

程序启动时,传入参数  --name

获取参数:

ParameterTool parameterTool = ParameterTool.fromArgs(args);
parameterTool.get("name");
//output:hello

2.2 从程序中的properties中获取配置

在resources下新建配置文件:application.properties

内容如下:

final String fileName = "application.properties";
    InputStream inputStream = ParameterToolUserCase.class.getClassLoader().getResourceAsStream(fileName);
    ParameterTool parameterTool;
    try{
        parameterTool = ParameterTool.fromPropertiesFile(inputStream);
        System.out.println(parameterTool.get("name"));
        //output:hello
    } catch (IOException e){
        e.printStackTrace();
    }

2.3 从指定路径获取配置

我们也可以使用ParamteTool获取指定的路径的配置文件,这些配置文件需要在每个task节点都存在,否则可能获取不到:

新建D:\temp\study-flink\application.properties,内容如下:

 

标签:配置文件,Flink,parameterTool,获取,关于,ParameterTool,properties
From: https://www.cnblogs.com/qikaipei/p/17228336.html

相关文章