public class CacheChunk
extends org.apache.hadoop.hive.common.io.DiskRangeList
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.hive.common.io.encoded.MemoryBuffer |
buffer |
Constructor and Description |
---|
CacheChunk(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer,
long offset,
long end) |
Modifier and Type | Method and Description |
---|---|
void |
adjustEnd(long l) |
org.apache.hadoop.hive.common.io.encoded.MemoryBuffer |
getBuffer() |
ByteBuffer |
getData() |
void |
handleCacheCollision(org.apache.hadoop.hive.common.io.DataCache cache,
org.apache.hadoop.hive.common.io.encoded.MemoryBuffer replacementBuffer,
List<org.apache.hadoop.hive.common.io.encoded.MemoryBuffer> cacheBuffers) |
boolean |
hasData() |
void |
setBuffer(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer) |
org.apache.hadoop.hive.common.io.DiskRange |
sliceAndShift(long offset,
long end,
long shiftBy) |
String |
toString() |
getTotalLength, hasContiguousNext, insertAfter, insertPartAfter, insertPartBefore, listSize, listToArray, removeAfter, removeSelf, replaceSelfWith, setEnd, split, stringifyDiskRanges
public CacheChunk(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer, long offset, long end)
public boolean hasData()
hasData
in class org.apache.hadoop.hive.common.io.DiskRange
public ByteBuffer getData()
getData
in class org.apache.hadoop.hive.common.io.DiskRange
public String toString()
toString
in class org.apache.hadoop.hive.common.io.DiskRange
public org.apache.hadoop.hive.common.io.DiskRange sliceAndShift(long offset, long end, long shiftBy)
sliceAndShift
in class org.apache.hadoop.hive.common.io.DiskRange
public org.apache.hadoop.hive.common.io.encoded.MemoryBuffer getBuffer()
public void setBuffer(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer)
public void handleCacheCollision(org.apache.hadoop.hive.common.io.DataCache cache, org.apache.hadoop.hive.common.io.encoded.MemoryBuffer replacementBuffer, List<org.apache.hadoop.hive.common.io.encoded.MemoryBuffer> cacheBuffers)
public void adjustEnd(long l)
Copyright © 2019 The Apache Software Foundation. All rights reserved.