Hi All, As we add more features to support batch use cases, there will be a need to access more information about the DAG from an operator. One example is the need to access the operator name while using Batched StatsListener.
The idea here is to implement DAG Listener ( similar to StatsListener ), which can potentially give every information present in the Stram. Operators will also have visibility into all the major activities in the DAG. Thoughts? Thanks
