flink 使用 ParameterTool 解析命令行参数

说明

flink可以使用 ParameterTool 类,解析命令行参数,非常方便

使用

创建对象

创建对象时,传入 main() 方法的 args 参数,如下:

ParameterTool pt = ParameterTool.fromArgs(args);

判断参数是否存在

判断是否有 input 命令行参数

if(!pt.has("input")){
            throw new Exception("需要指定 input 参数,读取该文件!");
        }

idea携带命令行参数

参数前面要有 -input 或 --input

如下:

--input D:\测试数据.txt

获取参数

返回字符串

String input = pt.get("input");

返回 boolean

pt.getBoolean("key");

返回 int

pt.getInt("key");

返回 double

pt.getDouble("key");

没有该参数,返回默认值

String input = pt.get("port","9092");

支持上面各个类型


原文出处:/show_1IX4bwxw04Uz.html