org.apache.hadoop.hbase.regionserver
Class Store

java.lang.Object
  org.apache.hadoop.hbase.regionserver.Store

All Implemented Interfaces:

HeapSize

public class Store
extends Object
implements HeapSize

A Store holds a column family in a Region. Its a memstore and a set of zero or more StoreFiles, which stretch backwards over time.

There's no reason to consider append-logging at this level; all logging and locking is handled at the HRegion level. Store just provides services to manage sets of StoreFiles. One of the most important of those services is compaction services where files are aggregated once they pass a configurable threshold.

Locking and transactions are handled at a higher level. This API should not be called directly but by an HRegion manager.

Field Summary

static long	DEEP_OVERHEAD
static long	FIXED_OVERHEAD
protected MemStore	memstore
protected long	ttl

Constructor Summary

protected

Store(org.apache.hadoop.fs.Path basedir, HRegion region, HColumnDescriptor family, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf) Constructor

Method Summary

protected long	add(KeyValue kv) Adds a value to the memstore
void	bulkLoadHFile(String srcPathStr)
protected long	delete(KeyValue kv) Adds a value to the memstore
void	get(Get get, NavigableSet<byte[]> columns, List<KeyValue> result) Retrieve results from this store given the specified Get parameters.
org.apache.hadoop.fs.Path	getHomedir() Return the directory in which this store stores its StoreFiles
int	getNumberOfstorefiles()
protected KeyValueScanner	getScanner(Scan scan, NavigableSet<byte[]> targetCols) Return a scanner for both the memstore and the HStore files
long	getSize()
org.apache.hadoop.hbase.regionserver.StoreFlusher	getStoreFlusher(long cacheFlushId)
static org.apache.hadoop.fs.Path	getStoreHomedir(org.apache.hadoop.fs.Path tabledir, String encodedName, byte[] family)
boolean	hasTooManyStoreFiles() See if there's too much store files in this store
long	heapSize()
String	toString()
long	updateColumnValue(byte[] row, byte[] f, byte[] qualifier, long newValue) Increments the value for the given row/family/qualifier.

Methods inherited from class java.lang.Object

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

Field Detail

memstore

protected final MemStore memstore

ttl

protected long ttl

FIXED_OVERHEAD

public static final long FIXED_OVERHEAD

DEEP_OVERHEAD

public static final long DEEP_OVERHEAD

Constructor Detail

Store

protected Store(org.apache.hadoop.fs.Path basedir,
                HRegion region,
                HColumnDescriptor family,
                org.apache.hadoop.fs.FileSystem fs,
                org.apache.hadoop.conf.Configuration conf)
         throws IOException

Constructor

Parameters:

basedir - qualified path under which the region directory lives; generally the table subdirectory

region -

family - HColumnDescriptor for this column

fs - file system object

conf - configuration object failed. Can be null.

Throws:

IOException

Method Detail

getStoreHomedir

public static org.apache.hadoop.fs.Path getStoreHomedir(org.apache.hadoop.fs.Path tabledir,
                                                        String encodedName,
                                                        byte[] family)

Parameters:

tabledir -

encodedName - Encoded region name.

family -

Returns:

Path to family/Store home directory.

getHomedir

public org.apache.hadoop.fs.Path getHomedir()

Return the directory in which this store stores its StoreFiles

add

protected long add(KeyValue kv)

Adds a value to the memstore

Parameters:

kv -

Returns:

memstore size delta

delete

protected long delete(KeyValue kv)

Adds a value to the memstore

Parameters:

kv -

Returns:

memstore size delta

bulkLoadHFile

public void bulkLoadHFile(String srcPathStr)
                   throws IOException

Throws:

IOException

getNumberOfstorefiles

public int getNumberOfstorefiles()

Returns:

the number of files in this store

getSize

public long getSize()

Returns:

aggregate size of HStore

getScanner

protected KeyValueScanner getScanner(Scan scan,
                                     NavigableSet<byte[]> targetCols)
                              throws IOException

Return a scanner for both the memstore and the HStore files

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

get

public void get(Get get,
                NavigableSet<byte[]> columns,
                List<KeyValue> result)
         throws IOException

Retrieve results from this store given the specified Get parameters.

Parameters:

get - Get operation

columns - List of columns to match, can be empty (not null)

result - List to add results to

Throws:

IOException

updateColumnValue

public long updateColumnValue(byte[] row,
                              byte[] f,
                              byte[] qualifier,
                              long newValue)
                       throws IOException

Increments the value for the given row/family/qualifier. This function will always be seen as atomic by other readers because it only puts a single KV to memstore. Thus no read/write control necessary.

Parameters:

row -

f -

qualifier -

newValue - the new value to set into memstore

Returns:

memstore size delta

Throws:

IOException

getStoreFlusher

public org.apache.hadoop.hbase.regionserver.StoreFlusher getStoreFlusher(long cacheFlushId)

hasTooManyStoreFiles

public boolean hasTooManyStoreFiles()

See if there's too much store files in this store

Returns:

true if number of store files is greater than the number defined in compactionThreshold

heapSize

public long heapSize()

Specified by:

heapSize in interface HeapSize

Returns:

Approximate 'exclusive deep size' of implementing object. Includes count of payload and hosting object sizings.