alluxio.worker.http

Class PagedService

java.lang.Object

alluxio.worker.http.PagedService

public class PagedService
extends Object

PagedService is used for providing page related RESTful API service.

Constructor Summary

Constructors

Constructor and Description
PagedService(CacheManager cacheManager) PagedService is used for providing page related RESTful API service.

Method Summary

Modifier and Type	Method and Description
io.netty.buffer.ByteBuf	getPage(String fileId, long pageIndex, io.netty.channel.Channel channel) Get page bytes given fileId, pageIndex, and channel which is used for allocating ByteBuf.
io.netty.channel.FileRegion	getPageFileRegion(String fileId, long pageIndex) Get FileRegion object given fileId, pageIndex, and channel.

Methods inherited from class java.lang.Object

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

Constructor Detail

PagedService

@Inject
public PagedService(CacheManager cacheManager)

PagedService is used for providing page related RESTful API service.

Parameters:

cacheManager - The interface for managing cached pages

Method Detail

getPage

public io.netty.buffer.ByteBuf getPage(String fileId,
                                       long pageIndex,
                                       io.netty.channel.Channel channel)

Get page bytes given fileId, pageIndex, and channel which is used for allocating ByteBuf.

Parameters:

fileId - the file ID

pageIndex - the page index

channel - the Netty channel which is used for allocating ByteBuf

Returns:

the ByteBuf object that wraps page bytes

getPageFileRegion

public io.netty.channel.FileRegion getPageFileRegion(String fileId,
                                                     long pageIndex)
                                              throws PageNotFoundException

Get FileRegion object given fileId, pageIndex, and channel.

Parameters:

fileId - the file ID

pageIndex - the page index

Returns:

the ByteBuf object that wraps page bytes

Throws:

PageNotFoundException