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