Flink提供一个ParameterTool工具类获取参数,提供fromArgs、fromPropertiesFile、fromMap、fromSystemProperties的方式
- fromArgs从main入参中获取
- fromPropertiesFile从文件中获取
- fromMap从map中获取
- fromSystemProperties从系统参数中获取
ParameterTool提供了get、getRequired、getInt、getLong、getFloat、getDouble、getBoolean、getShort、getByte等方法,每种类型的get均提供了一个支持defaultValue的方法
从args中获取
// 从args获取参数 |
从文件最中获取
def fromPropertiesFile(): Unit ={ |