WorkerOrchestrator (Snowflake Native SDK for Connectors - Java API Reference (2.1.0))

java.lang.Object
- com.snowflake.connectors.taskreactor.worker.registry.WorkerOrchestrator

public class WorkerOrchestrator
extends Object

A Task Reactor worker orchestrator.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static WorkerOrchestrator`	`from(Session session, Identifier instanceSchema)`	Creates a new `WorkerOrchestrator`.
`String`	`setWorkersNumber(int workersNumber)`	Sets the number of workers for the Task Reactor instance.

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

- Method Detail
  - from
```
public static WorkerOrchestrator from(Session session,
                                      Identifier instanceSchema)
```
    Creates a new WorkerOrchestrator.
    
    Parameters:
    
    session - Snowpark session object
    
    instanceSchema - Task Reactor instance name
    
    Returns:
    
    a new worker orchestrator
  - setWorkersNumber
```
public String setWorkersNumber(int workersNumber)
```
    Sets the number of workers for the Task Reactor instance.
    
    Parameters:
    
    workersNumber - new number of workers
    
    Returns:
    
    whether the workers number was changed