Is it possible to further add aggregation after the sink task executes? Or is the sink the last stage of the workflow? Is this flow possible?
start stream -> transform -> load (sink) -> mark final state as loaded in a table after all the load was successful in previous state (sink)
