public static void writeConfiguration ( Configuration cfg , File file ) throws IOException { try ( FileWriter fwrt = new FileWriter ( file ) ; PrintWriter out = new PrintWriter ( fwrt ) ) { for ( String key : cfg . keySet ( ) ) { String value = cfg . getString ( key , null ) ; out . print ( key ) ; out . print ( ": " ) ; out . println ( value ) ; } } }
Writes a Flink YAML config file from a Flink Configuration object .