Add streaming Listener to Stop after first Iterati

2019-09-09 09:16发布

问题:

I need to know how implement Streaming Listener to Stop a Streaming application.

I need a small example with Dependencies, imports and implement Codes.

Similar to detecting connection lost in spark streaming

Can you Help me?