Interface OnIngestionFinishedCallback
-
public interface OnIngestionFinishedCallback
Callback called when ingestion has been finished.Default implementation of this callback updates metadata of the finished ingestion process, and:
- if current status of the ingestion process is
IN_PROGRESS
, then next iteration is scheduled by changing the status toSCHEDULED
- if current status of the ingestion process is
COMPLETED
, then next iteration is not scheduled and the status is preserved
- if current status of the ingestion process is
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static OnIngestionFinishedCallback
getInstance(Session session)
Returns a new instance of the default callback implementation.void
onIngestionFinished(String processId, Variant metadata)
Action executed when the next ingestion is finished.
-
-
-
Method Detail
-
onIngestionFinished
void onIngestionFinished(String processId, Variant metadata)
Action executed when the next ingestion is finished.- Parameters:
processId
- ingestion process idmetadata
- new ingestion process metadata
-
getInstance
static OnIngestionFinishedCallback getInstance(Session session)
Returns a new instance of the default callback implementation.Default implementation of the callback uses a default implementation of
CrudIngestionProcessRepository
.- Parameters:
session
- Snowpark session object- Returns:
- a new callback instance
-
-