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
