Interface OnIngestionScheduledCallback
-
- All Known Implementing Classes:
TaskReactorOnIngestionScheduledCallback
public interface OnIngestionScheduledCallbackCallback called when the next scheduler iteration is run.Default implementation of this callback calls the
PUBLIC.ON_INGESTION_SCHEDULEDprocedure.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static OnIngestionScheduledCallbackgetInstance(Session session)Returns a new instance of the default callback implementation.voidonIngestionScheduled(List<String> processIds)Action executed when the next scheduler iteration is run.
-
-
-
Method Detail
-
onIngestionScheduled
void onIngestionScheduled(List<String> processIds)
Action executed when the next scheduler iteration is run.- Parameters:
processIds- ingestion process ids
-
getInstance
static OnIngestionScheduledCallback getInstance(Session session)
Returns a new instance of the default callback implementation.- Parameters:
session- Snowpark session object- Returns:
- a new callback instance
-
-