Package org.apache.druid.server.compaction

Class BaseCandidateSearchPolicy

java.lang.Object

org.apache.druid.server.compaction.BaseCandidateSearchPolicy

All Implemented Interfaces:

CompactionCandidateSearchPolicy

Direct Known Subclasses:

MostFragmentedIntervalFirstPolicy, NewestSegmentFirstPolicy

@SubclassesMustOverrideEqualsAndHashCode
public abstract class BaseCandidateSearchPolicy
extends Object
implements CompactionCandidateSearchPolicy

Base implementation of CompactionCandidateSearchPolicy that can have a priorityDatasource.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseCandidateSearchPolicy(String priorityDatasource)

Method Summary

Modifier and Type	Method	Description
Eligibility	checkEligibilityForCompaction(CompactionCandidate candidate, CompactionTaskStatus latestTaskStatus)	Checks if the given CompactionCandidate is eligible for compaction in the current iteration.
final int	compareCandidates(CompactionCandidate o1, CompactionCandidate o2)	Compares between two compaction candidates.
boolean	equals(Object o)
final String	getPriorityDatasource()	The candidates of this datasource are prioritized over all others.
protected abstract Comparator<CompactionCandidate>	getSegmentComparator()	Compares between two compaction candidates.
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Details

BaseCandidateSearchPolicy

protected BaseCandidateSearchPolicy(@Nullable
 String priorityDatasource)

Method Details

getPriorityDatasource

@Nullable
public final String getPriorityDatasource()

The candidates of this datasource are prioritized over all others.

compareCandidates

public final int compareCandidates(CompactionCandidate o1,
 CompactionCandidate o2)

Description copied from interface: CompactionCandidateSearchPolicy

Compares between two compaction candidates. Used to determine the order in which segments and intervals should be picked for compaction.

Specified by:

compareCandidates in interface CompactionCandidateSearchPolicy

Returns:

A negative value if candidateA should be picked first, a positive value if candidateB should be picked first or zero if the order does not matter.

checkEligibilityForCompaction

public Eligibility checkEligibilityForCompaction(CompactionCandidate candidate,
 CompactionTaskStatus latestTaskStatus)

Description copied from interface: CompactionCandidateSearchPolicy

Checks if the given CompactionCandidate is eligible for compaction in the current iteration. A policy may implement this method to skip compacting intervals or segments that do not fulfil some required criteria.

Specified by:

checkEligibilityForCompaction in interface CompactionCandidateSearchPolicy

Returns:

Eligibility.FULL only if eligible.

getSegmentComparator

protected abstract Comparator<CompactionCandidate> getSegmentComparator()

Compares between two compaction candidates. Used to determine the order in which segments and intervals should be picked for compaction.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object