1. Parse input relation as input datasets 2. Extract lakesoul's table name during commit as output dataset 3. Extract spark's job name (app name) as job 4. Emit run event for every commit