Class Scheduler
- java.lang.Object
-
- com.snowflake.connectors.application.scheduler.Scheduler
-
public class Scheduler extends Object
Ingestion process scheduler.
-
-
Field Summary
Fields Modifier and Type Field Description static ObjectName
SCHEDULER_TASK
-
Constructor Summary
Constructors Constructor Description Scheduler(CrudIngestionProcessRepository ingestionProcessRepository, OnIngestionScheduledCallback onIngestionScheduledCallback)
Creates a newScheduler
.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
runIteration()
Runs the next scheduler iteration.
-
-
-
Field Detail
-
SCHEDULER_TASK
public static final ObjectName SCHEDULER_TASK
-
-
Constructor Detail
-
Scheduler
public Scheduler(CrudIngestionProcessRepository ingestionProcessRepository, OnIngestionScheduledCallback onIngestionScheduledCallback)
Creates a newScheduler
.- Parameters:
ingestionProcessRepository
- ingestion process repositoryonIngestionScheduledCallback
- callback called when the next scheduler iteration is run
-
-