阅读了 Apache Flink 的几个文档页面(官方文档,dataArtisans),以及 官方存储库 中提供的示例后,我看到他们经常使用已下载的文件作为流数据源,并始终连接到本地主机。
我正在尝试使用 Apache Flink 下载包含动态数据的 JSON 文件。我的意图是尝试将可以访问 JSON 文件的 URL 建立为 Apache Flink 的输入源,而不是使用另一个系统下载并使用 Apache Flink 处理已下载的文件。
是否可以使用 Apache Flink 建立此网络连接?
我正在尝试使用 Apache Flink 下载包含动态数据的 JSON 文件。我的意图是尝试将可以访问 JSON 文件的 URL 建立为 Apache Flink 的输入源,而不是使用另一个系统下载并使用 Apache Flink 处理已下载的文件。
是否可以使用 Apache Flink 建立此网络连接?
ContinuousFileMonitoringFunction
。流本身并不意味着作业将无限期运行。只有当您拥有非有限源时才会发生这种情况。但在这种情况下,env.fromElements
函数生成有限的流源。一旦此源到达其末尾,程序将终止。 - Till Rohrmann