org.apache.hadoop.hive.ql.io.orc.encoded

Class CacheChunk

java.lang.Object

org.apache.hadoop.hive.common.io.DiskRange

org.apache.hadoop.hive.common.io.DiskRangeList

org.apache.hadoop.hive.ql.io.orc.encoded.CacheChunk

public class CacheChunk
extends org.apache.hadoop.hive.common.io.DiskRangeList

DiskRange containing encoded, uncompressed data from cache. It should be hidden inside EncodedReaderImpl, but we need to expose it for tests.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.common.io.DiskRangeList

org.apache.hadoop.hive.common.io.DiskRangeList.CreateHelper, org.apache.hadoop.hive.common.io.DiskRangeList.MutateHelper

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.hive.common.io.encoded.MemoryBuffer	buffer

Fields inherited from class org.apache.hadoop.hive.common.io.DiskRangeList

next, prev

Fields inherited from class org.apache.hadoop.hive.common.io.DiskRange

end, offset

Constructor Summary

Constructors

Constructor and Description
CacheChunk(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer, long offset, long end)

Method Summary

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()

Methods inherited from class org.apache.hadoop.hive.common.io.DiskRangeList

getTotalLength, hasContiguousNext, insertAfter, insertPartAfter, insertPartBefore, listSize, listToArray, removeAfter, removeSelf, replaceSelfWith, setEnd, split, stringifyDiskRanges

Methods inherited from class org.apache.hadoop.hive.common.io.DiskRange

equalRange, equals, getEnd, getLength, getOffset, hashCode, merge

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

buffer

protected org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer

Constructor Detail

CacheChunk

public CacheChunk(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer,
                  long offset,
                  long end)

Method Detail

hasData

public boolean hasData()

Overrides:

hasData in class org.apache.hadoop.hive.common.io.DiskRange

getData

public ByteBuffer getData()

Overrides:

getData in class org.apache.hadoop.hive.common.io.DiskRange

toString

public String toString()

Overrides:

toString in class org.apache.hadoop.hive.common.io.DiskRange

sliceAndShift

public org.apache.hadoop.hive.common.io.DiskRange sliceAndShift(long offset,
                                                                long end,
                                                                long shiftBy)

Overrides:

sliceAndShift in class org.apache.hadoop.hive.common.io.DiskRange

getBuffer

public org.apache.hadoop.hive.common.io.encoded.MemoryBuffer getBuffer()

setBuffer

public void setBuffer(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer)

handleCacheCollision

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)

adjustEnd

public void adjustEnd(long l)