Class ResumeTaskReactorService
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.lifecycle.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 Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ResumeTaskReactorService
getInstance(Session session)
Creates a new instance of the ResumeTaskReactorService.void
resumeAllInstances()
Resumes all Task Reactor instances defined in Instance Registryvoid
resumeInstance(Identifier instanceSchema)
Resumes a given Task Reactor instance
-
-
-
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
-
-