public static interface JobGraphStore.JobGraphListener
JobGraphinstances. This is used to react to races between multiple running
JobGraphStoreinstances (on multiple job managers).
|Modifier and Type||Method and Description|
void onAddedJobGraph(JobID jobId)
JobGraphinstances added by a different
Important: It is possible to get false positives and be notified about a job graph, which was added by this instance.
JobIDof the added job graph
void onRemovedJobGraph(JobID jobId)
JobGraphinstances removed by a different
JobIDof the removed job graph
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.