org.apache.hadoop.hbase.io.hfile

Class BlockCacheUtil

java.lang.Object

org.apache.hadoop.hbase.io.hfile.BlockCacheUtil

@InterfaceAudience.Private
public class BlockCacheUtil
extends Object

Utilty for aggregating counts in CachedBlocks and toString/toJSON CachedBlocks and BlockCaches. No attempt has been made at making this thread safe.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockCacheUtil.CachedBlocksByFile Use one of these to keep a running account of cached blocks by file.

Field Summary

Fields

Modifier and Type	Field and Description
static long	NANOS_PER_SECOND

Constructor Summary

Constructors

Constructor and Description
BlockCacheUtil()

Method Summary

Modifier and Type	Method and Description
static int	compareCacheBlock(Cacheable left, Cacheable right)
static BlockCacheUtil.CachedBlocksByFile	getLoadedCachedBlocksByFile(org.apache.hadoop.conf.Configuration conf, BlockCache bc) Get a BlockCacheUtil.CachedBlocksByFile instance and load it up by iterating content in BlockCache.
static String	toJSON(BlockCache bc)
static String	toJSON(BlockCacheUtil.CachedBlocksByFile cbsbf)
static String	toJSON(String filename, NavigableSet<CachedBlock> blocks)
static String	toString(CachedBlock cb, long now)
static String	toStringMinusFileName(CachedBlock cb, long now)

Methods inherited from class java.lang.Object

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

Field Detail

NANOS_PER_SECOND

public static final long NANOS_PER_SECOND

See Also:

Constant Field Values

Constructor Detail

BlockCacheUtil

public BlockCacheUtil()

Method Detail

toString

public static String toString(CachedBlock cb,
                              long now)

Parameters:

cb -

Returns:

The block content as String.

toJSON

public static String toJSON(String filename,
                            NavigableSet<CachedBlock> blocks)
                     throws com.fasterxml.jackson.core.JsonGenerationException,
                            com.fasterxml.jackson.databind.JsonMappingException,
                            IOException

Parameters:

filename -

blocks -

Returns:

A JSON String of filename and counts of blocks

Throws:

com.fasterxml.jackson.core.JsonGenerationException

com.fasterxml.jackson.databind.JsonMappingException

IOException

toJSON

public static String toJSON(BlockCacheUtil.CachedBlocksByFile cbsbf)
                     throws com.fasterxml.jackson.core.JsonGenerationException,
                            com.fasterxml.jackson.databind.JsonMappingException,
                            IOException

Parameters:

cbsbf -

Returns:

JSON string of cbsf aggregated

Throws:

com.fasterxml.jackson.core.JsonGenerationException

com.fasterxml.jackson.databind.JsonMappingException

IOException

toJSON

public static String toJSON(BlockCache bc)
                     throws com.fasterxml.jackson.core.JsonGenerationException,
                            com.fasterxml.jackson.databind.JsonMappingException,
                            IOException

Parameters:

bc -

Returns:

JSON string of bc content.

Throws:

com.fasterxml.jackson.core.JsonGenerationException

com.fasterxml.jackson.databind.JsonMappingException

IOException

toStringMinusFileName

public static String toStringMinusFileName(CachedBlock cb,
                                           long now)

Parameters:

cb -

Returns:

The block content of bc as a String minus the filename.

getLoadedCachedBlocksByFile

public static BlockCacheUtil.CachedBlocksByFile getLoadedCachedBlocksByFile(org.apache.hadoop.conf.Configuration conf,
                                                                            BlockCache bc)

Get a BlockCacheUtil.CachedBlocksByFile instance and load it up by iterating content in BlockCache.

Parameters:

conf - Used to read configurations

bc - Block Cache to iterate.

Returns:

Laoded up instance of CachedBlocksByFile

compareCacheBlock

public static int compareCacheBlock(Cacheable left,
                                    Cacheable right)