Path	Lines of Code
indexing-service/src/main/java/org/apache/druid/guice/IndexingServiceInputSourceModule.java	29
indexing-service/src/main/java/org/apache/druid/guice/IndexingServiceModuleHelper.java	17
indexing-service/src/main/java/org/apache/druid/guice/IndexingServiceTaskLogsModule.java	29
indexing-service/src/main/java/org/apache/druid/guice/IndexingServiceTuningConfigModule.java	30
indexing-service/src/main/java/org/apache/druid/guice/PeonProcessingModule.java	107
indexing-service/src/main/java/org/apache/druid/guice/SupervisorModule.java	30
indexing-service/src/main/java/org/apache/druid/indexing/appenderator/ActionBasedPublishedSegmentRetriever.java	73
indexing-service/src/main/java/org/apache/druid/indexing/appenderator/ActionBasedSegmentAllocator.java	37
indexing-service/src/main/java/org/apache/druid/indexing/appenderator/SegmentAllocateActionGenerator.java	15
indexing-service/src/main/java/org/apache/druid/indexing/common/AdjustedRuntimeInfo.java	27
indexing-service/src/main/java/org/apache/druid/indexing/common/Counters.java	26
indexing-service/src/main/java/org/apache/druid/indexing/common/LockGranularity.java	6
indexing-service/src/main/java/org/apache/druid/indexing/common/MultipleFileTaskReportFileWriter.java	56
indexing-service/src/main/java/org/apache/druid/indexing/common/RetryPolicy.java	30
indexing-service/src/main/java/org/apache/druid/indexing/common/RetryPolicyConfig.java	39
indexing-service/src/main/java/org/apache/druid/indexing/common/RetryPolicyFactory.java	15
indexing-service/src/main/java/org/apache/druid/indexing/common/SegmentCacheManagerFactory.java	42
indexing-service/src/main/java/org/apache/druid/indexing/common/SegmentLock.java	183
indexing-service/src/main/java/org/apache/druid/indexing/common/TaskInfoProvider.java	9
indexing-service/src/main/java/org/apache/druid/indexing/common/TaskLock.java	38
indexing-service/src/main/java/org/apache/druid/indexing/common/TaskLockType.java	8
indexing-service/src/main/java/org/apache/druid/indexing/common/TaskRealtimeMetricsMonitorBuilder.java	31
indexing-service/src/main/java/org/apache/druid/indexing/common/TaskStorageDirTracker.java	179
indexing-service/src/main/java/org/apache/druid/indexing/common/TaskToolbox.java	786
indexing-service/src/main/java/org/apache/druid/indexing/common/TaskToolboxFactory.java	247
indexing-service/src/main/java/org/apache/druid/indexing/common/TimeChunkLock.java	173
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/CheckPointDataSourceMetadataAction.java	115
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/LocalTaskActionClient.java	74
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/LocalTaskActionClientFactory.java	17
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/LockListAction.java	23
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/LockReleaseAction.java	40
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/MarkSegmentsAsUnusedAction.java	41
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/RemoteTaskActionClient.java	66
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/RemoteTaskActionClientFactory.java	42
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/ResetDataSourceMetadataAction.java	46
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/RetrieveSegmentsByIdAction.java	68
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/RetrieveUnusedSegmentsAction.java	83
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/RetrieveUpgradedFromSegmentIdsAction.java	53
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/RetrieveUpgradedToSegmentIdsAction.java	53
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/RetrieveUsedSegmentsAction.java	169
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentAllocateAction.java	315
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentAllocateRequest.java	57
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentAllocateResult.java	24
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentAllocationQueue.java	575
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentLockAcquireAction.java	94
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentLockTryAcquireAction.java	79
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentMetadataUpdateAction.java	77
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentNukeAction.java	77
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentTransactionalAppendAction.java	162
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentTransactionalInsertAction.java	251
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentTransactionalReplaceAction.java	125
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SurrogateAction.java	54
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SurrogateTaskActionClient.java	17
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/TaskAction.java	48
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/TaskActionClient.java	6
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/TaskActionClientFactory.java	6
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/TaskActionHolder.java	28
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/TaskActionToolbox.java	105
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/TaskLocks.java	189
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/TimeChunkLockAcquireAction.java	73
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/TimeChunkLockTryAcquireAction.java	57
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/UpdateLocationAction.java	45
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/UpdateStatusAction.java	80
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/UpgradedFromSegmentsResponse.java	20
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/UpgradedToSegmentsResponse.java	21
indexing-service/src/main/java/org/apache/druid/indexing/common/config/FileTaskLogsConfig.java	21
indexing-service/src/main/java/org/apache/druid/indexing/common/config/TaskConfig.java	265
indexing-service/src/main/java/org/apache/druid/indexing/common/config/TaskStorageConfig.java	25
indexing-service/src/main/java/org/apache/druid/indexing/common/stats/DropwizardRowIngestionMeters.java	115
indexing-service/src/main/java/org/apache/druid/indexing/common/stats/DropwizardRowIngestionMetersFactory.java	11
indexing-service/src/main/java/org/apache/druid/indexing/common/stats/TaskRealtimeMetricsMonitor.java	105
indexing-service/src/main/java/org/apache/druid/indexing/common/task/AbstractBatchIndexTask.java	779
indexing-service/src/main/java/org/apache/druid/indexing/common/task/AbstractFixedIntervalTask.java	87
indexing-service/src/main/java/org/apache/druid/indexing/common/task/AbstractTask.java	354
indexing-service/src/main/java/org/apache/druid/indexing/common/task/ArchiveTask.java	77
indexing-service/src/main/java/org/apache/druid/indexing/common/task/BatchAppenderators.java	81
indexing-service/src/main/java/org/apache/druid/indexing/common/task/CachingLocalSegmentAllocator.java	127
indexing-service/src/main/java/org/apache/druid/indexing/common/task/CompactionIOConfig.java	71
indexing-service/src/main/java/org/apache/druid/indexing/common/task/CompactionInputSpec.java	18
indexing-service/src/main/java/org/apache/druid/indexing/common/task/CompactionIntervalSpec.java	91
indexing-service/src/main/java/org/apache/druid/indexing/common/task/CompactionRunner.java	28
indexing-service/src/main/java/org/apache/druid/indexing/common/task/CompactionTask.java	1295
indexing-service/src/main/java/org/apache/druid/indexing/common/task/CurrentSubTaskHolder.java	33
indexing-service/src/main/java/org/apache/druid/indexing/common/task/FilteringCloseableInputRowIterator.java	65
indexing-service/src/main/java/org/apache/druid/indexing/common/task/HadoopIndexTask.java	905
indexing-service/src/main/java/org/apache/druid/indexing/common/task/HadoopTask.java	169
indexing-service/src/main/java/org/apache/druid/indexing/common/task/IndexTask.java	1438
indexing-service/src/main/java/org/apache/druid/indexing/common/task/IndexTaskUtils.java	72
indexing-service/src/main/java/org/apache/druid/indexing/common/task/Initialization.java	31
indexing-service/src/main/java/org/apache/druid/indexing/common/task/InputSourceProcessor.java	101
indexing-service/src/main/java/org/apache/druid/indexing/common/task/KillUnusedSegmentsTask.java	323
indexing-service/src/main/java/org/apache/druid/indexing/common/task/LinearlyPartitionedSequenceNameFunction.java	16
indexing-service/src/main/java/org/apache/druid/indexing/common/task/LocalSegmentAllocator.java	73
indexing-service/src/main/java/org/apache/druid/indexing/common/task/MoveTask.java	84
indexing-service/src/main/java/org/apache/druid/indexing/common/task/NativeCompactionRunner.java	277
indexing-service/src/main/java/org/apache/druid/indexing/common/task/NonLinearlyPartitionedSequenceNameFunction.java	23
indexing-service/src/main/java/org/apache/druid/indexing/common/task/NoopTask.java	99
indexing-service/src/main/java/org/apache/druid/indexing/common/task/NoopTaskContextEnricher.java	9
indexing-service/src/main/java/org/apache/druid/indexing/common/task/OverlordCoordinatingSegmentAllocator.java	118
indexing-service/src/main/java/org/apache/druid/indexing/common/task/PendingSegmentAllocatingTask.java	5
indexing-service/src/main/java/org/apache/druid/indexing/common/task/RestoreTask.java	88
indexing-service/src/main/java/org/apache/druid/indexing/common/task/SegmentAllocatorForBatch.java	6
indexing-service/src/main/java/org/apache/druid/indexing/common/task/SegmentAllocators.java	76
indexing-service/src/main/java/org/apache/druid/indexing/common/task/SequenceNameFunction.java	8
indexing-service/src/main/java/org/apache/druid/indexing/common/task/ShardSpecs.java	27
indexing-service/src/main/java/org/apache/druid/indexing/common/task/SpecificSegmentsSpec.java	85
indexing-service/src/main/java/org/apache/druid/indexing/common/task/SupervisorTaskCoordinatingSegmentAllocator.java	41
indexing-service/src/main/java/org/apache/druid/indexing/common/task/Task.java	133
indexing-service/src/main/java/org/apache/druid/indexing/common/task/TaskContextEnricher.java	7
indexing-service/src/main/java/org/apache/druid/indexing/common/task/TaskLockHelper.java	240
indexing-service/src/main/java/org/apache/druid/indexing/common/task/TaskResource.java	37
indexing-service/src/main/java/org/apache/druid/indexing/common/task/TaskResourceCleaner.java	39
indexing-service/src/main/java/org/apache/druid/indexing/common/task/Tasks.java	33
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/MaxAllowedLocksExceededException.java	19
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/TooManyBucketsException.java	15
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/AbstractBatchSubtask.java	30
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/DeepStoragePartitionLocation.java	87
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/DeepStoragePartitionStat.java	80
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/DeepStorageShuffleClient.java	36
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/DimensionCardinalityReport.java	65
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/DimensionDistributionReport.java	60
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/GeneratedPartitionsMetadataReport.java	18
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/GeneratedPartitionsReport.java	61
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/GenericPartitionLocation.java	124
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/GenericPartitionStat.java	134
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/HttpShuffleClient.java	68
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/InputSourceSplitParallelIndexTaskRunner.java	82
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/LegacySinglePhaseSubTask.java	36
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexIOConfig.java	22
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexIngestionSpec.java	60
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexPhaseRunner.java	366
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexSupervisorTask.java	1616
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexSupervisorTaskClient.java	16
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexSupervisorTaskClientImpl.java	81
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexSupervisorTaskClientProvider.java	10
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexSupervisorTaskClientProviderImpl.java	50
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexTaskRunner.java	64
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexTuningConfig.java	273
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexingPhaseProgress.java	63
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialDimensionCardinalityParallelIndexTaskRunner.java	67
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialDimensionCardinalityTask.java	220
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialDimensionDistributionParallelIndexTaskRunner.java	240
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialDimensionDistributionTask.java	379
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialGenericSegmentMergeParallelIndexTaskRunner.java	78
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialGenericSegmentMergeTask.java	108
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialHashSegmentGenerateParallelIndexTaskRunner.java	66
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialHashSegmentGenerateTask.java	161
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialRangeSegmentGenerateParallelIndexTaskRunner.java	65
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialRangeSegmentGenerateTask.java	155
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialSegmentGenerateTask.java	207
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialSegmentMergeIOConfig.java	26
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialSegmentMergeIngestionSpec.java	15
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialSegmentMergeTask.java	349
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartitionLocation.java	17
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartitionStat.java	18
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PerfectRollupWorkerTask.java	81
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PushedSegmentsReport.java	80
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/SegmentAllocationRequest.java	60
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ShuffleClient.java	11
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/SinglePhaseParallelIndexTaskRunner.java	208
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/SinglePhaseSubTask.java	459
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/SinglePhaseSubTaskSpec.java	54
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/SubTaskReport.java	16
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/SubTaskSpec.java	59
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/SupervisorTaskAccess.java	22
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/TaskHistory.java	37
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/TaskMonitor.java	448
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/TombstoneHelper.java	223
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/distribution/ArrayOfStringTuplesSerDe.java	106
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/distribution/ArrayOfStringsNullSafeSerde.java	75
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/distribution/StringDistribution.java	17
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/distribution/StringDistributionMerger.java	6
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/distribution/StringSketch.java	191
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/distribution/StringSketchMerger.java	25
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/iterator/DefaultIndexTaskInputRowIteratorBuilder.java	42
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/iterator/IndexTaskInputRowIteratorBuilder.java	11
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/iterator/RangePartitionIndexTaskInputRowIteratorBuilder.java	80
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/partition/CompletePartitionAnalysis.java	11
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/partition/HashPartitionAnalysis.java	80
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/partition/LinearPartitionAnalysis.java	46
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/partition/PartitionAnalysis.java	12
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/partition/RangePartitionAnalysis.java	93
indexing-service/src/main/java/org/apache/druid/indexing/common/tasklogs/ConsoleLoggingEnforcementConfigurationFactory.java	107
indexing-service/src/main/java/org/apache/druid/indexing/common/tasklogs/FileTaskLogs.java	109
indexing-service/src/main/java/org/apache/druid/indexing/common/tasklogs/LogUtils.java	20
indexing-service/src/main/java/org/apache/druid/indexing/common/tasklogs/SwitchingTaskLogStreamer.java	87
indexing-service/src/main/java/org/apache/druid/indexing/common/tasklogs/TaskRunnerTaskLogStreamer.java	37
indexing-service/src/main/java/org/apache/druid/indexing/compact/CompactionScheduler.java	21
indexing-service/src/main/java/org/apache/druid/indexing/compact/CompactionSupervisor.java	110
indexing-service/src/main/java/org/apache/druid/indexing/compact/CompactionSupervisorSpec.java	104
indexing-service/src/main/java/org/apache/druid/indexing/compact/LocalOverlordClient.java	153
indexing-service/src/main/java/org/apache/druid/indexing/compact/OverlordCompactionScheduler.java	303
indexing-service/src/main/java/org/apache/druid/indexing/hadoop/OverlordActionBasedUsedSegmentsRetriever.java	32
indexing-service/src/main/java/org/apache/druid/indexing/input/DruidInputSource.java	522
indexing-service/src/main/java/org/apache/druid/indexing/input/DruidSegmentInputEntity.java	69
indexing-service/src/main/java/org/apache/druid/indexing/input/DruidSegmentInputFormat.java	61
indexing-service/src/main/java/org/apache/druid/indexing/input/DruidSegmentReader.java	268
indexing-service/src/main/java/org/apache/druid/indexing/input/DruidTombstoneSegmentReader.java	53
indexing-service/src/main/java/org/apache/druid/indexing/input/GeneratorInputSource.java	256
indexing-service/src/main/java/org/apache/druid/indexing/input/InputRowSchemas.java	75
indexing-service/src/main/java/org/apache/druid/indexing/input/TaskInputSource.java	7
indexing-service/src/main/java/org/apache/druid/indexing/input/WindowedSegmentId.java	62
indexing-service/src/main/java/org/apache/druid/indexing/overlord/BaseRestorableTaskRunner.java	180
indexing-service/src/main/java/org/apache/druid/indexing/overlord/CriticalAction.java	45
indexing-service/src/main/java/org/apache/druid/indexing/overlord/DruidOverlord.java	226
indexing-service/src/main/java/org/apache/druid/indexing/overlord/ForkingTaskRunner.java	786
indexing-service/src/main/java/org/apache/druid/indexing/overlord/ForkingTaskRunnerFactory.java	69
indexing-service/src/main/java/org/apache/druid/indexing/overlord/HeapMemoryTaskStorage.java	309
indexing-service/src/main/java/org/apache/druid/indexing/overlord/ImmutableWorkerInfo.java	253
indexing-service/src/main/java/org/apache/druid/indexing/overlord/IndexerMetadataStorageAdapter.java	50
indexing-service/src/main/java/org/apache/druid/indexing/overlord/LockRequest.java	17
indexing-service/src/main/java/org/apache/druid/indexing/overlord/LockRequestForNewSegment.java	158
indexing-service/src/main/java/org/apache/druid/indexing/overlord/LockResult.java	58
indexing-service/src/main/java/org/apache/druid/indexing/overlord/MetadataTaskStorage.java	252
indexing-service/src/main/java/org/apache/druid/indexing/overlord/PortFinder.java	77
indexing-service/src/main/java/org/apache/druid/indexing/overlord/QuotableWhiteSpaceSplitter.java	34
indexing-service/src/main/java/org/apache/druid/indexing/overlord/RemoteTaskRunner.java	1368
indexing-service/src/main/java/org/apache/druid/indexing/overlord/RemoteTaskRunnerFactory.java	73
indexing-service/src/main/java/org/apache/druid/indexing/overlord/RemoteTaskRunnerWorkItem.java	110
indexing-service/src/main/java/org/apache/druid/indexing/overlord/RemoteTaskRunnerWorkQueue.java	11
indexing-service/src/main/java/org/apache/druid/indexing/overlord/SingleTaskBackgroundRunner.java	393
indexing-service/src/main/java/org/apache/druid/indexing/overlord/SpecificSegmentLockRequest.java	137
indexing-service/src/main/java/org/apache/druid/indexing/overlord/Stats.java	12
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskLockbox.java	1398
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskLockboxSyncResult.java	15
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskMaster.java	221
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskQueryTool.java	311
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskQueue.java	783
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskRunner.java	67
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskRunnerFactory.java	6
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskRunnerListener.java	10
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskRunnerUtils.java	86
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskRunnerWorkItem.java	72
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskStorage.java	44
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskStorageUtils.java	33
indexing-service/src/main/java/org/apache/druid/indexing/overlord/ThreadingTaskRunner.java	476
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TimeChunkLockRequest.java	125
indexing-service/src/main/java/org/apache/druid/indexing/overlord/WorkerTaskRunner.java	22
indexing-service/src/main/java/org/apache/druid/indexing/overlord/WorkerTaskRunnerQueryAdapter.java	97
indexing-service/src/main/java/org/apache/druid/indexing/overlord/ZkWorker.java	215
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/AbstractWorkerProvisioningStrategy.java	95
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/AutoScaler.java	23
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/AutoScalingData.java	23
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/NoopAutoScaler.java	53
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/NoopProvisioningStrategy.java	21
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/PendingTaskBasedWorkerProvisioningConfig.java	58
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/PendingTaskBasedWorkerProvisioningStrategy.java	439
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/Provisioner.java	9
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/ProvisioningSchedulerConfig.java	32
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/ProvisioningService.java	10
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/ProvisioningStrategy.java	15
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/ProvisioningUtil.java	40
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/ScalingStats.java	112
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/SimpleWorkerProvisioningConfig.java	68
indexing-service/src/main/java/org/apache/druid/indexing/overlord/autoscaling/SimpleWorkerProvisioningStrategy.java	310
indexing-service/src/main/java/org/apache/druid/indexing/overlord/config/DefaultTaskConfig.java	13
indexing-service/src/main/java/org/apache/druid/indexing/overlord/config/ForkingTaskRunnerConfig.java	82
indexing-service/src/main/java/org/apache/druid/indexing/overlord/config/HttpRemoteTaskRunnerConfig.java	48
indexing-service/src/main/java/org/apache/druid/indexing/overlord/config/RemoteTaskRunnerConfig.java	152
indexing-service/src/main/java/org/apache/druid/indexing/overlord/config/TaskLockConfig.java	29
indexing-service/src/main/java/org/apache/druid/indexing/overlord/config/TaskQueueConfig.java	68
indexing-service/src/main/java/org/apache/druid/indexing/overlord/config/WorkerTaskRunnerConfig.java	17
indexing-service/src/main/java/org/apache/druid/indexing/overlord/duty/DutySchedule.java	19
indexing-service/src/main/java/org/apache/druid/indexing/overlord/duty/OverlordDuty.java	7
indexing-service/src/main/java/org/apache/druid/indexing/overlord/duty/OverlordDutyExecutor.java	90
indexing-service/src/main/java/org/apache/druid/indexing/overlord/duty/TaskLogAutoCleaner.java	40
indexing-service/src/main/java/org/apache/druid/indexing/overlord/duty/TaskLogAutoCleanerConfig.java	66
indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunner.java	1599
indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunnerFactory.java	92
indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/HttpRemoteTaskRunnerResource.java	109
indexing-service/src/main/java/org/apache/druid/indexing/overlord/hrtr/WorkerHolder.java	381
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/CompactionConfigHistoryResponse.java	37
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/CompactionConfigsResponse.java	37
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/OverlordCompactionResource.java	352
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/OverlordDataSourcesResource.java	246
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/OverlordRedirectInfo.java	45
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/OverlordResource.java	779
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/TaskLockResponse.java	29
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/TaskPayloadResponse.java	55
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/TaskStateLookup.java	19
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/TaskStatusResponse.java	58
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/TotalWorkerCapacityResponse.java	35
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/security/SupervisorResourceFilter.java	81
indexing-service/src/main/java/org/apache/druid/indexing/overlord/http/security/TaskResourceFilter.java	71
indexing-service/src/main/java/org/apache/druid/indexing/overlord/sampler/IndexTaskSamplerSpec.java	76
indexing-service/src/main/java/org/apache/druid/indexing/overlord/sampler/InputSourceSampler.java	259
indexing-service/src/main/java/org/apache/druid/indexing/overlord/sampler/SamplerConfig.java	51
indexing-service/src/main/java/org/apache/druid/indexing/overlord/sampler/SamplerException.java	9
indexing-service/src/main/java/org/apache/druid/indexing/overlord/sampler/SamplerExceptionMapper.java	23
indexing-service/src/main/java/org/apache/druid/indexing/overlord/sampler/SamplerInputRow.java	79
indexing-service/src/main/java/org/apache/druid/indexing/overlord/sampler/SamplerModule.java	33
indexing-service/src/main/java/org/apache/druid/indexing/overlord/sampler/SamplerResource.java	60
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/AffinityConfig.java	64
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/DefaultWorkerBehaviorConfig.java	68
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/EqualDistributionWithAffinityWorkerSelectStrategy.java	14
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/EqualDistributionWithCategorySpecWorkerSelectStrategy.java	77
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/EqualDistributionWorkerSelectStrategy.java	84
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/FillCapacityWithAffinityWorkerSelectStrategy.java	14
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/FillCapacityWithCategorySpecWorkerSelectStrategy.java	77
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/FillCapacityWorkerSelectStrategy.java	84
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/JavaScriptUtil.java	24
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/JavaScriptWorkerSelectStrategy.java	72
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/TaskLimits.java	136
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/WorkerBehaviorConfig.java	15
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/WorkerCategorySpec.java	106
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/WorkerSelectStrategy.java	29
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/WorkerSelectUtils.java	135
indexing-service/src/main/java/org/apache/druid/indexing/overlord/supervisor/CompactionSupervisorManager.java	140
indexing-service/src/main/java/org/apache/druid/indexing/overlord/supervisor/SupervisorManager.java	405
indexing-service/src/main/java/org/apache/druid/indexing/overlord/supervisor/SupervisorResource.java	624
indexing-service/src/main/java/org/apache/druid/indexing/package-info.java	3
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/BatchSupervisorTaskReport.java	42
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/BatchSupervisorTaskStatus.java	45
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/CronSchedulerConfig.java	18
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/CronSchedulerUtils.java	38
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/QuartzCronSchedulerConfig.java	68
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchStatusTracker.java	106
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchSupervisor.java	83
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchSupervisorSpec.java	151
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchSupervisorStatus.java	57
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchTaskManager.java	229
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/UnixCronSchedulerConfig.java	84
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/RecordSupplierInputSource.java	142
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamAppenderatorConfig.java	198
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamDataSourceMetadata.java	89
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamEndSequenceNumbers.java	154
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTask.java	229
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskClient.java	39
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskClientAsyncImpl.java	560
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskClientFactory.java	60
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskIOConfig.java	110
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java	1672
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskTuningConfig.java	305
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamSamplerSpec.java	219
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamSequenceNumbers.java	40
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamStartSequenceNumbers.java	180
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SequenceMetadata.java	374
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SettableByteEntity.java	67
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SettableByteEntityReader.java	48
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/StreamChunkParser.java	139
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/common/OrderedPartitionableRecord.java	95
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/common/OrderedSequenceNumber.java	57
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/common/RecordSupplier.java	35
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/common/StreamException.java	8
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/common/StreamPartition.java	53
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/extension/KafkaConfigOverrides.java	10
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/IdleConfig.java	41
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/NoticesQueue.java	45
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java	3687
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorIOConfig.java	174
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorIngestionSpec.java	36
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorReportPayload.java	170
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorSpec.java	158
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorStateManager.java	78
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorTuningConfig.java	30
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/TaskReportData.java	98
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/autoscaler/AutoScalerConfig.java	23
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/autoscaler/LagBasedAutoScaler.java	225
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/autoscaler/LagBasedAutoScalerConfig.java	192
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/autoscaler/NoopTaskAutoScaler.java	20
indexing-service/src/main/java/org/apache/druid/indexing/worker/TaskAnnouncement.java	103
indexing-service/src/main/java/org/apache/druid/indexing/worker/Worker.java	111
indexing-service/src/main/java/org/apache/druid/indexing/worker/WorkerCuratorCoordinator.java	172
indexing-service/src/main/java/org/apache/druid/indexing/worker/WorkerHistoryItem.java	81
indexing-service/src/main/java/org/apache/druid/indexing/worker/WorkerTaskManager.java	686
indexing-service/src/main/java/org/apache/druid/indexing/worker/WorkerTaskMonitor.java	173
indexing-service/src/main/java/org/apache/druid/indexing/worker/executor/ExecutorLifecycle.java	177
indexing-service/src/main/java/org/apache/druid/indexing/worker/executor/ExecutorLifecycleConfig.java	56
indexing-service/src/main/java/org/apache/druid/indexing/worker/http/TaskManagementResource.java	172
indexing-service/src/main/java/org/apache/druid/indexing/worker/http/WorkerResource.java	192
indexing-service/src/main/java/org/apache/druid/indexing/worker/shuffle/DeepStorageIntermediaryDataManager.java	72
indexing-service/src/main/java/org/apache/druid/indexing/worker/shuffle/IntermediaryDataManager.java	44
indexing-service/src/main/java/org/apache/druid/indexing/worker/shuffle/LocalIntermediaryDataManager.java	337
indexing-service/src/main/java/org/apache/druid/indexing/worker/shuffle/ShuffleDataSegmentPusher.java	43
indexing-service/src/main/java/org/apache/druid/indexing/worker/shuffle/ShuffleMetrics.java	53
indexing-service/src/main/java/org/apache/druid/indexing/worker/shuffle/ShuffleModule.java	28
indexing-service/src/main/java/org/apache/druid/indexing/worker/shuffle/ShuffleMonitor.java	35
indexing-service/src/main/java/org/apache/druid/indexing/worker/shuffle/ShuffleResource.java	91
indexing-service/src/main/java/org/apache/druid/server/initialization/IndexerZkConfig.java	96