Package org.apache.hadoop.hbase.regionserver

Class CompactSplit.CompactionRunner

java.lang.Object

org.apache.hadoop.hbase.regionserver.CompactSplit.CompactionRunner

All Implemented Interfaces:

Runnable

Enclosing class:

CompactSplit

private final class CompactSplit.CompactionRunner
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private final CompactionContext	compaction
private final CompactSplit.CompactionCompleteTracker	completeTracker
private ThreadPoolExecutor	parent
private int	queuedPriority
private final HRegion	region
private final HStore	store
private long	time
private final CompactionLifeCycleTracker	tracker
private User	user

Constructor Summary

Constructors

Constructor	Description
CompactionRunner(HStore store, HRegion region, CompactionContext compaction, CompactionLifeCycleTracker tracker, CompactSplit.CompactionCompleteTracker completeTracker, ThreadPoolExecutor parent, User user)

Method Summary

Modifier and Type	Method	Description
private void	doCompaction(User user)
private String	formatStackTrace(Exception ex)
void	run()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

store

private final HStore store

region

private final HRegion region

compaction

private final CompactionContext compaction

tracker

private final CompactionLifeCycleTracker tracker

completeTracker

private final CompactSplit.CompactionCompleteTracker completeTracker

queuedPriority

private int queuedPriority

parent

private ThreadPoolExecutor parent

user

private User user

time

private long time

Constructor Details

CompactionRunner

public CompactionRunner(HStore store,
 HRegion region,
 CompactionContext compaction,
 CompactionLifeCycleTracker tracker,
 CompactSplit.CompactionCompleteTracker completeTracker,
 ThreadPoolExecutor parent,
 User user)

Method Details

toString

public String toString()

Overrides:

toString in class Object

doCompaction

private void doCompaction(User user)

run

public void run()

Specified by:

run in interface Runnable

formatStackTrace

private String formatStackTrace(Exception ex)