Page History

...

For example, our JobStatusHook implementation is called CTASJobStatusHook, and use JdbcCatalog, the JdbcCatalog serialized by planner is like this :

...

'default-database' = '...',
'username' = '...',
'password' = '...',
'base-url' = '...'

JdbcCatalog serialized by Planner has been covered in the previous section and will not be repeated.

We get the new Catalog instance via FactoryUtil#createCatalogWe can get an empty instance of JdbcCatalog through the framework objenesis, and then read the default-database, username, password, base-url in the JdbcCatalog#deserialize method, so that a valid JdbcCatalog can be initialized. Then when the job status changes, the CTASJobStatusHook method can be called:

...