Class DefaultExpiredWorkSelector
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.queue.cleaner.DefaultExpiredWorkSelector
-
- All Implemented Interfaces:
ExpiredWorkSelector
public class DefaultExpiredWorkSelector extends Object implements ExpiredWorkSelector
Default implementation onfExpiredWorkSelector
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description List<String>
getExpired(String viewName)
Fetches all unreachable items from the WorkItemQueue.
-
-
-
Method Detail
-
getExpired
public List<String> getExpired(String viewName)
Description copied from interface:ExpiredWorkSelector
Fetches all unreachable items from the WorkItemQueue.- Specified by:
getExpired
in interfaceExpiredWorkSelector
- Parameters:
viewName
- Name of the view used for selecting items.- Returns:
- List of identifiers of unreachable items.
-
-