org.apache.tephra.hbase.txprune

Class InvalidListPruningDebug

java.lang.Object

org.apache.tephra.hbase.txprune.InvalidListPruningDebug

public class InvalidListPruningDebug
extends Object

Invalid List Pruning Debug Tool.

Constructor Summary

Constructors

Constructor and Description
InvalidListPruningDebug()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy()
Queue<RegionPruneInfo>	getIdleRegions(Integer numRegions) Return a list of RegionPruneInfo.
RegionPruneInfo	getRegionPruneInfo(String regionId) Return the prune upper bound value of a given region.
Map<Long,SortedSet<String>>	getRegionsOnOrBeforeTime(Long time)
Set<String>	getRegionsToBeCompacted(Integer numRegions) Returns a set of regions that are live but are not empty nor have a prune upper bound recorded.
void	initialize(org.apache.hadoop.conf.Configuration conf) Initialize the Invalid List Debug Tool.
static void	main(String[] args)

Methods inherited from class java.lang.Object

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

Constructor Detail

InvalidListPruningDebug

public InvalidListPruningDebug()

Method Detail

initialize

public void initialize(org.apache.hadoop.conf.Configuration conf)
                throws IOException

Initialize the Invalid List Debug Tool.

Parameters:

conf - Configuration

Throws:

IOException

destroy

public void destroy()
             throws IOException

Throws:

IOException

getRegionsToBeCompacted

public Set<String> getRegionsToBeCompacted(Integer numRegions)
                                    throws IOException

Returns a set of regions that are live but are not empty nor have a prune upper bound recorded. These regions will stop the progress of pruning.

Parameters:

numRegions - number of regions

Returns:

Set of regions that needs to be compacted and flushed

Throws:

IOException

getIdleRegions

public Queue<RegionPruneInfo> getIdleRegions(Integer numRegions)
                                      throws IOException

Return a list of RegionPruneInfo. These regions are the ones that have the lowest prune upper bounds. If -1 is passed in, all the regions and their prune upper bound will be returned. Note that only the regions that are known to be live will be returned.

Parameters:

numRegions - number of regions

Returns:

Map of region name and its prune upper bound

Throws:

IOException

getRegionPruneInfo

@Nullable
public RegionPruneInfo getRegionPruneInfo(String regionId)
                                   throws IOException

Return the prune upper bound value of a given region. If no prune upper bound has been written for this region yet, it will return a null.

Parameters:

regionId - region id

Returns:

RegionPruneInfo of the region

Throws:

IOException - if there are any errors while trying to fetch the RegionPruneInfo

getRegionsOnOrBeforeTime

public Map<Long,SortedSet<String>> getRegionsOnOrBeforeTime(Long time)
                                                     throws IOException

Parameters:

time - Given a time, provide the TimeRegions at or before that time

Returns:

transactional regions that are present at or before the given time

Throws:

IOException - if there are any errors while trying to fetch the TimeRegions

main

public static void main(String[] args)