public class JobEventsSample extends java.lang.Object
The example starts a system monitoring application, then concurrently submits two jobs. The job monitoring application generates job event tuples when jobs are added or removed from registry, or when a job gets updated. Tuples are pushed to a sink, which prints them onto the system output.
Note that the original job events stream processing is executed by the JobRegistryService event listeners invoker thread. It is considered good practice to isolate the event source from the rest of the graph, in order for the processing of tuples to be executed by a different thread.
Copyright © 2017 The Apache Software Foundation. All Rights Reserved - 4744f56-20170226-1707