Class InMemoryWorkerCombinedView
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.worker.InMemoryWorkerCombinedView
-
- All Implemented Interfaces:
com.snowflake.connectors.taskreactor.worker.WorkerCombinedView
public class InMemoryWorkerCombinedView extends Object implements com.snowflake.connectors.taskreactor.worker.WorkerCombinedView
In memory implementation ofWorkerCombinedView
.
-
-
Constructor Summary
Constructors Constructor Description InMemoryWorkerCombinedView()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addExecutingWorkers(List<com.snowflake.connectors.taskreactor.worker.WorkerId> workerIds)
Adds new executing workers.void
clear()
Clears the list of executing workers.Stream<com.snowflake.connectors.taskreactor.worker.WorkerId>
getWorkersExecuting(String resourceId)
List<com.snowflake.connectors.taskreactor.worker.WorkerId>
getWorkersExecuting(List<String> ids)
void
recreate(List<com.snowflake.connectors.taskreactor.worker.WorkerId> workerIds)
-
-
-
Method Detail
-
getWorkersExecuting
public List<com.snowflake.connectors.taskreactor.worker.WorkerId> getWorkersExecuting(List<String> ids)
- Specified by:
getWorkersExecuting
in interfacecom.snowflake.connectors.taskreactor.worker.WorkerCombinedView
-
getWorkersExecuting
public Stream<com.snowflake.connectors.taskreactor.worker.WorkerId> getWorkersExecuting(String resourceId)
- Specified by:
getWorkersExecuting
in interfacecom.snowflake.connectors.taskreactor.worker.WorkerCombinedView
-
recreate
public void recreate(List<com.snowflake.connectors.taskreactor.worker.WorkerId> workerIds)
- Specified by:
recreate
in interfacecom.snowflake.connectors.taskreactor.worker.WorkerCombinedView
-
addExecutingWorkers
public void addExecutingWorkers(List<com.snowflake.connectors.taskreactor.worker.WorkerId> workerIds)
Adds new executing workers.- Parameters:
workerIds
- worker ids
-
clear
public void clear()
Clears the list of executing workers.
-
-