alluxio.client.file.cache.store

Class RocksPageStore

java.lang.Object

alluxio.client.file.cache.store.RocksPageStore

All Implemented Interfaces:

PageStore, java.lang.AutoCloseable

@NotThreadSafe
public class RocksPageStore
extends java.lang.Object
implements PageStore

A page store implementation which utilizes rocksDB to persist the data. This implementation will not be included to client jar by default to reduce client jar size.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.client.file.cache.PageStore

PageStore.Metrics

Method Summary

Modifier and Type	Method and Description
void	close()
org.rocksdb.RocksIterator	createNewInterator()
void	delete(PageId pageId) Deletes a page from the store.
int	get(PageId pageId, int pageOffset, int bytesToRead, PageReadTargetBuffer target, boolean isTemporary) Gets part of a page from the store to the destination buffer.
static RocksPageStore	open(PageStoreOptions pageStoreOptions)
void	put(PageId pageId, java.nio.ByteBuffer page, boolean isTemporary) Writes a new page from a source channel to the store.

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.PageStore

abort, commit, commit, create, get, get, put, put, putTemporary

Method Detail

open

public static RocksPageStore open(PageStoreOptions pageStoreOptions)

Parameters:

pageStoreOptions - options for the rocks page store

Returns:

a new instance of PageStore backed by RocksDB

Throws:

java.io.IOException - if I/O error happens

put

public void put(PageId pageId,
                java.nio.ByteBuffer page,
                boolean isTemporary)
         throws java.io.IOException

Description copied from interface: PageStore

Writes a new page from a source channel to the store.

Specified by:

put in interface PageStore

Parameters:

pageId - page identifier

page - page data

isTemporary - is page data temporary

Throws:

ResourceExhaustedException - when there is not enough space found on disk

java.io.IOException - when the store fails to write this page

get

public int get(PageId pageId,
               int pageOffset,
               int bytesToRead,
               PageReadTargetBuffer target,
               boolean isTemporary)
        throws java.io.IOException,
               PageNotFoundException

Description copied from interface: PageStore

Gets part of a page from the store to the destination buffer.

Specified by:

get in interface PageStore

Parameters:

pageId - page identifier

pageOffset - offset within page

bytesToRead - bytes to read in this page

target - destination buffer

isTemporary - is page data temporary

Returns:

the number of bytes read

Throws:

java.io.IOException - when the store fails to read this page

PageNotFoundException - when the page isn't found in the store

delete

public void delete(PageId pageId)
            throws PageNotFoundException

Description copied from interface: PageStore

Deletes a page from the store.

Specified by:

delete in interface PageStore

Parameters:

pageId - page identifier

Throws:

PageNotFoundException - when the page isn't found in the store

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

createNewInterator

public org.rocksdb.RocksIterator createNewInterator()

Returns:

a new iterator for the rocksdb