Class InMemoryExpiredWorkSelector
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.queue.cleaner.InMemoryExpiredWorkSelector
-
- All Implemented Interfaces:
com.snowflake.connectors.taskreactor.queue.cleaner.ExpiredWorkSelector
public class InMemoryExpiredWorkSelector extends Object implements com.snowflake.connectors.taskreactor.queue.cleaner.ExpiredWorkSelector
In memory implementation ofExpiredWorkSelector
.
-
-
Constructor Summary
Constructors Constructor Description InMemoryExpiredWorkSelector()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addIdentifiers(List<String> ids)
Adds new queue item ids for selection.void
clear()
Clears this selector.List<String>
getExpired(String viewName)
-
-
-
Method Detail
-
getExpired
public List<String> getExpired(String viewName)
- Specified by:
getExpired
in interfacecom.snowflake.connectors.taskreactor.queue.cleaner.ExpiredWorkSelector
-
addIdentifiers
public void addIdentifiers(List<String> ids)
Adds new queue item ids for selection.- Parameters:
ids
- queue item ids
-
clear
public void clear()
Clears this selector.
-
-