Interface OnIngestionFinishedCallback
-
public interface OnIngestionFinishedCallbackCallback 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 OnIngestionFinishedCallbackgetInstance(Session session)Returns a new instance of the default callback implementation.voidonIngestionFinished(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
-
-