org.apache.hadoop.hbase.regionserver

Class TestCompaction.BlockingStoreMockMaker.BlockingCompactionContext

java.lang.Object

org.apache.hadoop.hbase.regionserver.compactions.CompactionContext

org.apache.hadoop.hbase.regionserver.TestCompaction.BlockingStoreMockMaker.BlockingCompactionContext

Enclosing class:

TestCompaction.BlockingStoreMockMaker

public class TestCompaction.BlockingStoreMockMaker.BlockingCompactionContext
extends CompactionContext

Field Summary

Fields

Modifier and Type	Field and Description
boolean	isInCompact

Fields inherited from class org.apache.hadoop.hbase.regionserver.compactions.CompactionContext

request

Constructor Summary

Constructors

Constructor and Description
BlockingCompactionContext()

Method Summary

Modifier and Type	Method and Description
java.util.List<Path>	compact(CompactionThroughputController throughputController) Runs the compaction based on current selection.
java.util.List<Path>	compact(CompactionThroughputController throughputController, User user)
java.util.List<StoreFile>	preSelect(java.util.List<StoreFile> filesCompacting) Called before coprocessor preCompactSelection and should filter the candidates for coprocessor; i.e.
boolean	select(java.util.List<StoreFile> f, boolean i, boolean m, boolean e) Called to select files for compaction.
void	unblock()

Methods inherited from class org.apache.hadoop.hbase.regionserver.compactions.CompactionContext

forceSelect, getRequest, hasSelection

Methods inherited from class java.lang.Object

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

Field Detail

isInCompact

public volatile boolean isInCompact

Constructor Detail

BlockingCompactionContext

public BlockingCompactionContext()

Method Detail

unblock

public void unblock()

compact

public java.util.List<Path> compact(CompactionThroughputController throughputController)
                             throws java.io.IOException

Description copied from class: CompactionContext

Runs the compaction based on current selection. select/forceSelect must have been called.

Specified by:

compact in class CompactionContext

Returns:

The new file paths resulting from compaction.

Throws:

java.io.IOException

compact

public java.util.List<Path> compact(CompactionThroughputController throughputController,
                                    User user)
                             throws java.io.IOException

Specified by:

compact in class CompactionContext

Throws:

java.io.IOException

preSelect

public java.util.List<StoreFile> preSelect(java.util.List<StoreFile> filesCompacting)

Description copied from class: CompactionContext

Called before coprocessor preCompactSelection and should filter the candidates for coprocessor; i.e. exclude the files that definitely cannot be compacted at this time.

Specified by:

preSelect in class CompactionContext

Parameters:

filesCompacting - files currently compacting

Returns:

the list of files that can theoretically be compacted.

select

public boolean select(java.util.List<StoreFile> f,
                      boolean i,
                      boolean m,
                      boolean e)
               throws java.io.IOException

Description copied from class: CompactionContext

Called to select files for compaction. Must fill in the request field if successful.

Specified by:

select in class CompactionContext

Parameters:

f - Files currently being compacted by other compactions.

i - Whether this is a user compaction.

m - Whether the underlying policy may assume it's off-peak hours.

e - Whether to force major compaction.

Returns:

Whether the selection succeeded. Selection may be empty and lead to no compaction.

Throws:

java.io.IOException