Interface OnIngestionScheduledCallback
-
- All Known Implementing Classes:
TaskReactorOnIngestionScheduledCallback
public interface OnIngestionScheduledCallback
Callback called when the next scheduler iteration is run.Default implementation of this callback calls the
PUBLIC.ON_INGESTION_SCHEDULED
procedure.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static OnIngestionScheduledCallback
getInstance(Session session)
Returns a new instance of the default callback implementation.void
onIngestionScheduled(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
-
-