Github user bOOm-X commented on the issue:
https://github.com/apache/spark/pull/18253
@vanzin
`GroupOfListener` is just a set of listeners, which handle all the metric
stuff. it allows to decouple this metric aspect from the `ListernerBus` and the
`LiveListenerBus`. And It allows to enforce the dependency model between
listeners (one message processed sequentially). I can change its name if you
want.
The `BusQueue` just handle the queuing / dequeueing generic processing,
which includes the consumer thread start an stop and the queuing strategy (drop
if full).
`WithListenerBus` is indeed just the declaration of the method implemented
in `ListenerBus`. This declaration is shared between the `LiveListenerBus` and
the `ReplayListenerBus`, and the UI listeners are added to them through it. The
`ListenerBus` still contains a simple synchronous implementation of them used
by the `ReplayListenerBus`. The `LiveListenerBus` has its own based on multiple
queues for some kind of set of listeners. I can rename this interface if you
want.
I will do a pass to try to fix the code style issues.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
