Package org.apache.druid.server.compaction

Class FixedIntervalOrderPolicy

java.lang.Object

org.apache.druid.server.compaction.FixedIntervalOrderPolicy

All Implemented Interfaces:

CompactionCandidateSearchPolicy

public class FixedIntervalOrderPolicy
extends Object
implements CompactionCandidateSearchPolicy

Implementation of CompactionCandidateSearchPolicy that specifies the datasources and intervals eligible for compaction and their order.

This policy is primarily used for integration tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FixedIntervalOrderPolicy.Candidate	Specifies a datasource-interval eligible for compaction.

Constructor Summary

Constructors

Constructor	Description
FixedIntervalOrderPolicy(List<FixedIntervalOrderPolicy.Candidate> eligibleCandidates)

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.
int	compareCandidates(CompactionCandidate candidateA, CompactionCandidate candidateB)	Compares between two compaction candidates.
List<FixedIntervalOrderPolicy.Candidate>	getEligibleCandidates()

Methods inherited from class java.lang.Object

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

Constructor Details

FixedIntervalOrderPolicy

public FixedIntervalOrderPolicy(List<FixedIntervalOrderPolicy.Candidate> eligibleCandidates)

Method Details

getEligibleCandidates

public List<FixedIntervalOrderPolicy.Candidate> getEligibleCandidates()

compareCandidates

public int compareCandidates(CompactionCandidate candidateA,
 CompactionCandidate candidateB)

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.