如文档中所述:
例如,数据管道可能会监视文件系统目录中的新文件并将其数据写入事件日志。另一个应用程序可能将事件流具体化到数据库或增量构建和细化搜索索引。
那么,如何在使用 Flink 的同时关注本地文件系统的文件更新呢?
在这里,该文件还提到:
流式传输的文件系统源仍在开发中。未来,社区将增加对常见流用例的支持,即分区和目录监控。
这是否意味着我可以使用 API 进行一些特殊的流式传输?如果您知道如何使用流式文件系统源,请告诉我。谢谢!
如文档中所述:
例如,数据管道可能会监视文件系统目录中的新文件并将其数据写入事件日志。另一个应用程序可能将事件流具体化到数据库或增量构建和细化搜索索引。
那么,如何在使用 Flink 的同时关注本地文件系统的文件更新呢?
在这里,该文件还提到:
流式传输的文件系统源仍在开发中。未来,社区将增加对常见流用例的支持,即分区和目录监控。
这是否意味着我可以使用 API 进行一些特殊的流式传输?如果您知道如何使用流式文件系统源,请告诉我。谢谢!