Package org.apache.druid.server.compaction

Class CompactionStatusTracker

java.lang.Object

org.apache.druid.server.compaction.CompactionStatusTracker

public class CompactionStatusTracker
extends Object

Tracks status of recently submitted compaction tasks. Can be used by a segment search policy to skip an interval if it has been recently compacted or if it keeps failing repeatedly.

Constructor Summary

Constructors

Constructor	Description
CompactionStatusTracker()

Method Summary

Modifier and Type	Method	Description
CompactionStatus	computeCompactionStatus(CompactionCandidate candidate, CompactionCandidateSearchPolicy searchPolicy)	Deprecated. This method is used only by Coordinator-based CompactSegments duty and will be removed in the future.
CompactionStatus	deriveCompactionStatus(CompactionTaskStatus lastTaskStatus)
@Nullable CompactionTaskStatus	getLatestTaskStatus(CompactionCandidate candidates)
Set<String>	getSubmittedTaskIds()	Set of submitted compaction task IDs which have not been marked completed via onTaskFinished(java.lang.String, org.apache.druid.indexer.TaskStatus) yet.
void	onCompactionStatusComputed(CompactionCandidate candidateSegments, DataSourceCompactionConfig config)	Tracks the latest compaction status of the given compaction candidates.
void	onSegmentTimelineUpdated(org.joda.time.DateTime snapshotTime)
void	onTaskFinished(String taskId, TaskStatus taskStatus)
void	onTaskSubmitted(String taskId, CompactionCandidate candidateSegments)
void	removeDatasource(String datasource)
void	resetActiveDatasources(Set<String> compactionEnabledDatasources)	Updates the set of datasources that have compaction enabled and cleans up stale task statuses.
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

CompactionStatusTracker

public CompactionStatusTracker()

Method Details

stop

public void stop()

removeDatasource

public void removeDatasource(String datasource)

getLatestTaskStatus

public @Nullable CompactionTaskStatus getLatestTaskStatus(CompactionCandidate candidates)

getSubmittedTaskIds

public Set<String> getSubmittedTaskIds()

Set of submitted compaction task IDs which have not been marked completed via onTaskFinished(java.lang.String, org.apache.druid.indexer.TaskStatus) yet.

computeCompactionStatus

@Deprecated
public CompactionStatus computeCompactionStatus(CompactionCandidate candidate,
 CompactionCandidateSearchPolicy searchPolicy)

Deprecated.

This method is used only by Coordinator-based CompactSegments duty and will be removed in the future.

Checks if compaction can be started for the given CompactionCandidate. This method assumes that the given candidate is eligible for compaction based on the current compaction config/supervisor of the datasource.

deriveCompactionStatus

public CompactionStatus deriveCompactionStatus(CompactionTaskStatus lastTaskStatus)

onCompactionStatusComputed

public void onCompactionStatusComputed(CompactionCandidate candidateSegments,
 DataSourceCompactionConfig config)

Tracks the latest compaction status of the given compaction candidates. Used only by the CompactionRunSimulator.

onSegmentTimelineUpdated

public void onSegmentTimelineUpdated(org.joda.time.DateTime snapshotTime)

resetActiveDatasources

public void resetActiveDatasources(Set<String> compactionEnabledDatasources)

Updates the set of datasources that have compaction enabled and cleans up stale task statuses.

onTaskSubmitted

public void onTaskSubmitted(String taskId,
 CompactionCandidate candidateSegments)

onTaskFinished

public void onTaskFinished(String taskId,
 TaskStatus taskStatus)