Class ResumeTaskReactorService


  • public class ResumeTaskReactorService
    extends Object
    Service which is used to start the process of resuming the Task Reactor which was paused. It inserts RESUME_INSTANCE command into command queue and resumes the dispatcher's task. Then the Task Reactor instances are actually resumed by dispatcher which handles the command.
    • Method Detail

      • getInstance

        public static ResumeTaskReactorService getInstance​(Session session)
        Creates a new instance of the ResumeTaskReactorService.
        Parameters:
        session - Snowpark session object
        Returns:
        a new ResumeTaskReactorService instance
      • resumeInstance

        public void resumeInstance​(Identifier instanceSchema)
        Resumes a given Task Reactor instance
        Parameters:
        instanceSchema - name of the Task Reactor instance to be resumed
      • resumeAllInstances

        public void resumeAllInstances()
        Resumes all Task Reactor instances defined in Instance Registry