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 and Description
protected org.apache.hadoop.conf.Configuration	conf
protected org.apache.hadoop.hbase.regionserver.StoreContext	ctx
protected boolean	isPrimaryReplica
private static org.slf4j.Logger	LOG
private String	storeId
private static ConcurrentMap<String,BlockingQueue<org.apache.hadoop.hbase.regionserver.StoreFileInfo>>	trackedFiles

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	add(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
static void	clear()
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 String	getTrackerName()
List<org.apache.hadoop.hbase.regionserver.StoreFileInfo>	load()
void	replace(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0, Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg1)
boolean	requireWritingToTmpDirFirst()
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 Detail

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 Detail

StoreFileTrackerForTest

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

Method Detail

doAddNewStoreFiles

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

Throws:

IOException

load

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

Specified by:

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

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

set

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

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

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