spark_plugin.py
def _get_mesos_apps(self):
        """
        Retrieve all applications corresponding to Spark mesos cluster
        """
        resp = self.spark_agent.request_metrics(self.master, MESOS_MASTER_APP_PATH)
        apps = {}
        frameworks = {}
        if "frameworks" in resp:
            frameworks = resp["frameworks"]

        for app in frameworks:
            app_id = app.get("id")
            app_name = app.get("name")
            app_user = app.get("user")

            tracking_url = app.get("webui_url")
            if app_id and app_name and app_user and tracking_url:
                apps[app_id] = (app_name, app_user, tracking_url)
                self.metrics[(app_name, app_user)] = {}
        return apps

        Retrieve all applications corresponding to Spark mesos cluster
        
Retrieve all applications corresponding to Spark mesos cluster
Retrieve all applications corresponding to Spark mesos cluster
def _get_mesos_apps(self):
        resp = self.spark_agent.request_metrics(self.master, MESOS_MASTER_APP_PATH)
        apps = {}
        frameworks = {}
        if "frameworks" in resp:
            frameworks = resp["frameworks"]
        for app in frameworks:
            app_id = app.get("id")
            app_name = app.get("name")
            app_user = app.get("user")
            tracking_url = app.get("webui_url")
            if app_id and app_name and app_user and tracking_url:
                apps[app_id] = (app_name, app_user, tracking_url)
                self.metrics[(app_name, app_user)] = {}
        return apps
def _get_mesos_apps ( self ) : resp = self . spark_agent . request_metrics ( self . master , MESOS_MASTER_APP_PATH ) apps = { } frameworks = { } if "frameworks" in resp : frameworks = resp [ "frameworks" ] for app in frameworks : app_id = app . get ( "id" ) app_name = app . get ( "name" ) app_user = app . get ( "user" ) tracking_url = app . get ( "webui_url" ) if app_id and app_name and app_user and tracking_url : apps [ app_id ] = ( app_name , app_user , tracking_url ) self . metrics [ ( app_name , app_user ) ] = { } return apps
Retrieve all applications corresponding to Spark mesos cluster
Retrieve all applications corresponding to Spark mesos cluster
"""
        Retrieve all applications corresponding to Spark mesos cluster
        """
self