Versions Compared

Old Version 49

changes.mady.by.user ron liu

Saved on

compared with

New Version 50

changes.mady.by.user ron liu

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

public class StreamGraph implements Pipeline {

    
    private final List<JobStatusHook> jobStatusHooks = new ArrayList<>();

    ... ...

    /** Registers the JobStatusHook. */
    void addJobStatusHook(List<JobStatusHook>JobStatusHook hook) {
        ...
    }
}

The final tasks of the job are all generated by Planner. We want to complete the create table/drop table through Hook on the JM side, so we need an API to register the Hook on the JM side.

...