Hi,
>From what I see here
https://nightlies.apache.org/flink/flink-docs-release-1.14/api/java/org/apache/flink/connector/file/src/AbstractFileSource.AbstractFileSourceBuilder.html#setFileEnumerator-org.apache.flink.connector.file.src.enumerate.FileEnumerator.Provider-
the file enumerator can be setup with the FileSourceBuilder:

fileSourceBuilder.setFileEnumerator(new FileEnumerator.Provider() {
    @Override
    public FileEnumerator create() {
        // Do something
        return null;
    }
})


Hope it helps,
FG

Reply via email to