Interface JobGraphStoreWatcher
-
- All Known Implementing Classes:
NoOpJobGraphStoreWatcher
,ZooKeeperJobGraphStoreWatcher
public interface JobGraphStoreWatcher
A watcher onJobGraphStore
. It could monitor all the changes on the job graph store and notify theJobGraphStore
viaJobGraphStore.JobGraphListener
.Important: The
JobGraphStoreWatcher
could not guarantee that there is noJobGraphStore.JobGraphListener
callbacks happen afterstop()
. So the implementor is responsible for filtering out these spurious callbacks.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
start(JobGraphStore.JobGraphListener jobGraphListener)
Start the watcher onJobGraphStore
.void
stop()
Stop the watcher onJobGraphStore
.
-
-
-
Method Detail
-
start
void start(JobGraphStore.JobGraphListener jobGraphListener) throws Exception
Start the watcher onJobGraphStore
.- Parameters:
jobGraphListener
- use jobGraphListener to notify theDefaultJobGraphStore
- Throws:
Exception
- when start internal services
-
stop
void stop() throws Exception
Stop the watcher onJobGraphStore
.- Throws:
Exception
- when stop internal services
-
-