flink监控目录并采集新增文件

Apache Flink提供了一个文件系统监听器，可以监控特定目录中的文件并在新文件出现时触发数据处理。您可以使用FileSystem.watchForNewFiles(path, interval)方法实现文件监听。其中，path是您要监控的目录，interval是文件系统监听器检查新文件的时间间隔。