Dispatcher (Snowflake Native SDK for Connectors - Java API Reference (2.2.0))

java.lang.Object
- com.snowflake.connectors.taskreactor.Dispatcher

```
public class Dispatcher
extends Object
```
Main task reactor task dispatcher.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`cancelOngoingExecution(QueueItem queueItem)`	Cancels ongoing executions for items with the same resource id as a provided queue item.
`String`	`execute()`	Executes the next dispatcher run.
`static Dispatcher`	`from(Session session, Identifier instanceSchema)`	Create a new `Dispatcher`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - from
```
public static Dispatcher from(Session session,
                              Identifier instanceSchema)
```
    Create a new Dispatcher.
    
    Parameters:
    
    session - Snowpark session object
    
    instanceSchema - Task Reactor instance name
    
    Returns:
    
    a new dispatcher
  - execute
```
public String execute()
```
    Executes the next dispatcher run.
    
    Returns:
    
    work items dispatching result
  - cancelOngoingExecution
```
public void cancelOngoingExecution(QueueItem queueItem)
```
    Cancels ongoing executions for items with the same resource id as a provided queue item.
    
    Parameters:
    
    queueItem - queue item