com.indeed.lsmtree.recordcache

Class PersistentRecordCache<K,V>

java.lang.Object

com.indeed.lsmtree.recordcache.PersistentRecordCache<K,V>

All Implemented Interfaces:

RecordCache<K,V>, Closeable, AutoCloseable

public final class PersistentRecordCache<K,V>
extends Object
implements RecordCache<K,V>

Author:

jplaisance

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PersistentRecordCache.Builder<K,V>

Method Summary

Modifier and Type	Method and Description
void	close() Close the cache.
V	get(K key, CacheStats cacheStats) Performs lookup for single key.
Map<K,V>	getAll(Collection<K> keys, CacheStats cacheStats) Performs batch lookup for multiple keys.
RecordLogDirectoryPoller.Functions	getFunctions() Update functions to be registered with a RecordLogDirectoryPoller
long	getIndexActiveSpaceUsage()
long	getIndexFreeSpace()
long	getIndexReservedSpaceUsage()
long	getIndexTotalSpaceUsage()
int	getRepairedSegments()
Iterator<com.indeed.util.core.Either<Exception,fj.P2<K,V>>>	getStreaming(Iterator<K> keys, AtomicInteger progress, AtomicInteger skipped) Performs lookup for multiple keys and returns a streaming iterator to results.
void	waitForCompactions() Blocks until compactions are complete.

Methods inherited from class java.lang.Object

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

Method Detail

getRepairedSegments

public int getRepairedSegments()

getIndexActiveSpaceUsage

public long getIndexActiveSpaceUsage()
                              throws IOException

Throws:

IOException

getIndexTotalSpaceUsage

public long getIndexTotalSpaceUsage()
                             throws IOException

Throws:

IOException

getIndexReservedSpaceUsage

public long getIndexReservedSpaceUsage()

getIndexFreeSpace

public long getIndexFreeSpace()
                       throws IOException

Throws:

IOException

get

@Nullable
public V get(@Nonnull
                       K key,
                       @Nonnull
                       CacheStats cacheStats)

Performs lookup for single key.

Specified by:

get in interface RecordCache<K,V>

Parameters:

key - key to lookup

cacheStats - stats

Returns:

value for lookup key, or null if not found

getAll

@Nonnull
public Map<K,V> getAll(@Nonnull
                                Collection<K> keys,
                                @Nonnull
                                CacheStats cacheStats)

Performs batch lookup for multiple keys.

Specified by:

getAll in interface RecordCache<K,V>

Parameters:

keys - keys to lookup

cacheStats - stats

Returns:

map of found keys to their values

getStreaming

public Iterator<com.indeed.util.core.Either<Exception,fj.P2<K,V>>> getStreaming(@Nonnull
                                                                                Iterator<K> keys,
                                                                                @Nullable
                                                                                AtomicInteger progress,
                                                                                @Nullable
                                                                                AtomicInteger skipped)

Performs lookup for multiple keys and returns a streaming iterator to results. Each element in the iterator is one of (1) an exception associated with a single lookup (2) a key value tuple

Parameters:

keys - lookup keys

progress - (optional) an AtomicInteger for tracking progress

skipped - (optional) an AtomicInteger for tracking missing keys

Returns:

iterator of lookup results

getFunctions

public RecordLogDirectoryPoller.Functions getFunctions()

Update functions to be registered with a RecordLogDirectoryPoller

Specified by:

getFunctions in interface RecordCache<K,V>

Returns:

callback functions

close

public void close()
           throws IOException

Close the cache.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException - if an I/O error occurs

waitForCompactions

public void waitForCompactions()
                        throws InterruptedException

Blocks until compactions are complete.

Throws:

InterruptedException - when interrupted during operation