Class 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 of WorkerCombinedView.
    • Constructor Detail

      • InMemoryWorkerCombinedView

        public InMemoryWorkerCombinedView()
    • Method Detail

      • getWorkersExecuting

        public List<com.snowflake.connectors.taskreactor.worker.WorkerId> getWorkersExecuting​(List<String> ids)
        Specified by:
        getWorkersExecuting in interface com.snowflake.connectors.taskreactor.worker.WorkerCombinedView
      • getWorkersExecuting

        public Stream<com.snowflake.connectors.taskreactor.worker.WorkerId> getWorkersExecuting​(String resourceId)
        Specified by:
        getWorkersExecuting in interface com.snowflake.connectors.taskreactor.worker.WorkerCombinedView
      • recreate

        public void recreate​(List<com.snowflake.connectors.taskreactor.worker.WorkerId> workerIds)
        Specified by:
        recreate in interface com.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.