co.cask.cdap.data2.transaction.queue.leveldb

Class LevelDBQueueEvictor

java.lang.Object

co.cask.cdap.data2.transaction.queue.leveldb.LevelDBQueueEvictor

All Implemented Interfaces:

QueueEvictor

public class LevelDBQueueEvictor
extends Object
implements QueueEvictor

An evictor for the levelDB based queues.

Field Summary

Fields inherited from interface co.cask.cdap.data2.transaction.queue.QueueEvictor

NOOP

Constructor Summary

Constructors

Constructor and Description
LevelDBQueueEvictor(LevelDBTableCore core, QueueName queueName, int numGroups, Executor executor)

Method Summary

Methods

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<Integer>	evict(co.cask.tephra.Transaction transaction) Performs queue eviction in the given transaction context.

Methods inherited from class java.lang.Object

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

Constructor Detail

LevelDBQueueEvictor

public LevelDBQueueEvictor(LevelDBTableCore core,
                   QueueName queueName,
                   int numGroups,
                   Executor executor)

Method Detail

evict

public com.google.common.util.concurrent.ListenableFuture<Integer> evict(co.cask.tephra.Transaction transaction)

Description copied from interface: QueueEvictor

Performs queue eviction in the given transaction context.

Specified by:

evict in interface QueueEvictor

Parameters:

transaction - The transaction context that the eviction happens.

Returns:

A ListenableFuture that will be completed when eviction is done. The future result carries number of entries being evicted.