Uses of Class
org.apache.druid.server.compaction.CompactionCandidate

Packages that use CompactionCandidate

Package	Description
org.apache.druid.server.compaction
org.apache.druid.server.coordinator.duty

Uses of CompactionCandidate in org.apache.druid.server.compaction

Methods in org.apache.druid.server.compaction that return CompactionCandidate

Modifier and Type	Method	Description
static CompactionCandidate	CompactionCandidate.from(List<DataSegment> segments, Granularity targetSegmentGranularity, CompactionStatus currentStatus)
CompactionCandidate	DataSourceCompactibleSegmentIterator.next()
CompactionCandidate	PriorityBasedCompactionSegmentIterator.next()
CompactionCandidate	CompactionCandidate.withCurrentStatus(CompactionStatus status)	Creates a copy of this CompactionCandidate object with the given status.

Methods in org.apache.druid.server.compaction that return types with arguments of type CompactionCandidate

Modifier and Type	Method	Description
List<CompactionCandidate>	CompactionSegmentIterator.getCompactedSegments()	List of candidate segments that are already compacted and do not need to be compacted again.
List<CompactionCandidate>	DataSourceCompactibleSegmentIterator.getCompactedSegments()
List<CompactionCandidate>	PriorityBasedCompactionSegmentIterator.getCompactedSegments()
protected abstract Comparator<CompactionCandidate>	BaseCandidateSearchPolicy.getSegmentComparator()	Compares between two compaction candidates.
protected Comparator<CompactionCandidate>	MostFragmentedIntervalFirstPolicy.getSegmentComparator()
protected Comparator<CompactionCandidate>	NewestSegmentFirstPolicy.getSegmentComparator()
List<CompactionCandidate>	CompactionSegmentIterator.getSkippedSegments()	List of candidate segments that have been skipped for compaction as they cannot be compacted due to some reason.
List<CompactionCandidate>	DataSourceCompactibleSegmentIterator.getSkippedSegments()
List<CompactionCandidate>	PriorityBasedCompactionSegmentIterator.getSkippedSegments()

Methods in org.apache.druid.server.compaction with parameters of type CompactionCandidate

Modifier and Type	Method	Description
void	CompactionSnapshotBuilder.addToComplete(CompactionCandidate candidate)
void	CompactionSnapshotBuilder.addToPending(CompactionCandidate candidate)
void	CompactionSnapshotBuilder.addToSkipped(CompactionCandidate candidate)
Eligibility	BaseCandidateSearchPolicy.checkEligibilityForCompaction(CompactionCandidate candidate, CompactionTaskStatus latestTaskStatus)
Eligibility	CompactionCandidateSearchPolicy.checkEligibilityForCompaction(CompactionCandidate candidate, CompactionTaskStatus latestTaskStatus)	Checks if the given CompactionCandidate is eligible for compaction in the current iteration.
Eligibility	FixedIntervalOrderPolicy.checkEligibilityForCompaction(CompactionCandidate candidate, CompactionTaskStatus latestTaskStatus)
Eligibility	MostFragmentedIntervalFirstPolicy.checkEligibilityForCompaction(CompactionCandidate candidate, CompactionTaskStatus latestTaskStatus)
final int	BaseCandidateSearchPolicy.compareCandidates(CompactionCandidate o1, CompactionCandidate o2)
int	CompactionCandidateSearchPolicy.compareCandidates(CompactionCandidate candidateA, CompactionCandidate candidateB)	Compares between two compaction candidates.
int	FixedIntervalOrderPolicy.compareCandidates(CompactionCandidate candidateA, CompactionCandidate candidateB)
CompactionStatus	CompactionStatusTracker.computeCompactionStatus(CompactionCandidate candidate, CompactionCandidateSearchPolicy searchPolicy)	Deprecated. This method is used only by Coordinator-based CompactSegments duty and will be removed in the future.
@Nullable CompactionTaskStatus	CompactionStatusTracker.getLatestTaskStatus(CompactionCandidate candidates)
void	CompactionSnapshotBuilder.moveFromPendingToCompleted(CompactionCandidate candidate)
void	CompactionSnapshotBuilder.moveFromPendingToSkipped(CompactionCandidate candidate)
void	CompactionStatusTracker.onCompactionStatusComputed(CompactionCandidate candidateSegments, DataSourceCompactionConfig config)	Tracks the latest compaction status of the given compaction candidates.
void	CompactionStatusTracker.onTaskSubmitted(String taskId, CompactionCandidate candidateSegments)

Uses of CompactionCandidate in org.apache.druid.server.coordinator.duty

Methods in org.apache.druid.server.coordinator.duty with parameters of type CompactionCandidate

Modifier and Type	Method	Description
static ClientCompactionTaskQuery	CompactSegments.createCompactionTask(CompactionCandidate candidate, Eligibility eligibility, DataSourceCompactionConfig config, CompactionEngine defaultEngine, String indexingStateFingerprint, boolean storeCompactionStatePerSegment)	Creates a ClientCompactionTaskQuery which can be submitted to an OverlordClient to start a compaction task.