org.apache.hadoop.hbase.regionserver.storefiletracker

Class StoreFileTrackerBase

java.lang.Object

org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTrackerBase

All Implemented Interfaces:

StoreFileTracker

Direct Known Subclasses:

DefaultStoreFileTracker, FileBasedStoreFileTracker, MigrationStoreFileTracker

@InterfaceAudience.Private
abstract class StoreFileTrackerBase
extends Object
implements StoreFileTracker

Base class for all store file tracker.

Mainly used to place the common logic to skip persistent for secondary replicas.

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	cacheOnWriteLogged
protected org.apache.hadoop.conf.Configuration	conf
protected StoreContext	ctx
protected boolean	isPrimaryReplica
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StoreFileTrackerBase(org.apache.hadoop.conf.Configuration conf, boolean isPrimaryReplica, StoreContext ctx)

Method Summary

Modifier and Type	Method and Description
void	add(Collection<StoreFileInfo> newFiles) Add new store files.
private HFileContext	createFileContext(Compression.Algorithm compression, boolean includeMVCCReadpoint, boolean includesTag, Encryption.Context encryptionContext)
StoreFileWriter	createWriter(CreateStoreFileWriterParams params) Create a writer for writing new store files.
protected abstract void	doAddCompactionResults(Collection<StoreFileInfo> compactedFiles, Collection<StoreFileInfo> newFiles)
protected abstract void	doAddNewStoreFiles(Collection<StoreFileInfo> newFiles)
protected String	getTrackerName()
void	replace(Collection<StoreFileInfo> compactedFiles, Collection<StoreFileInfo> newFiles) Add new store files and remove compacted store files after compaction.
TableDescriptorBuilder	updateWithTrackerConfigs(TableDescriptorBuilder builder) Adds StoreFileTracker implementations specific configurations into the table descriptor.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker

load, requireWritingToTmpDirFirst, set

Field Detail

LOG

private static final org.slf4j.Logger LOG

conf

protected final org.apache.hadoop.conf.Configuration conf

isPrimaryReplica

protected final boolean isPrimaryReplica

ctx

protected final StoreContext ctx

cacheOnWriteLogged

private volatile boolean cacheOnWriteLogged

Constructor Detail

StoreFileTrackerBase

protected StoreFileTrackerBase(org.apache.hadoop.conf.Configuration conf,
                               boolean isPrimaryReplica,
                               StoreContext ctx)

Method Detail

add

public final void add(Collection<StoreFileInfo> newFiles)
               throws IOException

Description copied from interface: StoreFileTracker

Add new store files.

Used for flush and bulk load.

Specified by:

add in interface StoreFileTracker

Throws:

IOException

replace

public final void replace(Collection<StoreFileInfo> compactedFiles,
                          Collection<StoreFileInfo> newFiles)
                   throws IOException

Description copied from interface: StoreFileTracker

Add new store files and remove compacted store files after compaction.

Specified by:

replace in interface StoreFileTracker

Throws:

IOException

updateWithTrackerConfigs

public TableDescriptorBuilder updateWithTrackerConfigs(TableDescriptorBuilder builder)

Description copied from interface: StoreFileTracker

Adds StoreFileTracker implementations specific configurations into the table descriptor.

This is used to avoid accidentally data loss when changing the cluster level store file tracker implementation, and also possible misconfiguration between master and region servers.

See HBASE-26246 for more details.

Specified by:

updateWithTrackerConfigs in interface StoreFileTracker

Parameters:

builder - The table descriptor builder for the given table.

getTrackerName

protected final String getTrackerName()

createFileContext

private HFileContext createFileContext(Compression.Algorithm compression,
                                       boolean includeMVCCReadpoint,
                                       boolean includesTag,
                                       Encryption.Context encryptionContext)

createWriter

public final StoreFileWriter createWriter(CreateStoreFileWriterParams params)
                                   throws IOException

Description copied from interface: StoreFileTracker

Create a writer for writing new store files.

Specified by:

createWriter in interface StoreFileTracker

Returns:

Writer for a new StoreFile

Throws:

IOException

doAddNewStoreFiles

protected abstract void doAddNewStoreFiles(Collection<StoreFileInfo> newFiles)
                                    throws IOException

Throws:

IOException

doAddCompactionResults

protected abstract void doAddCompactionResults(Collection<StoreFileInfo> compactedFiles,
                                               Collection<StoreFileInfo> newFiles)
                                        throws IOException

Throws:

IOException