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

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final byte[]	PB_MAGIC_V2

Constructor Summary

Constructors

Modifier	Constructor	Description
private	BucketProtoUtils()

Method Summary

Modifier and Type	Method	Description
private static void	addEntryToBuilder(Map.Entry<BlockCacheKey,BucketEntry> entry, org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BackingMapEntry.Builder entryBuilder, org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BackingMap.Builder builder)
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)
static void	serializeAsPB(BucketCache cache, FileOutputStream fos, long chunkSize)
(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.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, org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BackingMap.Builder backingMapBuilder)
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

Field Details

PB_MAGIC_V2

static final byte[] PB_MAGIC_V2

Constructor Details

BucketProtoUtils

private BucketProtoUtils()

Method Details

toPB

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

serializeAsPB

public static void serializeAsPB(BucketCache cache,
 FileOutputStream fos,
 long chunkSize)
                          throws IOException

Throws:

IOException

addEntryToBuilder

private static void addEntryToBuilder(Map.Entry<BlockCacheKey,BucketEntry> entry,
 org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BackingMapEntry.Builder entryBuilder,
 org.apache.hadoop.hbase.shaded.protobuf.generated.BucketCacheProtos.BackingMap.Builder builder)

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)