Interface OnIngestionScheduledCallback

  • All Known Implementing Classes:
    SchedulerTaskReactorOnIngestionScheduled

    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 Detail

      • onIngestionScheduled

        void onIngestionScheduled​(String processId)
        Action executed when the next scheduler iteration is run.
        Parameters:
        processId - ingestion process id
      • 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