Github user vanzin commented on the issue:
https://github.com/apache/spark/pull/18253
@bOOm-X
I pushed some code to my repo:
https://github.com/vanzin/spark/tree/SPARK-18838
Which is an attempt to do things the way I've been trying to explain. It
tries to keep changes as local as possible to `LiveListenerBus`, creating a few
types that implement the grouping and asynchronous behavior. You could do
filtering by extending the new `AsyncListener`, for example, and adding it to
the live listener bus.
It's just a p.o.c. so I cut a few corners (like metrics), and I only ran
`SparkListenerSuite`, but I'm just trying to show a different approach that
leaves the `ListenerBus` hierarchy mostly the same as now.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
