[BEAM-734] Add support for Spark Streaming Listeners.

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: 0.3.0-incubating
• Component/s: runner-spark
• Assignee: Amit Sela
• Reporter: Amit Sela
• Created: 09/Oct/16 10:27
• Updated: 16/May/20 13:22
• Resolved: 14/Oct/16 10:55

Description

Spark has a mechanism for (async.) Streaming Listeners and they can be exposed via SparkPipelineOptions field.

First use-case I have for them is for testing, but they might prove useful in other ways as well.

Issue Links

• links to: GitHub Pull Request #1072