custom FileStreamSource which reads from one partition onwards
to my best knowledge, the existing FileStreamSource reads all the files in a directory (hive table).
However, I need to be able to specify an initial partition it should start from (i.e. like a Kafka offset/initial warmed-up state) and then only read data which is semantically (i.e. using a file path lexicographically) greater than the minimum committed initial state?