org.apache.hadoop.hbase.regionserver

Class StoreFileInfo

java.lang.Object

org.apache.hadoop.hbase.regionserver.StoreFileInfo

@InterfaceAudience.Private
public class StoreFileInfo
extends Object

Describe a StoreFile (hfile, reference, link)

Field Summary

Fields

Modifier and Type	Field and Description
static String	DELFILE_NAME_REGEX A non-capture group, for del files, so that this can be embedded.
static String	HFILE_NAME_REGEX A non-capture group, for hfiles, so that this can be embedded.

Constructor Summary

Constructors

Constructor and Description
StoreFileInfo(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus fileStatus) Create a Store File Info
StoreFileInfo(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus fileStatus, HFileLink link) Create a Store File Info from an HFileLink
StoreFileInfo(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus fileStatus, Reference reference) Create a Store File Info from an HFileLink
StoreFileInfo(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus fileStatus, Reference reference, HFileLink link) Create a Store File Info from an HFileLink and a Reference
StoreFileInfo(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path initialPath) Create a Store File Info

Method Summary

Modifier and Type	Method and Description
HDFSBlocksDistribution	computeHDFSBlocksDistribution(org.apache.hadoop.fs.FileSystem fs) Compute the HDFS Block Distribution for this StoreFile
boolean	equals(Object that)
String	getActiveFileName() Return the active file name that contains the real data.
long	getCreatedTimestamp()
org.apache.hadoop.fs.FileStatus	getFileStatus()
HDFSBlocksDistribution	getHDFSBlockDistribution()
long	getModificationTime()
org.apache.hadoop.fs.Path	getPath()
Reference	getReference()
org.apache.hadoop.fs.FileStatus	getReferencedFileStatus(org.apache.hadoop.fs.FileSystem fs) Get the FileStatus of the file referenced by this StoreFileInfo
static org.apache.hadoop.fs.Path	getReferredToFile(org.apache.hadoop.fs.Path p)
int	hashCode()
static boolean	isDelFile(org.apache.hadoop.fs.Path path)
static boolean	isDelFile(String fileName)
static boolean	isHFile(org.apache.hadoop.fs.Path path)
static boolean	isHFile(String fileName)
boolean	isLink()
boolean	isReference()
static boolean	isReference(org.apache.hadoop.fs.Path path)
static boolean	isReference(String name)
boolean	isTopReference()
static boolean	isValid(org.apache.hadoop.fs.FileStatus fileStatus) Return if the specified file is a valid store file or not.
StoreFileReader	open(org.apache.hadoop.fs.FileSystem fs, CacheConfig cacheConf, boolean canUseDropBehind, long readahead, boolean isPrimaryReplicaStoreFile, AtomicInteger refCount, boolean shared) Open a Reader for the StoreFile
void	setRegionCoprocessorHost(RegionCoprocessorHost coprocessorHost) Sets the region coprocessor env.
String	toString()
static boolean	validateStoreFileName(String fileName) Validate the store file name.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

HFILE_NAME_REGEX

public static final String HFILE_NAME_REGEX

A non-capture group, for hfiles, so that this can be embedded. HFiles are uuid ([0-9a-z]+). Bulk loaded hfiles has (_SeqId_[0-9]+_) has suffix. The mob del file has (_del) as suffix.

See Also:

Constant Field Values

DELFILE_NAME_REGEX

public static final String DELFILE_NAME_REGEX

A non-capture group, for del files, so that this can be embedded. A del file has (_del) as suffix.

See Also:

Constant Field Values

Constructor Detail

StoreFileInfo

public StoreFileInfo(org.apache.hadoop.conf.Configuration conf,
                     org.apache.hadoop.fs.FileSystem fs,
                     org.apache.hadoop.fs.Path initialPath)
              throws IOException

Create a Store File Info

Parameters:

conf - the Configuration to use

fs - The current file system to use.

initialPath - The Path of the file

Throws:

IOException

StoreFileInfo

public StoreFileInfo(org.apache.hadoop.conf.Configuration conf,
                     org.apache.hadoop.fs.FileSystem fs,
                     org.apache.hadoop.fs.FileStatus fileStatus)
              throws IOException

Create a Store File Info

Parameters:

conf - the Configuration to use

fs - The current file system to use.

fileStatus - The FileStatus of the file

Throws:

IOException

StoreFileInfo

public StoreFileInfo(org.apache.hadoop.conf.Configuration conf,
                     org.apache.hadoop.fs.FileSystem fs,
                     org.apache.hadoop.fs.FileStatus fileStatus,
                     HFileLink link)

Create a Store File Info from an HFileLink

Parameters:

conf - The Configuration to use

fs - The current file system to use

fileStatus - The FileStatus of the file

StoreFileInfo

