There is a Java csv source operator inside the wayang sql api:
JavaCSVTableSource.
We should move it to the wayang-platforms/wayang-java module, specifically here and rename it to JavaCSVFileSource because it is reading from a file and not a table in the database.