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

All Known Implementing Classes:

DefaultWorkerCombinedView
```
public interface WorkerCombinedView
```
Utility for creating a combined view of worker queues.

Method Summary

All Methods Static Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`static WorkerCombinedView`	`getInstance(Session session, Identifier schema)`	Returns a new instance of the default view implementation.
`Stream<WorkerId>`	`getWorkersExecuting(String resourceId)`	Returns the ids of workers executing ingestion of a specified resource.
`List<WorkerId>`	`getWorkersExecuting(List<String> ids)`	Returns the ids of workers executing ingestion of a specified resource.
`void`	`recreate(List<WorkerId> workerIds)`	Replaces current view, with actual state of queues.

- Method Detail
  - getWorkersExecuting
```
List<WorkerId> getWorkersExecuting(List<String> ids)
```
    Returns the ids of workers executing ingestion of a specified resource.
    
    Parameters:
    
    ids - Identifiers of work queue items
    
    Returns:
    
    list of ids of workers executing ingestion of a specified resource
  - getWorkersExecuting
```
Stream<WorkerId> getWorkersExecuting(String resourceId)
```
    Returns the ids of workers executing ingestion of a specified resource.
    
    Parameters:
    
    resourceId - resource id
    
    Returns:
    
    list of ids of workers executing ingestion of a specified resource
  - recreate
```
void recreate(List<WorkerId> workerIds)
```
    Replaces current view, with actual state of queues.
    
    Parameters:
    
    workerIds - identifiers of currently active workers
  - getInstance
```
static WorkerCombinedView getInstance(Session session,
                                      Identifier schema)
```
    Returns a new instance of the default view implementation.
    Default implementation of the view uses:
    
    a default implementation of DefaultWorkerCombinedView, created for the view <schema>.WORKER_QUEUES table.
    Parameters:
    
    session - Snowpark session object
    
    schema - Schema of the Task Reactor
    
    Returns:
    
    a new view instance