Class QueueItemSelector
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.queue.selector.QueueItemSelector
-
public class QueueItemSelector extends Object
Class responsible for selection of items from the WorkItemQueue.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static QueueItemSelector
from(Session session, Identifier instanceSchema)
Returns a new instance of theQueueItemSelector
List<QueueItem>
getSelectedItemsFromQueue()
Selects items from WorkItemQueue based on Task Reactor configuration.
-
-
-
Method Detail
-
from
public static QueueItemSelector from(Session session, Identifier instanceSchema)
Returns a new instance of theQueueItemSelector
- Parameters:
session
- Snowpark session objectinstanceSchema
- Task Reactor schema instance- Returns:
- a new selector instance
-
-