co.cask.cdap.data2.transaction.queue

Interface QueueEvictor

All Known Implementing Classes:

LevelDBQueueEvictor

public interface QueueEvictor

For performing queue eviction action.

Field Summary

Fields

Modifier and Type	Field and Description
static QueueEvictor	NOOP

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.

Field Detail

NOOP

static final QueueEvictor NOOP

Method Detail

evict

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

Performs queue eviction in the given transaction context.

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.