Uses of Class
org.apache.druid.client.indexing.ClientCompactionTaskQuery
Packages that use ClientCompactionTaskQuery
-
Uses of ClientCompactionTaskQuery in org.apache.druid.server.compaction
Methods in org.apache.druid.server.compaction that return types with arguments of type ClientCompactionTaskQueryModifier and TypeMethodDescriptionCompactionSlotManager.fetchRunningCompactionTasks()Retrieves currently running tasks of typeCompactionSlotManager.COMPACTION_TASK_TYPEfrom the Overlord.Methods in org.apache.druid.server.compaction with parameters of type ClientCompactionTaskQueryModifier and TypeMethodDescriptionbooleanCompactionSlotManager.cancelTaskOnlyIfGranularityChanged(ClientCompactionTaskQuery compactionTaskQuery, DataSourceCompactionConfig dataSourceCompactionConfig) Cancels a currently running compaction task only if the segment granularity has changed in the datasource compaction config.static intCompactionSlotManager.computeSlotsRequiredForTask(ClientCompactionTaskQuery task) Computes the number of task slots required to run this compaction task.intCompactionSlotManager.computeSlotsRequiredForTask(ClientCompactionTaskQuery task, DataSourceCompactionConfig config) Computes the maximum number of slots required for a compaction task.voidCompactionSlotManager.reserveTaskSlots(ClientCompactionTaskQuery compactionTaskQuery) Reserves task slots for the given task from the overall compaction task capacity. -
Uses of ClientCompactionTaskQuery in org.apache.druid.server.coordinator.duty
Methods in org.apache.druid.server.coordinator.duty that return ClientCompactionTaskQueryModifier and TypeMethodDescriptionstatic ClientCompactionTaskQueryCompactSegments.createCompactionTask(CompactionCandidate candidate, Eligibility eligibility, DataSourceCompactionConfig config, CompactionEngine defaultEngine, String indexingStateFingerprint, boolean storeCompactionStatePerSegment) Creates aClientCompactionTaskQuerywhich can be submitted to anOverlordClientto start a compaction task.