Modifier and Type | Method and Description |
---|---|
default int |
PositionReader.read(long position,
ReadTargetBuffer buffer,
int length) |
int |
PositionReader.readInternal(long position,
ReadTargetBuffer buffer,
int length) |
Modifier and Type | Method and Description |
---|---|
default int |
PageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer)
Gets part of a page from the store to the destination buffer.
|
int |
TimeBoundPageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer target,
boolean isTemporary) |
int |
PageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
boolean isTemporary)
Gets part of a page from the store to the destination buffer.
|
int |
CacheManagerWithShadowCache.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer target,
CacheContext cacheContext) |
int |
NoExceptionCacheManager.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext) |
int |
LocalCacheManager.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext) |
int |
CacheManager.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext)
Reads a part of a page if the queried page is found in the cache, stores the result in buffer.
|
int |
NoExceptionCacheManager.get(PageId pageId,
int pageOffset,
ReadTargetBuffer buffer,
CacheContext cacheContext) |
int |
LocalCacheManager.get(PageId pageId,
int pageOffset,
ReadTargetBuffer buffer,
CacheContext cacheContext) |
default int |
CacheManager.get(PageId pageId,
int pageOffset,
ReadTargetBuffer buffer,
CacheContext cacheContext)
Reads a part of a page if the queried page is found in the cache, stores the result in buffer.
|
default int |
PageStore.get(PageId pageId,
ReadTargetBuffer buffer)
Gets a page from the store to the destination buffer.
|
int |
CacheManagerWithShadowCache.getAndLoad(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext,
java.util.function.Supplier<byte[]> externalDataSupplier) |
int |
NoExceptionCacheManager.getAndLoad(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext,
java.util.function.Supplier<byte[]> externalDataSupplier) |
int |
LocalCacheManager.getAndLoad(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext,
java.util.function.Supplier<byte[]> externalDataSupplier) |
int |
CacheManager.getAndLoad(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext,
java.util.function.Supplier<byte[]> externalDataSupplier)
Reads a part of a page if the queried page is found in the cache, stores the result in buffer.
|
int |
LocalCachePositionReader.readInternal(long position,
ReadTargetBuffer buffer,
int length) |
Modifier and Type | Method and Description |
---|---|
int |
LocalPageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer target,
boolean isTemporary) |
int |
MemoryPageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer target,
boolean isTemporary) |
Modifier and Type | Method and Description |
---|---|
int |
DoraCachePositionReader.readInternal(long position,
ReadTargetBuffer buffer,
int length) |
Modifier and Type | Method and Description |
---|---|
int |
NettyDataReader.readInternal(long position,
ReadTargetBuffer buffer,
int length) |
Constructor and Description |
---|
NettyDataReaderStateMachine(FileSystemContext context,
WorkerNetAddress address,
Protocol.ReadRequest.Builder requestBuilder,
ReadTargetBuffer buffer)
Constructor.
|
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayTargetBuffer
Target buffer backed by bytes array for zero-copy read from page store.
|
class |
ByteBufferTargetBuffer
Target buffer backed by nio ByteBuffer for zero-copy read from page store.
|
class |
NettyBufTargetBuffer
Netty Buf backed target buffer for zero-copy read from page store.
|
Modifier and Type | Method and Description |
---|---|
int |
AlluxioHdfsPositionReader.readInternal(long position,
ReadTargetBuffer buffer,
int length) |
Modifier and Type | Method and Description |
---|---|
int |
ObjectPositionReader.readInternal(long position,
ReadTargetBuffer buffer,
int length) |
Modifier and Type | Method and Description |
---|---|
int |
HdfsPositionedUnderFileInputStream.readInternal(long position,
ReadTargetBuffer buffer,
int length) |
Modifier and Type | Method and Description |
---|---|
int |
LocalPositionReader.readInternal(long position,
ReadTargetBuffer buffer,
int length) |
Modifier and Type | Method and Description |
---|---|
int |
PagedFileReader.readInternal(long position,
ReadTargetBuffer buffer,
int length) |
Copyright © 2023. All Rights Reserved.