The base class for ClarityNLP aggregate tasks. Only gets called after all the other tasks of its related type are complete.
Main function that runs the collector.
Primary function where custom implementation of the collector is written.
Run custom custom cleanup after collector has run.
Main cleanup task that marks job as complete and runs custom cleanup tasks after collector is completed.