Package org.apache.hadoop.hbase.io.hfile.bucket

Class BucketProtoUtils

java.lang.Object

org.apache.hadoop.hbase.io.hfile.bucket.BucketProtoUtils

@Private
final class BucketProtoUtils
extends Object

Constructor Summary

Constructors

Modifier	Constructor	Description
private	BucketProtoUtils()

Method Summary

Modifier and Type	Method	Description
private static BlockType	fromPb(org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BlockType blockType)
(package private) static Pair<ConcurrentHashMap<BlockCacheKey,BucketEntry>,NavigableSet<BlockCacheKey>>	fromPB(Map<Integer,String> deserializers, org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BackingMap backingMap, Function<BucketEntry,ByteBuffAllocator.Recycler> createRecycler)
(package private) static Map<String,Pair<String,Long>>	fromPB(Map<String,org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.RegionFileSizeMap> prefetchHFileNames)
(package private) static Map<String,org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.RegionFileSizeMap>	toCachedPB(Map<String,Pair<String,Long>> prefetchedHfileNames)
private static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BackingMap	toPB(Map<BlockCacheKey,BucketEntry> backingMap)
private static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BlockCacheKey	toPB(BlockCacheKey key)
private static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BlockPriority	toPB(BlockPriority p)
private static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BlockType	toPB(BlockType blockType)
(package private) static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BucketCacheEntry	toPB(BucketCache cache)
private static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BucketEntry	toPB(BucketEntry entry)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BucketProtoUtils

private BucketProtoUtils()

Method Details

toPB

static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BucketCacheEntry toPB(BucketCache cache)

toPB

private static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BackingMap toPB(Map<BlockCacheKey,BucketEntry> backingMap)

toPB

private static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BlockCacheKey toPB(BlockCacheKey key)

toPB

private static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BlockType toPB(BlockType blockType)

toPB

private static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BucketEntry toPB(BucketEntry entry)

toPB

private static org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BlockPriority toPB(BlockPriority p)

fromPB

static Pair<ConcurrentHashMap<BlockCacheKey,BucketEntry>,NavigableSet<BlockCacheKey>> fromPB(Map<Integer,String> deserializers,
 org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BackingMap backingMap,
 Function<BucketEntry,ByteBuffAllocator.Recycler> createRecycler)
                                                                                      throws IOException

Throws:

IOException

fromPb

private static BlockType fromPb(org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BlockType blockType)

toCachedPB

static Map<String,org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.RegionFileSizeMap> toCachedPB(Map<String,Pair<String,Long>> prefetchedHfileNames)

fromPB

static Map<String,Pair<String,Long>> fromPB(Map<String,org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.RegionFileSizeMap> prefetchHFileNames)