Modifier and Type | Method and Description |
---|---|
List<DiskRange> |
DiskRangeInfo.getDiskRanges() |
Modifier and Type | Method and Description |
---|---|
void |
DiskRangeInfo.addDiskRange(DiskRange diskRange) |
Modifier and Type | Class and Description |
---|---|
class |
DiskRangeList
Java linked list iterator interface is convoluted, and moreover concurrent modifications
of the same list by multiple iterators are impossible.
|
static class |
DiskRangeList.MutateHelper
List in-place mutation helper - a bogus first element that is inserted before list head,
and thus remains constant even if head is replaced with some new range via in-place list
mutation.
|
Modifier and Type | Method and Description |
---|---|
DiskRange |
DiskRange.sliceAndShift(long offset,
long end,
long shiftBy) |
Modifier and Type | Method and Description |
---|---|
boolean |
DiskRange.equalRange(DiskRange other) |
long[] |
DataCache.putFileData(Object fileKey,
DiskRange[] ranges,
MemoryBuffer[] data,
long baseOffset)
Puts file data into cache, or gets older data in case of collisions.
|
Modifier and Type | Method and Description |
---|---|
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 |
OrcMetadataCache.putIncompleteCbs(Object fileKey,
DiskRange[] ranges,
long baseOffset) |
Modifier and Type | Class and Description |
---|---|
class |
CacheChunk
DiskRange containing encoded, uncompressed data from cache.
|
class |
IncompleteCb |
Modifier and Type | Method and Description |
---|---|
DiskRange |
CacheChunk.sliceAndShift(long offset,
long end,
long shiftBy) |
Modifier and Type | Class and Description |
---|---|
class |
BufferChunk
The sections of stripe that we have read.
|
Modifier and Type | Method and Description |
---|---|
DiskRange |
BufferChunk.sliceAndShift(long offset,
long end,
long shiftBy) |
Modifier and Type | Method and Description |
---|---|
static InStream |
InStream.create(String name,
List<DiskRange> input,
long length,
CompressionCodec codec,
int bufferSize)
Create an input stream from a list of disk ranges with data.
|
static com.google.protobuf.CodedInputStream |
InStream.createCodedInputStream(String name,
List<DiskRange> input,
long length,
CompressionCodec codec,
int bufferSize)
Creates coded input stream (used for protobuf message parsing) with higher message size limit.
|
protected void |
InStream.UncompressedStream.reset(List<DiskRange> input,
long length) |
Constructor and Description |
---|
SettableUncompressedStream(String name,
List<DiskRange> input,
long length) |
UncompressedStream(String name,
List<DiskRange> input,
long length) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.