Package org.apache.hadoop.hbase.regionserver.storefiletracker

Class StoreFileTrackerForTest

java.lang.Object

org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTrackerForTest

All Implemented Interfaces:

org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker

public class StoreFileTrackerForTest
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.hadoop.conf.Configuration	conf
protected final org.apache.hadoop.hbase.regionserver.StoreContext	ctx
protected final boolean	isPrimaryReplica
private static final org.slf4j.Logger	LOG
private String	storeId
private static ConcurrentMap<String,BlockingQueue<org.apache.hadoop.hbase.regionserver.StoreFileInfo>>	trackedFiles

Constructor Summary

Constructors

Constructor	Description
StoreFileTrackerForTest(org.apache.hadoop.conf.Configuration conf, boolean isPrimaryReplica, org.apache.hadoop.hbase.regionserver.StoreContext ctx)

Method Summary

Modifier and Type	Method	Description
final void	add(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
static void	clear()
final org.apache.hadoop.hbase.regionserver.StoreFileWriter	createWriter(org.apache.hadoop.hbase.regionserver.CreateStoreFileWriterParams arg0)
protected void	doAddCompactionResults(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0, Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg1)
protected void	doAddNewStoreFiles(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> newFiles)
protected List<org.apache.hadoop.hbase.regionserver.StoreFileInfo>	doLoadStoreFiles(boolean readOnly)
protected void	doSetStoreFiles(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
protected final String	getTrackerName()
final List<org.apache.hadoop.hbase.regionserver.StoreFileInfo>	load()
final void	replace(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0, Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg1)
boolean	requireWritingToTmpDirFirst()
final void	set(List<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
static boolean	tracked(String encodedRegionName, String family, org.apache.hadoop.fs.Path file)
org.apache.hadoop.hbase.client.TableDescriptorBuilder	updateWithTrackerConfigs(org.apache.hadoop.hbase.client.TableDescriptorBuilder arg0)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

trackedFiles

private static ConcurrentMap<String,BlockingQueue<org.apache.hadoop.hbase.regionserver.StoreFileInfo>> trackedFiles

storeId

private String storeId

conf

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

isPrimaryReplica

protected final boolean isPrimaryReplica

ctx

protected final org.apache.hadoop.hbase.regionserver.StoreContext ctx

Constructor Details

StoreFileTrackerForTest

public StoreFileTrackerForTest(org.apache.hadoop.conf.Configuration conf,
 boolean isPrimaryReplica,
 org.apache.hadoop.hbase.regionserver.StoreContext ctx)

Method Details

doAddNewStoreFiles

protected void doAddNewStoreFiles(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> newFiles)
                           throws IOException

Throws:

IOException

doLoadStoreFiles

protected List<org.apache.hadoop.hbase.regionserver.StoreFileInfo> doLoadStoreFiles(boolean readOnly)
                                                                             throws IOException

Throws:

IOException

tracked

public static boolean tracked(String encodedRegionName,
 String family,
 org.apache.hadoop.fs.Path file)

clear

public static void clear()

requireWritingToTmpDirFirst

public boolean requireWritingToTmpDirFirst()

doAddCompactionResults

protected void doAddCompactionResults(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0,
 Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg1)
                               throws IOException

Throws:

IOException

doSetStoreFiles

protected void doSetStoreFiles(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
                        throws IOException

Throws:

IOException

load

public final List<org.apache.hadoop.hbase.regionserver.StoreFileInfo> load()
                                                                    throws IOException

Specified by:

load in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker

Throws:

IOException

add

public final void add(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
               throws IOException

Specified by:

add in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker

Throws:

IOException

replace

public final void replace(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0,
 Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg1)
                   throws IOException

Specified by:

replace in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker

Throws:

IOException

set

public final void set(List<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
               throws IOException

Specified by:

set in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker

Throws:

IOException

updateWithTrackerConfigs

public org.apache.hadoop.hbase.client.TableDescriptorBuilder updateWithTrackerConfigs(org.apache.hadoop.hbase.client.TableDescriptorBuilder arg0)

Specified by:

updateWithTrackerConfigs in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker

getTrackerName

protected final String getTrackerName()

createWriter

public final org.apache.hadoop.hbase.regionserver.StoreFileWriter createWriter(org.apache.hadoop.hbase.regionserver.CreateStoreFileWriterParams arg0)
                                                                        throws IOException

Specified by:

createWriter in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker

Throws:

IOException