Package org.apache.hadoop.hbase.regionserver.compactions

Class DateTieredCompactor

java.lang.Object

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

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

org.apache.hadoop.hbase.regionserver.compactions.DateTieredCompactor

Direct Known Subclasses:

CustomTieredCompactor

@Private
public class DateTieredCompactor
extends AbstractMultiOutputCompactor<DateTieredMultiFileWriter>

This compactor will generate StoreFile for different time ranges.

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
DateTieredCompactor(org.apache.hadoop.conf.Configuration conf, HStore store)

Method Summary

Modifier and Type	Method	Description
protected List<org.apache.hadoop.fs.Path>	commitWriter(DateTieredMultiFileWriter writer, Compactor.FileDetails fd, CompactionRequestImpl request)
List<org.apache.hadoop.fs.Path>	compact(CompactionRequestImpl request, List<Long> lowerBoundaries, Map<Long,String> lowerBoundariesPolicies, ThroughputController throughputController, User user)
protected DateTieredMultiFileWriter	createMultiWriter(CompactionRequestImpl request, List<Long> lowerBoundaries, Map<Long,String> lowerBoundariesPolicies)
protected boolean	needEmptyFile(CompactionRequestImpl request)

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

abortWriter, initMultiWriter

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

compact, createParams, createScanner, createScanner, createWriter, createWriter, decorateCells, 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

DateTieredCompactor

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

Method Details

needEmptyFile

protected boolean needEmptyFile(CompactionRequestImpl request)

compact

public List<org.apache.hadoop.fs.Path> compact(CompactionRequestImpl request,
 List<Long> lowerBoundaries,
 Map<Long,String> lowerBoundariesPolicies,
 ThroughputController throughputController,
 User user)
                                        throws IOException

Throws:

IOException

createMultiWriter

protected DateTieredMultiFileWriter createMultiWriter(CompactionRequestImpl request,
 List<Long> lowerBoundaries,
 Map<Long,String> lowerBoundariesPolicies)

commitWriter

protected List<org.apache.hadoop.fs.Path> commitWriter(DateTieredMultiFileWriter writer,
 Compactor.FileDetails fd,
 CompactionRequestImpl request)
                                                throws IOException

Specified by:

commitWriter in class Compactor<DateTieredMultiFileWriter>

Throws:

IOException