Package 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

@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	Description
private static final org.slf4j.Logger	LOG

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	abortWriter(AbstractMultiFileWriter writer)
protected final 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 Details

LOG

private static final org.slf4j.Logger LOG

Constructor Details

AbstractMultiOutputCompactor

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

Method Details

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