如何在web应用中运行spark job

如何在web应用中运行spark job

比如现在我需要看看使用A功能最多的用户是谁，然后我事先已经写好了一个jar包是专门用来实现该功能的。然后我可以在命令行中使用spark-submit的方式来提交该job，得到结果，但是现在我希望在代码中实现该操作。比如我用servlet，收到了前端发送过来的查找使用A功能最多的用户是谁的一个请求，然后我需要在servlet中执行spark-submit，得到结果后返回给前端。

spark的web监控页面 在sparkcontext中可以看到如下代码： 首先是创建一个spark application的web监控实例对象： 然后bind方法会绑定一个web服务器： 可以看出我们使用jetty服务器来监控程序的运行和显示spark集群的信息的。