Package com.snowflake.connectors.application.lifecycle.resume

Class ResumeConnectorHandler

java.lang.Object

com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandler

public class ResumeConnectorHandler
extends Object

Handler for the connector 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 connector resuming failure, used by the ConnectorErrorHelper.

Method Summary

Modifier and Type	Method	Description
static ResumeConnectorHandlerBuilder	builder(Session session)	Returns a new instance of ResumeConnectorHandlerBuilder.
ConnectorResponse	resumeConnector()	Executes the main logic of the handler, with logging using withExceptionLogging.
static Variant	resumeConnector(Session session)	Default handler method for the PUBLIC.RESUME_CONNECTOR 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 connector resuming failure, used by the ConnectorErrorHelper.

See Also:

Constant Field Values

Method Detail

resumeConnector

public static Variant resumeConnector(Session session)

Default handler method for the PUBLIC.RESUME_CONNECTOR procedure.

Parameters:

session - Snowpark session object

Returns:

a variant representing the ConnectorResponse returned by resumeConnector

builder

public static ResumeConnectorHandlerBuilder builder(Session session)

Returns a new instance of ResumeConnectorHandlerBuilder.

Parameters:

session - Snowpark session object

Returns:

a new builder instance

resumeConnector

public ConnectorResponse resumeConnector()

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

The handler logic consists of:

• connector privileges check
• connector status check
• ResumeConnectorStateValidator.validate()
• ResumeConnectorCallback.execute()
• ResumeConnectorSdkCallback.execute()
• InstanceStreamService.recreateStreams(Identifier) executed for all Task Reactor instances
• connector status update

If the callback execution returns a ROLLBACK code, any changes made by this handler are also rolled back.

Returns:

a response with the code OK if the execution was successful, a response with the code ROLLBACK if a rollback operation was performed, or a response with an error code and an error message