org.apache.hadoop.hbase.regionserver.compactions

Class AbstractMultiOutputCompactor<T extends AbstractMultiFileWriter>

java.lang.Object

org.apache.hadoop.hbase.regionserver.compactions.Compactor<T>

org.apache.hadoop.hbase.regionserver.compactions.AbstractMultiOutputCompactor<T>

Direct Known Subclasses:

DateTieredCompactor, StripeCompactor

@InterfaceAudience.Private
public abstract class AbstractMultiOutputCompactor<T extends AbstractMultiFileWriter>
extends Compactor<T>

Base class for implementing a Compactor which will generate multiple output files after compaction.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.compactions.Compactor

Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactory

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

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

COMPACTION_PROGRESS_LOG_INTERVAL, compactionKVMax, conf, defaultScannerFactory, dropCacheMajor, dropCacheMinor, keepSeqIdPeriod, MAJOR_COMPACTION_DROP_CACHE, majorCompactionCompression, MINOR_COMPACTION_DROP_CACHE, minorCompactionCompression, store

Constructor Summary

Constructors

Constructor and Description
AbstractMultiOutputCompactor(org.apache.hadoop.conf.Configuration conf, HStore store)

Method Summary

Modifier and Type	Method and Description
protected void	abortWriter(AbstractMultiFileWriter writer)
protected void	initMultiWriter(AbstractMultiFileWriter writer, InternalScanner scanner, Compactor.FileDetails fd, boolean shouldDropBehind, boolean major, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)

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

commitWriter, compact, createParams, createScanner, createScanner, createWriter, createWriter, getProgress, isCompacting, performCompaction

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

Constructor Detail

AbstractMultiOutputCompactor

public AbstractMultiOutputCompactor(org.apache.hadoop.conf.Configuration conf,
                                    HStore store)

Method Detail

initMultiWriter

protected final void initMultiWriter(AbstractMultiFileWriter writer,
                                     InternalScanner scanner,
                                     Compactor.FileDetails fd,
                                     boolean shouldDropBehind,
                                     boolean major,
                                     Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)

abortWriter

protected void abortWriter(AbstractMultiFileWriter writer)
                    throws IOException

Specified by:

abortWriter in class Compactor<T extends AbstractMultiFileWriter>

Throws:

IOException