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
Tag:
Stream API
-
-
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