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() |
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 |
init(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer,
long offset,
long end) |
void |
reset() |
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
public void init(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 reset()
public void adjustEnd(long l)
Copyright © 2017 The Apache Software Foundation. All rights reserved.