As far as I can see from the example, you are trying to filter by key and
„flatten“ nested maps for each record. Both, data set and data stream API (from
the question it is unclear which one you would like to use, but it works with
both) provide transformations that can do this for you. For an o
I have a file, which each line is one json record
I run the following
val env = ExecutionEnvironment.getExecutionEnvironment
val data = env.readTextFile("file:///somefile")
.map(line => JSON.parseFull(line))
and get the following for one json record. For simplicity, the ke
