Как создать поток Map [String, Any] в flink [DataStream [Map [String, Any]] с использованием Scala?

Question

У нас есть потоковые данные (DataStream [String]), как показано ниже

key1 = value1 $$ key2 = value2 $$ key3 = value3 $$ key4 = value4 $$ key25 = value25 $$ key34 =значение34

А нам нужно преобразовать как DataStream [Map [String, String]]