Stream API

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.

Stream API’s groupingBy is similar to GROUP BY of SQL since it groups and collects the objects based on given condition or value.

The Stream API, included in Java 8, is utilised for processing collections of objects. Stream API can make your code more simple, efficient, and readable.

Using Functional interfaces provided by Java we can become more functional. And Knowing them would help us utilise Stream API fully