Package com.snowflake.connectors.taskreactor.queue.selector

Interface WorkSelector

  • public interface WorkSelector
    Class representing selection mechanism from WorkItemQueue.

    • Method Detail

      • selectItemsFromView

        List<QueueItem> selectItemsFromView​(String workSelectorView)
        Selects all items returned by the view.
        Parameters:
        workSelectorView - Name of the snowflake view to be selected from.
        Returns:
        Items from the view.

      • selectItemsUsingProcedure

        List<QueueItem> selectItemsUsingProcedure​(List<QueueItem> queueItems,
                                          String workSelectorProcedure)
        Calls selector procedure with provided queueItems.
        Parameters:
        queueItems - Items to be filtered by procedure.
        workSelectorProcedure - Snowflake procedure name.
        Returns:
        Filtered items.

      • getInstance

        static WorkSelector getInstance​(Session session)
        Gets a new instance of the default selector implementation.

        Default implementation of the selector uses:

        • a default implementation of DefaultWorkSelector.
        Parameters:
        session - Snowpark session object
        Returns:
        a new selector instance