Class Scheduler


  • public class Scheduler
    extends Object
    Ingestion process scheduler.
    • Field Detail

      • SCHEDULER_TASK

        public static final ObjectName SCHEDULER_TASK
    • Constructor Detail

      • Scheduler

        public Scheduler​(CrudIngestionProcessRepository ingestionProcessRepository,
                         OnIngestionScheduledCallback onIngestionScheduledCallback)
        Creates a new Scheduler.
        Parameters:
        ingestionProcessRepository - ingestion process repository
        onIngestionScheduledCallback - callback called when the next scheduler iteration is run
    • Method Detail

      • runIteration

        public void runIteration()
        Runs the next scheduler iteration.