Package com.snowflake.connectors.application.scheduler

Class RunSchedulerIterationHandler

java.lang.Object

com.snowflake.connectors.application.scheduler.RunSchedulerIterationHandler

public class RunSchedulerIterationHandler
extends Object

Handler for running a scheduler iteration. 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 configuration failure, used by the ConnectorErrorHelper.

Method Summary

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

See Also:

Constant Field Values

Method Detail

runIteration

public static Variant runIteration(Session session)

Default handler method for the PUBLIC.RUN_SCHEDULER_ITERATION procedure.

Parameters:

session - Snowpark session object

Returns:

a variant representing the ConnectorResponse returned by runIteration

builder

public static RunSchedulerIterationHandlerBuilder builder(Session session)

Returns a new instance of RunSchedulerIterationHandlerBuilder.

Parameters:

session - Snowpark session object

Returns:

a new builder instance

runIteration

public ConnectorResponse runIteration()

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

The handler logic consists of running a new scheduler iteration via the runIteration method.

Returns:

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