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 SummaryAll Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclean()Removes obsolete items from WorkItemQueue.static QueueItemCleanerfrom(Session session, Identifier instanceSchema)Returns a new instance of theQueueItemCleaner
 
- 
- 
- 
Method Detail- 
frompublic static QueueItemCleaner from(Session session, Identifier instanceSchema) Returns a new instance of theQueueItemCleaner- Parameters:
- session- Snowpark session object
- instanceSchema- Task Reactor schema instance
- Returns:
- a new cleaner instance
 
 - 
cleanpublic void clean() Removes obsolete items from WorkItemQueue.
 
- 
 
-