org.apache.accumulo.server.tabletserver
Class Compactor

java.lang.Object
  extended by org.apache.accumulo.server.tabletserver.Compactor
All Implemented Interfaces:
Callable<CompactionStats>
Direct Known Subclasses:
MinorCompactor

public class Compactor
extends Object
implements Callable<CompactionStats>


Nested Class Summary
static class Compactor.CompactionInfo
           
 class Compactor.CountingIterator
           
 
Field Summary
protected  KeyExtent extent
           
protected  org.apache.accumulo.server.tabletserver.Tablet.MinorCompactionReason mincReason
           
protected static Set<Compactor> runningCompactions
           
 
Method Summary
 CompactionStats call()
           
 org.apache.hadoop.fs.FileSystem getFileSystem()
           
static List<Compactor.CompactionInfo> getRunningCompactions()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

extent

protected KeyExtent extent

mincReason

protected org.apache.accumulo.server.tabletserver.Tablet.MinorCompactionReason mincReason

runningCompactions

protected static Set<Compactor> runningCompactions
Method Detail

getRunningCompactions

public static List<Compactor.CompactionInfo> getRunningCompactions()

getFileSystem

public org.apache.hadoop.fs.FileSystem getFileSystem()

call

public CompactionStats call()
                     throws IOException,
                            org.apache.accumulo.server.tabletserver.Compactor.CompactionCanceledException
Specified by:
call in interface Callable<CompactionStats>
Throws:
IOException
org.apache.accumulo.server.tabletserver.Compactor.CompactionCanceledException


Copyright © 2013 Apache Accumulo Project. All Rights Reserved.