(self, rm_address, addl_tags, queue_blacklist)
Get metrics from YARN scheduler
Get metrics from YARN scheduler
Get metrics from YARN scheduler
def _yarn_scheduler_metrics(self, rm_address, addl_tags, queue_blacklist):
        """
        Get metrics from YARN scheduler
        """
        metrics_json = self._rest_request_to_json(rm_address, YARN_SCHEDULER_PATH, addl_tags)

        try:
            metrics_json = metrics_json['scheduler']['schedulerInfo']

            if metrics_json['type'] == 'capacityScheduler':
                self._yarn_capacity_scheduler_metrics(metrics_json, addl_tags, queue_blacklist)

        except KeyError:
            pass
def _yarn_scheduler_metrics ( self , rm_address , addl_tags , queue_blacklist ) : metrics_json = self . _rest_request_to_json ( rm_address , YARN_SCHEDULER_PATH , addl_tags ) try : metrics_json = metrics_json [ 'scheduler' ] [ 'schedulerInfo' ] if metrics_json [ 'type' ] == 'capacityScheduler' : self . _yarn_capacity_scheduler_metrics ( metrics_json , addl_tags , queue_blacklist ) except KeyError : pass