Package com.snowflake.connectors.taskreactor.worker.queue

Interface WorkerQueueManager

  • public interface WorkerQueueManager
    Manager responsible for creating queues for given workers

    • Method Detail

      • createWorkerQueueIfNotExist

        void createWorkerQueueIfNotExist​(WorkerId workerId)
        Creates queue table and snowflake stream on this table if objects do not exist.
        Parameters:
        workerId - worker identifier

      • dropWorkerQueue

        void dropWorkerQueue​(WorkerId workerId)
        Removes snowflake table and stream for provided workerId.
        Parameters:
        workerId - worker identifier

      • getInstance

        static WorkerQueueManager getInstance​(Session session,
                                      Identifier schema)
        Returns a new instance of the default manager implementation.

        Default implementation of the manager uses:

        • a default implementation of DefaultWorkerQueueManager.
        Parameters:
        session - Snowpark session object
        schema - Schema of the Task Reactor
        Returns:
        a new manager instance