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 ObjectNameSCHEDULER_TASKName of the scheduler task object.
-
Constructor Summary
Constructors Constructor Description Scheduler(CrudIngestionProcessRepository ingestionProcessRepository, OnIngestionScheduledCallback onIngestionScheduledCallback, TransactionManager transactionManager)Creates a newScheduler.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidrunIteration()Runs the next scheduler iteration.
-
-
-
Field Detail
-
SCHEDULER_TASK
public static final ObjectName SCHEDULER_TASK
Name of the scheduler task object.
-
-
Constructor Detail
-
Scheduler
public Scheduler(CrudIngestionProcessRepository ingestionProcessRepository, OnIngestionScheduledCallback onIngestionScheduledCallback, TransactionManager transactionManager)
Creates a newScheduler.- Parameters:
ingestionProcessRepository- ingestion process repositoryonIngestionScheduledCallback- callback called when the next scheduler iteration is runtransactionManager- transaction manager
-
-