org.apache.hadoop.hbase.regionserver.compactions

Class CompactionRequestImpl

java.lang.Object

org.apache.hadoop.hbase.regionserver.compactions.CompactionRequestImpl

All Implemented Interfaces:

CompactionRequest

Direct Known Subclasses:

DateTieredCompactionRequest

@InterfaceAudience.Private
public class CompactionRequestImpl
extends Object
implements CompactionRequest

This class holds all logical details necessary to run a compaction.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	CompactionRequestImpl.DisplayCompactionType

Field Summary

Fields

Modifier and Type	Field and Description
private Collection<HStoreFile>	filesToCompact
private boolean	isAfterSplit
private CompactionRequestImpl.DisplayCompactionType	isMajor
private boolean	isOffPeak
private int	priority
private String	regionName
private long	selectionTime
private String	storeName
private long	totalSize
private CompactionLifeCycleTracker	tracker
private Consumer<org.apache.hadoop.fs.Path>	writerCreationTracker

Constructor Summary

Constructors

Constructor and Description
CompactionRequestImpl(Collection<HStoreFile> files)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
Collection<HStoreFile>	getFiles() Returns unmodifiable collection of StoreFiles in compaction
int	getPriority() Gets the priority for the request
long	getSelectionTime() Returns compaction request creation time in milliseconds
long	getSize() Gets the total size of all StoreFiles in compaction
CompactionLifeCycleTracker	getTracker()
Consumer<org.apache.hadoop.fs.Path>	getWriterCreationTracker()
int	hashCode()
boolean	isAfterSplit()
boolean	isAllFiles() Returns true if major compaction or all files are compacted
boolean	isMajor() Returns true if major compaction
boolean	isOffPeak() Returns true if compaction is Off-peak
private void	recalculateSize() Recalculate the size of the compaction based on current files.
void	setAfterSplit(boolean afterSplit)
void	setDescription(String regionName, String storeName) Sets the region/store name, for logging.
void	setIsMajor(boolean isMajor, boolean isAllFiles) Specify if this compaction should be a major compaction based on the state of the store
void	setOffPeak(boolean value)
void	setPriority(int p) Sets the priority for the request
void	setTracker(CompactionLifeCycleTracker tracker)
void	setWriterCreationTracker(Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
String	toString()
void	updateFiles(Collection<HStoreFile> files)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

isOffPeak

private boolean isOffPeak

isMajor

private CompactionRequestImpl.DisplayCompactionType isMajor

priority

private int priority

filesToCompact

private Collection<HStoreFile> filesToCompact

isAfterSplit

private boolean isAfterSplit

selectionTime

private long selectionTime

regionName

private String regionName

storeName

private String storeName

totalSize

private long totalSize

tracker

private CompactionLifeCycleTracker tracker

writerCreationTracker

private Consumer<org.apache.hadoop.fs.Path> writerCreationTracker

Constructor Detail

CompactionRequestImpl

public CompactionRequestImpl(Collection<HStoreFile> files)

Method Detail

updateFiles

public void updateFiles(Collection<HStoreFile> files)

getFiles

public Collection<HStoreFile> getFiles()

Description copied from interface: CompactionRequest

Returns unmodifiable collection of StoreFiles in compaction

Specified by:

getFiles in interface CompactionRequest

setDescription

public void setDescription(String regionName,
                           String storeName)

Sets the region/store name, for logging.

getSize

public long getSize()

Gets the total size of all StoreFiles in compaction

Specified by:

getSize in interface CompactionRequest

isAllFiles

public boolean isAllFiles()

Description copied from interface: CompactionRequest

Returns true if major compaction or all files are compacted

Specified by:

isAllFiles in interface CompactionRequest

isMajor

public boolean isMajor()

Description copied from interface: CompactionRequest

Returns true if major compaction

Specified by:

isMajor in interface CompactionRequest

getPriority

public int getPriority()

Gets the priority for the request

Specified by:

getPriority in interface CompactionRequest

setPriority

public void setPriority(int p)

Sets the priority for the request

isOffPeak

public boolean isOffPeak()

Description copied from interface: CompactionRequest

Returns true if compaction is Off-peak

Specified by:

isOffPeak in interface CompactionRequest

setOffPeak

public void setOffPeak(boolean value)

getSelectionTime

public long getSelectionTime()

Description copied from interface: CompactionRequest

Returns compaction request creation time in milliseconds

Specified by:

getSelectionTime in interface CompactionRequest

setIsMajor

public void setIsMajor(boolean isMajor,
                       boolean isAllFiles)

Specify if this compaction should be a major compaction based on the state of the store

Parameters:

isMajor - true if the system determines that this compaction should be a major compaction

setTracker

public void setTracker(CompactionLifeCycleTracker tracker)

getTracker

public CompactionLifeCycleTracker getTracker()

getWriterCreationTracker

public Consumer<org.apache.hadoop.fs.Path> getWriterCreationTracker()

setWriterCreationTracker

public void setWriterCreationTracker(Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)

isAfterSplit

public boolean isAfterSplit()

setAfterSplit

public void setAfterSplit(boolean afterSplit)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

recalculateSize

private void recalculateSize()

Recalculate the size of the compaction based on current files.