@InterfaceAudience.Private public class DefaultCompactor extends Compactor<StoreFileWriter>
compact(CompactionRequestImpl, ThroughputController, User)
Compactor.CellSinkFactory<S>, Compactor.FileDetails, Compactor.InternalScannerFactory
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
private Compactor.CellSinkFactory<StoreFileWriter> |
writerFactory |
COMPACTION_PROGRESS_LOG_INTERVAL, compactionKVMax, conf, defaultScannerFactory, dropCacheMajor, dropCacheMinor, keepSeqIdPeriod, MAJOR_COMPACTION_DROP_CACHE, majorCompactionCompression, MINOR_COMPACTION_DROP_CACHE, minorCompactionCompression, store
Constructor and Description |
---|
DefaultCompactor(org.apache.hadoop.conf.Configuration conf,
HStore store) |
Modifier and Type | Method and Description |
---|---|
protected void |
abortWriter(StoreFileWriter writer) |
protected List<org.apache.hadoop.fs.Path> |
commitWriter(StoreFileWriter writer,
Compactor.FileDetails fd,
CompactionRequestImpl request) |
List<org.apache.hadoop.fs.Path> |
compact(CompactionRequestImpl request,
ThroughputController throughputController,
User user)
Do a minor/major compaction on an explicit set of storefiles from a Store.
|
compact, createParams, createScanner, createScanner, createWriter, createWriter, getProgress, isCompacting, performCompaction
private static final org.slf4j.Logger LOG
private final Compactor.CellSinkFactory<StoreFileWriter> writerFactory
public DefaultCompactor(org.apache.hadoop.conf.Configuration conf, HStore store)
public List<org.apache.hadoop.fs.Path> compact(CompactionRequestImpl request, ThroughputController throughputController, User user) throws IOException
IOException
protected List<org.apache.hadoop.fs.Path> commitWriter(StoreFileWriter writer, Compactor.FileDetails fd, CompactionRequestImpl request) throws IOException
commitWriter
in class Compactor<StoreFileWriter>
IOException
protected final void abortWriter(StoreFileWriter writer) throws IOException
abortWriter
in class Compactor<StoreFileWriter>
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.