我将尝试解释我的简化用例。有:
- 计算单词的 Spark 应用程序。
- 使用表单为网页提供服务的 Web 服务器。
- 可以在此表单中键入单词并提交的用户。
服务器接收到这个词并将其发送到 Spark 应用程序。Spark 应用程序根据一些数据将这个词作为输入,然后这个词启动一个重新计算的作业。一旦 Spark 完成计算,它会将结果发送到 Web 服务器,该服务器会在网页上显示结果。
问题是,我如何在 Spark 应用程序和 Web 服务器之间建立通信?
我想,spark-jobserver 或 spark-streaming 可以在这里帮助我,但我不确定。