Package com.snowflake.connectors.taskreactor.api

Class ResumeInstanceHandler

java.lang.Object

com.snowflake.connectors.taskreactor.api.ResumeInstanceHandler

public class ResumeInstanceHandler
extends Object

Handler for the Task Reactor instance resuming process. A new instance of the handler must be created using the builder.

Field Summary

Fields

Modifier and Type	Field	Description
static String	ERROR_TYPE	Error type for the connection configuration failure, used by the ConnectorErrorHelper.

Method Summary

Modifier and Type	Method	Description
ConnectorResponse	resumeInstance(Identifier instanceSchema)	Executes the main logic of the handler, with logging using withExceptionLogging.
static Variant	resumeInstance(Session session, String instanceSchema)	Default handler method for the TASK_REACTOR.RESUME_INSTANCE procedure.

Methods inherited from class java.lang.Object

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

Field Detail

ERROR_TYPE

public static final String ERROR_TYPE

Error type for the connection configuration failure, used by the ConnectorErrorHelper.

See Also:

Constant Field Values

Method Detail

resumeInstance

public static Variant resumeInstance(Session session,
                                     String instanceSchema)

Default handler method for the TASK_REACTOR.RESUME_INSTANCE procedure.

It resumes the instance dispatcher task and inserts the RESUME_INSTANCE command into the Task Reactor command queue.

Parameters:

session - Snowpark session object

instanceSchema - task reactor instance name

Returns:

a variant representing the ConnectorResponse returned by resumeInstance

resumeInstance

public ConnectorResponse resumeInstance(Identifier instanceSchema)

Executes the main logic of the handler, with logging using withExceptionLogging.

Parameters:

instanceSchema - Task Reactor instance name

Returns:

a response with the code OK if the execution was successful, otherwise a response with an error code and an error message