Package org.apache.druid.server.compaction
package org.apache.druid.server.compaction
-
ClassDescriptionBase implementation for reindexing rules that apply based on data age thresholds.Base implementation of
CompactionCandidateSearchPolicythat can have apriorityDatasource.Non-empty list of segments of a datasource being considered for compaction.Policy used byCompactSegmentsduty to pick segments for compaction.Represents the mode of compaction for segment intervals.Response of/compaction/progressAPI exposed by Coordinator and Overlord (when compaction supervisors are enabled).Deprecated.The simulator does not support the Overlord-based CompactionJobQueue or the new reindexing templates.Iterator over compactible segments.Fetches running compaction tasks from the Overlord and tracks their compaction intervals and task slots.BuildsAutoCompactionSnapshotfor multiple datasources using the identifiedCompactionCandidatelist.Used to track statistics for segments in different states of compaction.Represents the status of compaction for a givenCompactionCandidate.Response of/compaction/statusAPI exposed by Coordinator and Overlord (when compaction supervisors are enabled).Tracks status of recently submitted compaction tasks.A meta-provider that composes multipleReindexingRuleProviders with first-wins semantics.Iterator over compactible segments of a datasource in order of specified priority.Describes the eligibility of an interval for compaction.Implementation ofCompactionCandidateSearchPolicythat specifies the datasources and intervals eligible for compaction and their order.Specifies a datasource-interval eligible for compaction.Rule provider that returns a static list of rules defined inline in the configuration.Associates a time interval with its partitioning information.ExperimentalCompactionCandidateSearchPolicywhich prioritizes compaction of intervals with the largest number of small uncompacted segments.Implementation ofCompactionCandidateSearchPolicythat prioritizes intervals which have the latest data.Implementation ofCompactionSegmentIteratorthat returns candidate segments in order of their priority.AReindexingRulethat specifies a data schema for reindexing tasks to configure.AReindexingRulethat specifies patterns to match for removing rows during reindexing.AReindexingRulethat specifies anIndexSpecfor reindexing tasks to configure.AReindexingRulethat specifies partitioning configuration for reindexing tasks.Defines a reindexing configuration that applies to data based on age thresholds.Indicates how a rule applies to a given time interval based on the rule's period threshold.Provides compaction rules for different aspects of reindexing configuration.A simple table POJO with any number of rows and specified column names.