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

Class InMemoryWorkSelector

java.lang.Object

com.snowflake.connectors.taskreactor.queue.selector.InMemoryWorkSelector

All Implemented Interfaces:

com.snowflake.connectors.taskreactor.queue.selector.WorkSelector

public class InMemoryWorkSelector
extends Object
implements com.snowflake.connectors.taskreactor.queue.selector.WorkSelector

In memory implementation of WorkSelector.

Constructor Summary

Constructors

Constructor	Description
InMemoryWorkSelector()

Method Summary

Modifier and Type	Method	Description
void	addItems(List<com.snowflake.connectors.taskreactor.queue.QueueItem> items)	Adds new queue items for selection.
void	clear()	Clears this selector.
List<com.snowflake.connectors.taskreactor.queue.QueueItem>	selectItemsFromView(String workSelectorView)
List<com.snowflake.connectors.taskreactor.queue.QueueItem>	selectItemsUsingProcedure(List<com.snowflake.connectors.taskreactor.queue.QueueItem> queueItems, String workSelectorProcedure)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InMemoryWorkSelector

public InMemoryWorkSelector()

Method Detail

selectItemsFromView

public List<com.snowflake.connectors.taskreactor.queue.QueueItem> selectItemsFromView(String workSelectorView)

Specified by:

selectItemsFromView in interface com.snowflake.connectors.taskreactor.queue.selector.WorkSelector

selectItemsUsingProcedure

public List<com.snowflake.connectors.taskreactor.queue.QueueItem> selectItemsUsingProcedure(List<com.snowflake.connectors.taskreactor.queue.QueueItem> queueItems,
                                                                                            String workSelectorProcedure)

Specified by:

selectItemsUsingProcedure in interface com.snowflake.connectors.taskreactor.queue.selector.WorkSelector

addItems

public void addItems(List<com.snowflake.connectors.taskreactor.queue.QueueItem> items)

Adds new queue items for selection.

Parameters:

items - queue items

clear

public void clear()

Clears this selector.