Class QueueItemCleaner
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.queue.cleaner.QueueItemCleaner
-
public class QueueItemCleaner extends Object
Class responsible for removal of obsolete items from the WorkItemQueue.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clean()
Removes obsolete items from WorkItemQueue.static QueueItemCleaner
from(Session session, Identifier instanceSchema)
Returns a new instance of theQueueItemCleaner
-
-
-
Method Detail
-
from
public static QueueItemCleaner from(Session session, Identifier instanceSchema)
Returns a new instance of theQueueItemCleaner
- Parameters:
session
- Snowpark session objectinstanceSchema
- Task Reactor schema instance- Returns:
- a new cleaner instance
-
clean
public void clean()
Removes obsolete items from WorkItemQueue.
-
-