Package | Description |
---|---|
org.apache.hadoop.hive.common.io | |
org.apache.hadoop.hive.common.io.encoded | |
org.apache.hadoop.hive.llap.cache | |
org.apache.hadoop.hive.ql.io.orc.encoded |
Modifier and Type | Method and Description |
---|---|
MemoryBuffer |
Allocator.createUnallocated()
Creates an unallocated memory buffer object.
|
Modifier and Type | Method and Description |
---|---|
void |
Allocator.allocateMultiple(MemoryBuffer[] dest,
int size)
Allocates multiple buffers of a given size.
|
DiskRangeList |
DataCache.DiskRangeListFactory.createCacheChunk(MemoryBuffer buffer,
long startOffset,
long endOffset) |
void |
Allocator.deallocate(MemoryBuffer buffer)
Deallocates a memory buffer.
|
long[] |
DataCache.putFileData(Object fileKey,
DiskRange[] ranges,
MemoryBuffer[] data,
long baseOffset)
Puts file data into cache, or gets older data in case of collisions.
|
void |
DataCache.releaseBuffer(MemoryBuffer buffer)
Releases the buffer returned by getFileData/provided to putFileData back to cache.
|
void |
DataCache.reuseBuffer(MemoryBuffer buffer)
Notifies the cache that the buffer returned from getFileData/provided to putFileData will
be used by another consumer and therefore released multiple times (one more time per call).
|
Modifier and Type | Method and Description |
---|---|
List<MemoryBuffer> |
EncodedColumnBatch.ColumnStreamData.getCacheBuffers() |
Modifier and Type | Method and Description |
---|---|
void |
EncodedColumnBatch.ColumnStreamData.setCacheBuffers(List<MemoryBuffer> cacheBuffers) |
Modifier and Type | Class and Description |
---|---|
class |
LlapDataBuffer |
Modifier and Type | Method and Description |
---|---|
MemoryBuffer |
BuddyAllocator.createUnallocated() |
Modifier and Type | Method and Description |
---|---|
void |
SimpleAllocator.allocateMultiple(MemoryBuffer[] dest,
int size) |
void |
BuddyAllocator.allocateMultiple(MemoryBuffer[] dest,
int size) |
void |
SimpleAllocator.deallocate(MemoryBuffer buffer) |
void |
BuddyAllocator.deallocate(MemoryBuffer buffer) |
void |
EvictionAwareAllocator.deallocateEvicted(MemoryBuffer buffer) |
void |
BuddyAllocator.deallocateEvicted(MemoryBuffer buffer) |
void |
SimpleBufferManager.decRefBuffer(MemoryBuffer buffer) |
void |
LowLevelCacheImpl.decRefBuffer(MemoryBuffer buffer) |
void |
BufferUsageManager.decRefBuffer(MemoryBuffer buffer) |
boolean |
SimpleBufferManager.incRefBuffer(MemoryBuffer buffer) |
boolean |
LowLevelCacheImpl.incRefBuffer(MemoryBuffer buffer) |
boolean |
BufferUsageManager.incRefBuffer(MemoryBuffer buffer) |
void |
SimpleBufferManager.notifyEvicted(MemoryBuffer buffer) |
void |
LowLevelCacheImpl.notifyEvicted(MemoryBuffer buffer) |
void |
LowLevelCache.notifyEvicted(MemoryBuffer buffer)
Notifies the cache that a particular buffer should be removed due to eviction.
|
long[] |
SimpleBufferManager.putFileData(Object fileKey,
DiskRange[] ranges,
MemoryBuffer[] chunks,
long baseOffset,
LowLevelCache.Priority priority,
LowLevelCacheCounters qfCounters) |
long[] |
LowLevelCacheImpl.putFileData(Object fileKey,
DiskRange[] ranges,
MemoryBuffer[] buffers,
long baseOffset,
LowLevelCache.Priority priority,
LowLevelCacheCounters qfCounters) |
long[] |
LowLevelCache.putFileData(Object fileKey,
DiskRange[] ranges,
MemoryBuffer[] chunks,
long baseOffset,
LowLevelCache.Priority priority,
LowLevelCacheCounters qfCounters)
Puts file data into cache.
|
Modifier and Type | Method and Description |
---|---|
void |
SimpleBufferManager.decRefBuffers(List<MemoryBuffer> cacheBuffers) |
void |
LowLevelCacheImpl.decRefBuffers(List<MemoryBuffer> cacheBuffers) |
void |
BufferUsageManager.decRefBuffers(List<MemoryBuffer> buffers) |
Modifier and Type | Field and Description |
---|---|
protected MemoryBuffer |
CacheChunk.buffer |
Modifier and Type | Method and Description |
---|---|
MemoryBuffer |
CacheChunk.getBuffer() |
Modifier and Type | Method and Description |
---|---|
void |
CacheChunk.handleCacheCollision(DataCache cache,
MemoryBuffer replacementBuffer,
List<MemoryBuffer> cacheBuffers) |
void |
CacheChunk.init(MemoryBuffer buffer,
long offset,
long end) |
void |
CacheChunk.setBuffer(MemoryBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
CacheChunk.handleCacheCollision(DataCache cache,
MemoryBuffer replacementBuffer,
List<MemoryBuffer> cacheBuffers) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.