Select specific folder in Flink Batch Job. When given a root path you can decide which file or folder to read in Flink specific folders
To use the partitioningBy Collector, you have to pass the Collectors.partitioningBy in the collect() method of Stream API.
Using Functional interfaces provided by Java we can become more functional. And Knowing them would help us utilise Stream API fully