Package com.snowflake.connectors.taskreactor.api

Class DispatcherHandler

java.lang.Object

com.snowflake.connectors.taskreactor.api.DispatcherHandler

public class DispatcherHandler
extends Object

Handler for the Task Reactor dispatcher.

Constructor Summary

Constructors

Constructor	Description
DispatcherHandler()

Method Summary

Modifier and Type	Method	Description
static String	dispatchWorkItems(Session session, String instanceSchema)	Default handler method for the TASK_REACTOR.DISPATCHER procedure.

Methods inherited from class java.lang.Object

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

Constructor Detail

DispatcherHandler

public DispatcherHandler()

Method Detail

dispatchWorkItems

public static String dispatchWorkItems(Session session,
                                       String instanceSchema)

Default handler method for the TASK_REACTOR.DISPATCHER procedure.

Parameters:

session - Snowpark session object

instanceSchema - task reactor instance name

Returns:

message about number of queue items consumed