public StoreFileInfo(org.apache.hadoop.conf.Configuration conf,
                     org.apache.hadoop.fs.FileSystem fs,
                     org.apache.hadoop.fs.FileStatus fileStatus,
                     Reference reference)

Create a Store File Info from an HFileLink

Parameters:

conf - The Configuration to use

fs - The current file system to use

fileStatus - The FileStatus of the file

reference - The reference instance

StoreFileInfo

public StoreFileInfo(org.apache.hadoop.conf.Configuration conf,
                     org.apache.hadoop.fs.FileSystem fs,
                     org.apache.hadoop.fs.FileStatus fileStatus,
                     Reference reference,
                     HFileLink link)

Create a Store File Info from an HFileLink and a Reference

Parameters:

conf - The Configuration to use

fs - The current file system to use

fileStatus - The FileStatus of the file

reference - The reference instance

link - The link instance

Method Detail

setRegionCoprocessorHost

public void setRegionCoprocessorHost(RegionCoprocessorHost coprocessorHost)

Sets the region coprocessor env.

Parameters:

coprocessorHost -

getReference

public Reference getReference()

isReference

public boolean isReference()

Returns:

True if the store file is a Reference

isTopReference

public boolean isTopReference()

Returns:

True if the store file is a top Reference

isLink

public boolean isLink()

Returns:

True if the store file is a link

getHDFSBlockDistribution

public HDFSBlocksDistribution getHDFSBlockDistribution()

Returns:

the HDFS block distribution

open

public StoreFileReader open(org.apache.hadoop.fs.FileSystem fs,
                            CacheConfig cacheConf,
                            boolean canUseDropBehind,
                            long readahead,
                            boolean isPrimaryReplicaStoreFile,
                            AtomicInteger refCount,
                            boolean shared)
                     throws IOException

Open a Reader for the StoreFile

Parameters:

fs - The current file system to use.

cacheConf - The cache configuration and block cache reference.

Returns:

The StoreFile.Reader for the file

Throws:

IOException

computeHDFSBlocksDistribution

public HDFSBlocksDistribution computeHDFSBlocksDistribution(org.apache.hadoop.fs.FileSystem fs)
                                                     throws IOException

Compute the HDFS Block Distribution for this StoreFile

Throws:

IOException

getReferencedFileStatus

public org.apache.hadoop.fs.FileStatus getReferencedFileStatus(org.apache.hadoop.fs.FileSystem fs)
                                                        throws IOException

Get the FileStatus of the file referenced by this StoreFileInfo

Parameters:

fs - The current file system to use.

Returns:

The FileStatus of the file referenced by this StoreFileInfo

Throws:

IOException

getPath

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

Returns:

The Path of the file

getFileStatus

public org.apache.hadoop.fs.FileStatus getFileStatus()
                                              throws IOException

Returns:

The FileStatus of the file

Throws:

IOException

getModificationTime

public long getModificationTime()
                         throws IOException

Returns:

Get the modification time of the file.

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

isHFile

public static boolean isHFile(org.apache.hadoop.fs.Path path)

Parameters:

path - Path to check.

Returns:

True if the path has format of a HFile.

isHFile

public static boolean isHFile(String fileName)

isDelFile

public static boolean isDelFile(org.apache.hadoop.fs.Path path)

Parameters:

path - Path to check.

Returns:

True if the path has format of a del file.

isDelFile

public static boolean isDelFile(String fileName)

Parameters:

fileName - Sting version of path to validate.

Returns:

True if the file name has format of a del file.

isReference

public static boolean isReference(org.apache.hadoop.fs.Path path)

Parameters:

path - Path to check.

Returns:

True if the path has format of a HStoreFile reference.

isReference

public static boolean isReference(String name)

Parameters:

name - file name to check.

Returns:

True if the path has format of a HStoreFile reference.

getCreatedTimestamp

public long getCreatedTimestamp()

Returns:

timestamp when this file was created (as returned by filesystem)

getReferredToFile

public static org.apache.hadoop.fs.Path getReferredToFile(org.apache.hadoop.fs.Path p)

validateStoreFileName

public static boolean validateStoreFileName(String fileName)

Validate the store file name.

Parameters:

fileName - name of the file to validate

Returns:

true if the file could be a valid store file, false otherwise

isValid

public static boolean isValid(org.apache.hadoop.fs.FileStatus fileStatus)
                       throws IOException

Return if the specified file is a valid store file or not.

Parameters:

fileStatus - The FileStatus of the file

Returns:

true if the file is valid

Throws:

IOException

equals

public boolean equals(Object that)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getActiveFileName

public String getActiveFileName()

Return the active file name that contains the real data.

For referenced hfile, we will return the name of the reference file as it will be used to construct the StoreFileReader. And for linked hfile, we will return the name of the file being linked.