[ https://issues.apache.org/jira/browse/SPARK-7171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Andrew Or updated SPARK-7171: ----------------------------- Assignee: Jacek Lewandowski > Allow for more flexible use of metric sources > --------------------------------------------- > > Key: SPARK-7171 > URL: https://issues.apache.org/jira/browse/SPARK-7171 > Project: Spark > Issue Type: Improvement > Components: Spark Core > Affects Versions: 1.3.1 > Reporter: Jacek Lewandowski > Assignee: Jacek Lewandowski > Priority: Minor > Fix For: 1.5.0 > > > With the current API, the user is allowed to add a custom metric source by > providing its class in metrics configuration. Metrics themselves are provided > by Codahale and therefore they allow to register multiple metrics in a single > source. Basically we can break the available types of metrics into two types: > "push" and "pull" - by push metrics I mean that some execution code updates > the metric by itself either periodically or every n events. On the other > hand, the pull metrics include some function which pulls the data from the > execution environment, when triggered. > h5.Problem > The metric source is instantiated and registered during initialisation. Then, > the user has no way to access the instantiated object. It is also almost > impossible to access the execution environment of the current task. > Therefore, the user who wanted to provide his own {{RDD}} implementation > along with a dedicated metrics source, would find it very difficult to do > this in a safe, concise and elegant way. > h5.Proposed solution > At least, for the "push" metrics, it would be nice to be able to retrieve the > metrics source of particular type or with particular id from {{TaskContext}}. > It would allow custom tasks to update various metrics and would greatly > improve the usability of metrics. > This could be achieved quite easily since {{TaskContext}} is created by > {{Executor}}, which has access to the metrics system, it would inject some > method to retrieve the particular metrics source. > This solution wouldn't change the current API, but just introduce one more > method in {{TaskContext}}. -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org