alluxio.client.file.cache

Interface PageStore

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

LocalPageStore, MemoryPageStore, RocksPageStore, TimeBoundPageStore

public interface PageStore
extends AutoCloseable

A simple abstraction on the storage to put, get and delete pages. The implementation of this class does not need to provide thread-safety.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	PageStore.Metrics Metrics.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Method Summary

Modifier and Type	Method and Description
static PageStore	create(PageStoreOptions options) Create an instance of PageStore.
void	delete(PageId pageId) Deletes a page from the store.
default int	get(PageId pageId, byte[] buffer) Gets a page from the store to the destination buffer.
default int	get(PageId pageId, int pageOffset, int bytesToRead, byte[] buffer, int bufferOffset) Gets part of a page from the store to the destination buffer.
int	get(PageId pageId, int pageOffset, int bytesToRead, byte[] buffer, int bufferOffset, boolean isTemporary) Gets part of a page from the store to the destination buffer.
default void	put(PageId pageId, byte[] page) Writes a new page from a source channel to the store.
void	put(PageId pageId, byte[] page, boolean isTemporary) Writes a new page from a source channel to the store.
default void	putTemporary(PageId pageId, byte[] page) Writes a new temporary page from a source channel to the store.

Methods inherited from interface java.lang.AutoCloseable

close

Field Detail

LOG

static final org.slf4j.Logger LOG

Method Detail

create

static PageStore create(PageStoreOptions options)

Create an instance of PageStore.

Parameters:

options - the options to instantiate the page store

Returns:

a PageStore instance

putTemporary

default void putTemporary(PageId pageId,
                          byte[] page)
                   throws ResourceExhaustedException,
                          IOException

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

Parameters:

pageId - page identifier

page - page data

Throws:

ResourceExhaustedException - when there is not enough space found on disk

IOException - when the store fails to write this page

put

default void put(PageId pageId,
                 byte[] page)
          throws ResourceExhaustedException,
                 IOException

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

Parameters:

pageId - page identifier

page - page data

Throws:

ResourceExhaustedException - when there is not enough space found on disk

IOException - when the store fails to write this page

put

void put(PageId pageId,
         byte[] page,
         boolean isTemporary)
  throws ResourceExhaustedException,
         IOException

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

Parameters:

pageId - page identifier

page - page data

isTemporary - is page data temporary

Throws:

ResourceExhaustedException - when there is not enough space found on disk

IOException - when the store fails to write this page

get

default int get(PageId pageId,
                byte[] buffer)
         throws IOException,
                PageNotFoundException

Gets a page from the store to the destination buffer.

Parameters:

pageId - page identifier

buffer - destination buffer

Returns:

the number of bytes read

Throws:

IOException - when the store fails to read this page

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

get

default int get(PageId pageId,
                int pageOffset,
                int bytesToRead,
                byte[] buffer,
                int bufferOffset)
         throws IOException,
                PageNotFoundException

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

Parameters:

pageId - page identifier

pageOffset - offset within page

bytesToRead - bytes to read in this page

buffer - destination buffer

bufferOffset - offset in buffer

Returns:

the number of bytes read

Throws:

IOException - when the store fails to read this page

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

IllegalArgumentException - when the page offset exceeds the page size

get

int get(PageId pageId,
        int pageOffset,
        int bytesToRead,
        byte[] buffer,
        int bufferOffset,
        boolean isTemporary)
 throws IOException,
        PageNotFoundException

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

Parameters:

pageId - page identifier

pageOffset - offset within page

bytesToRead - bytes to read in this page

buffer - destination buffer

bufferOffset - offset in buffer

isTemporary - is page data temporary

Returns:

the number of bytes read

Throws:

IOException - when the store fails to read this page

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

IllegalArgumentException - when the page offset exceeds the page size

delete

void delete(PageId pageId)
     throws IOException,
            PageNotFoundException

Deletes a page from the store.

Parameters:

pageId - page identifier

Throws:

IOException - when the store fails to delete this page

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