Package com.snowflake.connectors.taskreactor.commands.processor.executors

Class PauseInstanceExecutor

java.lang.Object

com.snowflake.connectors.taskreactor.commands.processor.executors.PauseInstanceExecutor

All Implemented Interfaces:

CommandExecutor

public class PauseInstanceExecutor
extends Object
implements CommandExecutor

Executor of the PAUSE_INSTANCE command.

Method Summary

Modifier and Type	Method	Description
void	execute(Command command)	Pauses an instance of Task Reactor.
static PauseInstanceExecutor	getInstance(Session session, Identifier instanceName)	Creates new instance of PauseInstanceExecutor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInstance

public static PauseInstanceExecutor getInstance(Session session,
                                                Identifier instanceName)

Creates new instance of PauseInstanceExecutor.

Parameters:

session - Snowpark session object

instanceName - name of the Task Reactor instance

Returns:

new executor instance

execute

public void execute(Command command)

Pauses an instance of Task Reactor. It suspends all Task Reactor tasks: worker tasks and dispatcher task and changes isActive flag in INSTANCE_REGISTRY table.

Specified by:

execute in interface CommandExecutor

Parameters:

command - command to be executed - for PAUSE_INSTANCE command no payload is needed