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

java.lang.Object
- com.snowflake.connectors.taskreactor.worker.WorkerManager

public class WorkerManager
extends Object

A set of utilities for worker management.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static WorkerManager`	`from(Session session, Identifier instanceSchema)`	Creates a new `WorkerManager`.
`void`	`reconcileWorkersNumber()`	Recalculates the number of active workers.

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

- Method Detail
  - from
```
public static WorkerManager from(Session session,
                                 Identifier instanceSchema)
```
    Creates a new WorkerManager.
    
    Parameters:
    
    session - Snowpark session object
    
    instanceSchema - task reactor instance schema name
    
    Returns:
    
    new manager instance
  - reconcileWorkersNumber
```
public void reconcileWorkersNumber()
```
    Recalculates the number of active workers.