alluxio.worker.page

Class BlockPageEvictor

java.lang.Object

alluxio.worker.page.BlockPageEvictor

All Implemented Interfaces:

CacheEvictor

public class BlockPageEvictor
extends Object
implements CacheEvictor

Evictor for pages that belong to a block. Blocks that are not eligible for eviction because they are pinned, waiting to be persisted, etc., can be temporarily skipped from eviction by calling addPinnedBlock(long), and later calling removePinnedBlock(long) makes them eligible for eviction again.

Method Summary

Modifier and Type	Method and Description
boolean	addPinnedBlock(long blockId) Adds a pinned block that is prevented from eviction.
PageId	evict()
PageId	evictMatching(java.util.function.Predicate<PageId> criterion) Picks the first candidate for eviction that satisfies the given criterion.
boolean	removePinnedBlock(long blockId) Removes a pinned block that is prevented from eviction.
void	reset() Resets the evictor.
void	updateOnDelete(PageId pageId) Updates evictor after a delete operation.
void	updateOnGet(PageId pageId) Updates evictor after a get operation.
void	updateOnPut(PageId pageId) Updates evictor after a put operation.

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.client.file.cache.evictor.CacheEvictor

create

Method Detail

updateOnGet

public void updateOnGet(PageId pageId)

Description copied from interface: CacheEvictor

Updates evictor after a get operation.

Specified by:

updateOnGet in interface CacheEvictor

Parameters:

pageId - page identifier

updateOnPut

public void updateOnPut(PageId pageId)

Description copied from interface: CacheEvictor

Updates evictor after a put operation.

Specified by:

updateOnPut in interface CacheEvictor

Parameters:

pageId - page identifier

updateOnDelete

public void updateOnDelete(PageId pageId)

Description copied from interface: CacheEvictor

Updates evictor after a delete operation.

Specified by:

updateOnDelete in interface CacheEvictor

Parameters:

pageId - page identifier

evict

@Nullable
public PageId evict()

Specified by:

evict in interface CacheEvictor

Returns:

a page to evict or null if no page available to evict

evictMatching

@Nullable
public PageId evictMatching(java.util.function.Predicate<PageId> criterion)

Description copied from interface: CacheEvictor

Picks the first candidate for eviction that satisfies the given criterion.

Specified by:

evictMatching in interface CacheEvictor

Parameters:

criterion - criterion

Returns:

the eviction candidate, or null if none

reset

public void reset()

Description copied from interface: CacheEvictor

Resets the evictor.

Specified by:

reset in interface CacheEvictor

addPinnedBlock

public boolean addPinnedBlock(long blockId)

Adds a pinned block that is prevented from eviction. All pages belonging to that block will not be eligible for eviction until removePinnedBlock(long) is called for that block.

Parameters:

blockId - block id

Returns:

true if the block was not already pinned, false otherwise

removePinnedBlock

public boolean removePinnedBlock(long blockId)

Removes a pinned block that is prevented from eviction.

Parameters:

blockId - block id

Returns:

true if the block was pinned, false otherwise