Path Lines of Code server/src/main/java/org/apache/druid/catalog/MetadataCatalog.java 16 server/src/main/java/org/apache/druid/catalog/NullMetadataCatalog.java 34 server/src/main/java/org/apache/druid/catalog/model/CatalogUtils.java 231 server/src/main/java/org/apache/druid/catalog/model/ColumnSpec.java 109 server/src/main/java/org/apache/druid/catalog/model/Columns.java 98 server/src/main/java/org/apache/druid/catalog/model/DatasourceProjectionMetadata.java 42 server/src/main/java/org/apache/druid/catalog/model/ModelProperties.java 259 server/src/main/java/org/apache/druid/catalog/model/ObjectDefn.java 61 server/src/main/java/org/apache/druid/catalog/model/ObjectFacade.java 38 server/src/main/java/org/apache/druid/catalog/model/ParameterizedDefn.java 10 server/src/main/java/org/apache/druid/catalog/model/ResolvedTable.java 61 server/src/main/java/org/apache/druid/catalog/model/SchemaRegistry.java 16 server/src/main/java/org/apache/druid/catalog/model/SchemaRegistryImpl.java 111 server/src/main/java/org/apache/druid/catalog/model/TableDefn.java 105 server/src/main/java/org/apache/druid/catalog/model/TableDefnRegistry.java 112 server/src/main/java/org/apache/druid/catalog/model/TableId.java 77 server/src/main/java/org/apache/druid/catalog/model/TableMetadata.java 231 server/src/main/java/org/apache/druid/catalog/model/TableSpec.java 88 server/src/main/java/org/apache/druid/catalog/model/facade/DatasourceFacade.java 150 server/src/main/java/org/apache/druid/catalog/model/facade/ExternalTableFacade.java 27 server/src/main/java/org/apache/druid/catalog/model/facade/TableFacade.java 39 server/src/main/java/org/apache/druid/catalog/model/table/BaseInputSourceDefn.java 158 server/src/main/java/org/apache/druid/catalog/model/table/BaseTableFunction.java 61 server/src/main/java/org/apache/druid/catalog/model/table/ClusterKeySpec.java 56 server/src/main/java/org/apache/druid/catalog/model/table/DatasourceDefn.java 121 server/src/main/java/org/apache/druid/catalog/model/table/ExternalTableDefn.java 71 server/src/main/java/org/apache/druid/catalog/model/table/ExternalTableSpec.java 25 server/src/main/java/org/apache/druid/catalog/model/table/FormattedInputSourceDefn.java 132 server/src/main/java/org/apache/druid/catalog/model/table/HttpInputSourceDefn.java 238 server/src/main/java/org/apache/druid/catalog/model/table/InlineInputSourceDefn.java 89 server/src/main/java/org/apache/druid/catalog/model/table/InputFormatDefn.java 19 server/src/main/java/org/apache/druid/catalog/model/table/InputFormats.java 227 server/src/main/java/org/apache/druid/catalog/model/table/InputSourceDefn.java 11 server/src/main/java/org/apache/druid/catalog/model/table/LocalInputSourceDefn.java 220 server/src/main/java/org/apache/druid/catalog/model/table/ResolvedExternalTable.java 69 server/src/main/java/org/apache/druid/catalog/model/table/TableBuilder.java 164 server/src/main/java/org/apache/druid/catalog/model/table/TableFunction.java 37 server/src/main/java/org/apache/druid/client/BatchServerInventoryView.java 354 server/src/main/java/org/apache/druid/client/BatchServerInventoryViewProvider.java 30 server/src/main/java/org/apache/druid/client/BootstrapSegmentsResponse.java 15 server/src/main/java/org/apache/druid/client/BrokerSegmentWatcherConfig.java 36 server/src/main/java/org/apache/druid/client/BrokerServerView.java 335 server/src/main/java/org/apache/druid/client/BrokerViewOfCoordinatorConfig.java 118 server/src/main/java/org/apache/druid/client/CacheUtil.java 114 server/src/main/java/org/apache/druid/client/CachingClusteredClient.java 764 server/src/main/java/org/apache/druid/client/CachingQueryRunner.java 149 server/src/main/java/org/apache/druid/client/CoordinatorSegmentWatcherConfig.java 11 server/src/main/java/org/apache/druid/client/CoordinatorServerView.java 254 server/src/main/java/org/apache/druid/client/DataSegmentInterner.java 16 server/src/main/java/org/apache/druid/client/DataSourcesSnapshot.java 130 server/src/main/java/org/apache/druid/client/DirectDruidClient.java 498 server/src/main/java/org/apache/druid/client/DirectDruidClientFactory.java 58 server/src/main/java/org/apache/druid/client/DruidDataSource.java 85 server/src/main/java/org/apache/druid/client/DruidServer.java 249 server/src/main/java/org/apache/druid/client/DruidServerConfig.java 54 server/src/main/java/org/apache/druid/client/FilteredBatchServerInventoryViewProvider.java 30 server/src/main/java/org/apache/druid/client/FilteredHttpServerInventoryViewProvider.java 48 server/src/main/java/org/apache/druid/client/FilteredServerInventoryView.java 15 server/src/main/java/org/apache/druid/client/FilteredServerInventoryViewProvider.java 13 server/src/main/java/org/apache/druid/client/FilteringSegmentCallback.java 50 server/src/main/java/org/apache/druid/client/HttpServerInventoryView.java 565 server/src/main/java/org/apache/druid/client/HttpServerInventoryViewConfig.java 44 server/src/main/java/org/apache/druid/client/HttpServerInventoryViewProvider.java 48 server/src/main/java/org/apache/druid/client/HttpServerInventoryViewResource.java 33 server/src/main/java/org/apache/druid/client/ImmutableDruidDataSource.java 106 server/src/main/java/org/apache/druid/client/ImmutableDruidServer.java 132 server/src/main/java/org/apache/druid/client/ImmutableSegmentLoadInfo.java 64 server/src/main/java/org/apache/druid/client/InputStreamHolder.java 37 server/src/main/java/org/apache/druid/client/InternalQueryConfig.java 13 server/src/main/java/org/apache/druid/client/InventoryView.java 12 server/src/main/java/org/apache/druid/client/JsonParserIterator.java 233 server/src/main/java/org/apache/druid/client/QueryableDruidServer.java 32 server/src/main/java/org/apache/druid/client/SegmentLoadInfo.java 111 server/src/main/java/org/apache/druid/client/SegmentServerSelector.java 29 server/src/main/java/org/apache/druid/client/ServerInventoryView.java 4 server/src/main/java/org/apache/druid/client/ServerInventoryViewProvider.java 13 server/src/main/java/org/apache/druid/client/ServerView.java 49 server/src/main/java/org/apache/druid/client/ServerViewUtil.java 56 server/src/main/java/org/apache/druid/client/TimelineServerView.java 36 server/src/main/java/org/apache/druid/client/broker/Broker.java 12 server/src/main/java/org/apache/druid/client/broker/BrokerClient.java 14 server/src/main/java/org/apache/druid/client/broker/BrokerClientImpl.java 89 server/src/main/java/org/apache/druid/client/coordinator/Coordinator.java 12 server/src/main/java/org/apache/druid/client/coordinator/CoordinatorClient.java 27 server/src/main/java/org/apache/druid/client/coordinator/CoordinatorClientImpl.java 200 server/src/main/java/org/apache/druid/client/coordinator/CoordinatorSelectorConfig.java 12 server/src/main/java/org/apache/druid/client/indexing/ClientCompactionIOConfig.java 62 server/src/main/java/org/apache/druid/client/indexing/ClientCompactionIntervalSpec.java 93 server/src/main/java/org/apache/druid/client/indexing/ClientCompactionRunnerInfo.java 177 server/src/main/java/org/apache/druid/client/indexing/ClientCompactionTaskDimensionsSpec.java 54 server/src/main/java/org/apache/druid/client/indexing/ClientCompactionTaskGranularitySpec.java 74 server/src/main/java/org/apache/druid/client/indexing/ClientCompactionTaskQuery.java 180 server/src/main/java/org/apache/druid/client/indexing/ClientCompactionTaskQueryTuningConfig.java 387 server/src/main/java/org/apache/druid/client/indexing/ClientKillUnusedSegmentsTaskQuery.java 117 server/src/main/java/org/apache/druid/client/indexing/ClientMSQContext.java 7 server/src/main/java/org/apache/druid/client/indexing/ClientTaskQuery.java 16 server/src/main/java/org/apache/druid/client/indexing/IndexingService.java 12 server/src/main/java/org/apache/druid/client/indexing/IndexingTotalWorkerCapacityInfo.java 54 server/src/main/java/org/apache/druid/client/indexing/IndexingWorker.java 83 server/src/main/java/org/apache/druid/client/indexing/IndexingWorkerInfo.java 105 server/src/main/java/org/apache/druid/client/indexing/QueryStatus.java 58 server/src/main/java/org/apache/druid/client/indexing/SamplerResponse.java 182 server/src/main/java/org/apache/druid/client/indexing/SamplerSpec.java 28 server/src/main/java/org/apache/druid/client/indexing/TaskPayloadResponse.java 35 server/src/main/java/org/apache/druid/client/indexing/TaskStatusResponse.java 58 server/src/main/java/org/apache/druid/client/selector/AbstractTierSelectorStrategy.java 45 server/src/main/java/org/apache/druid/client/selector/ConnectionCountServerSelectorStrategy.java 34 server/src/main/java/org/apache/druid/client/selector/CustomTierSelectorStrategy.java 40 server/src/main/java/org/apache/druid/client/selector/CustomTierSelectorStrategyConfig.java 13 server/src/main/java/org/apache/druid/client/selector/DiscoverySelector.java 7 server/src/main/java/org/apache/druid/client/selector/HighestPriorityTierSelectorStrategy.java 17 server/src/main/java/org/apache/druid/client/selector/HistoricalFilter.java 13 server/src/main/java/org/apache/druid/client/selector/LowestPriorityTierSelectorStrategy.java 17 server/src/main/java/org/apache/druid/client/selector/RandomServerSelectorStrategy.java 30 server/src/main/java/org/apache/druid/client/selector/Server.java 8 server/src/main/java/org/apache/druid/client/selector/ServerSelector.java 182 server/src/main/java/org/apache/druid/client/selector/ServerSelectorStrategy.java 39 server/src/main/java/org/apache/druid/client/selector/TierSelectorStrategy.java 50 server/src/main/java/org/apache/druid/curator/CuratorConfig.java 96 server/src/main/java/org/apache/druid/curator/CuratorModule.java 170 server/src/main/java/org/apache/druid/curator/CuratorUtils.java 80 server/src/main/java/org/apache/druid/curator/DruidConnectionStateListener.java 61 server/src/main/java/org/apache/druid/curator/PotentiallyGzippedCompressionProvider.java 28 server/src/main/java/org/apache/druid/curator/ZkEnablementConfig.java 26 server/src/main/java/org/apache/druid/curator/announcement/Announcer.java 335 server/src/main/java/org/apache/druid/curator/discovery/CuratorDruidLeaderSelector.java 172 server/src/main/java/org/apache/druid/curator/discovery/CuratorDruidNodeAnnouncer.java 62 server/src/main/java/org/apache/druid/curator/discovery/CuratorDruidNodeDiscoveryProvider.java 294 server/src/main/java/org/apache/druid/curator/discovery/CuratorServiceAnnouncer.java 85 server/src/main/java/org/apache/druid/curator/discovery/CuratorServiceUtils.java 9 server/src/main/java/org/apache/druid/curator/discovery/DiscoveryModule.java 421 server/src/main/java/org/apache/druid/curator/discovery/NoopServiceAnnouncer.java 14 server/src/main/java/org/apache/druid/curator/discovery/ServerDiscoveryFactory.java 54 server/src/main/java/org/apache/druid/curator/discovery/ServerDiscoverySelector.java 109 server/src/main/java/org/apache/druid/curator/discovery/ServiceAnnouncer.java 19 server/src/main/java/org/apache/druid/curator/inventory/CuratorInventoryManager.java 343 server/src/main/java/org/apache/druid/curator/inventory/CuratorInventoryManagerStrategy.java 13 server/src/main/java/org/apache/druid/curator/inventory/InventoryManagerConfig.java 6 server/src/main/java/org/apache/druid/discovery/BaseNodeRoleWatcher.java 284 server/src/main/java/org/apache/druid/discovery/ClientUtils.java 36 server/src/main/java/org/apache/druid/discovery/DataNodeService.java 114 server/src/main/java/org/apache/druid/discovery/DataServerClient.java 141 server/src/main/java/org/apache/druid/discovery/DataServerResponseHandler.java 227 server/src/main/java/org/apache/druid/discovery/DiscoveryDruidNode.java 179 server/src/main/java/org/apache/druid/discovery/DruidLeaderClient.java 223 server/src/main/java/org/apache/druid/discovery/DruidLeaderSelector.java 16 server/src/main/java/org/apache/druid/discovery/DruidNodeAnnouncer.java 6 server/src/main/java/org/apache/druid/discovery/DruidNodeDiscovery.java 21 server/src/main/java/org/apache/druid/discovery/DruidNodeDiscoveryProvider.java 195 server/src/main/java/org/apache/druid/discovery/DruidService.java 19 server/src/main/java/org/apache/druid/discovery/LookupNodeService.java 48 server/src/main/java/org/apache/druid/discovery/NodeRole.java 92 server/src/main/java/org/apache/druid/discovery/WorkerNodeService.java 78 server/src/main/java/org/apache/druid/guice/AnnouncerModule.java 44 server/src/main/java/org/apache/druid/guice/BrokerProcessingModule.java 143 server/src/main/java/org/apache/druid/guice/CacheModule.java 44 server/src/main/java/org/apache/druid/guice/CatalogCoreModule.java 13 server/src/main/java/org/apache/druid/guice/ConglomerateBackedToolChestWarehouse.java 20 server/src/main/java/org/apache/druid/guice/CoordinatorDiscoveryModule.java 34 server/src/main/java/org/apache/druid/guice/DruidBinders.java 165 server/src/main/java/org/apache/druid/guice/DruidInjectorBuilder.java 165 server/src/main/java/org/apache/druid/guice/DruidProcessingModule.java 178 server/src/main/java/org/apache/druid/guice/JavaScriptModule.java 12 server/src/main/java/org/apache/druid/guice/JoinableFactoryModule.java 45 server/src/main/java/org/apache/druid/guice/LocalDataStorageDruidModule.java 81 server/src/main/java/org/apache/druid/guice/MetadataConfigModule.java 18 server/src/main/java/org/apache/druid/guice/QueryRunnerFactoryModule.java 73 server/src/main/java/org/apache/druid/guice/QueryToolChestModule.java 130 server/src/main/java/org/apache/druid/guice/QueryableModule.java 51 server/src/main/java/org/apache/druid/guice/RouterProcessingModule.java 65 server/src/main/java/org/apache/druid/guice/SQLMetadataStorageDruidModule.java 98 server/src/main/java/org/apache/druid/guice/SegmentWranglerModule.java 39 server/src/main/java/org/apache/druid/guice/ServerModule.java 41 server/src/main/java/org/apache/druid/guice/ServerTypeConfig.java 16 server/src/main/java/org/apache/druid/guice/ServerViewModule.java 35 server/src/main/java/org/apache/druid/guice/StartupLoggingModule.java 19 server/src/main/java/org/apache/druid/guice/StorageNodeModule.java 105 server/src/main/java/org/apache/druid/guice/annotations/AttemptId.java 12 server/src/main/java/org/apache/druid/guice/annotations/Client.java 12 server/src/main/java/org/apache/druid/guice/annotations/EscalatedClient.java 12 server/src/main/java/org/apache/druid/guice/annotations/ExcludeScope.java 11 server/src/main/java/org/apache/druid/guice/annotations/LoadScope.java 11 server/src/main/java/org/apache/druid/guice/annotations/RemoteChatHandler.java 12 server/src/main/java/org/apache/druid/guice/http/AbstractHttpClientProvider.java 41 server/src/main/java/org/apache/druid/guice/http/DruidHttpClientConfig.java 99 server/src/main/java/org/apache/druid/guice/http/HttpClientModule.java 98 server/src/main/java/org/apache/druid/guice/http/JettyHttpClientModule.java 92 server/src/main/java/org/apache/druid/guice/security/AuthenticatorModule.java 32 server/src/main/java/org/apache/druid/guice/security/AuthorizerModule.java 30 server/src/main/java/org/apache/druid/guice/security/DruidAuthModule.java 13 server/src/main/java/org/apache/druid/guice/security/EscalatorModule.java 13 server/src/main/java/org/apache/druid/guice/security/PolicyModule.java 14 server/src/main/java/org/apache/druid/indexing/overlord/DataSourceMetadata.java 17 server/src/main/java/org/apache/druid/indexing/overlord/IndexerMetadataStorageCoordinator.java 152 server/src/main/java/org/apache/druid/indexing/overlord/ObjectMetadata.java 67 server/src/main/java/org/apache/druid/indexing/overlord/SegmentCreateRequest.java 44 server/src/main/java/org/apache/druid/indexing/overlord/SegmentPublishResult.java 124 server/src/main/java/org/apache/druid/indexing/overlord/Segments.java 6 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/NoopSupervisorSpec.java 147 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/StreamSupervisor.java 16 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/Supervisor.java 43 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/SupervisorReport.java 63 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/SupervisorSpec.java 48 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/SupervisorStateManager.java 217 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/SupervisorStateManagerConfig.java 60 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/SupervisorStatus.java 185 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/VersionedSupervisorSpec.java 52 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/autoscaler/AggregateFunction.java 7 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/autoscaler/LagStats.java 47 server/src/main/java/org/apache/druid/indexing/overlord/supervisor/autoscaler/SupervisorTaskAutoScaler.java 7 server/src/main/java/org/apache/druid/indexing/worker/config/WorkerConfig.java 188 server/src/main/java/org/apache/druid/initialization/CoreInjectorBuilder.java 110 server/src/main/java/org/apache/druid/initialization/ExtensionInjectorBuilder.java 24 server/src/main/java/org/apache/druid/initialization/Initialization.java 15 server/src/main/java/org/apache/druid/initialization/Log4jShutterDownerModule.java 87 server/src/main/java/org/apache/druid/initialization/ServerInjectorBuilder.java 74 server/src/main/java/org/apache/druid/initialization/ServiceInjectorBuilder.java 26 server/src/main/java/org/apache/druid/jackson/DruidServiceSerializer.java 45 server/src/main/java/org/apache/druid/jackson/DruidServiceSerializerModifier.java 21 server/src/main/java/org/apache/druid/jackson/StringObjectPairList.java 41 server/src/main/java/org/apache/druid/jackson/ToStringObjectPairListDeserializer.java 38 server/src/main/java/org/apache/druid/messages/MessageBatch.java 69 server/src/main/java/org/apache/druid/messages/client/MessageListener.java 8 server/src/main/java/org/apache/druid/messages/client/MessageRelay.java 175 server/src/main/java/org/apache/druid/messages/client/MessageRelayClient.java 8 server/src/main/java/org/apache/druid/messages/client/MessageRelayClientImpl.java 59 server/src/main/java/org/apache/druid/messages/client/MessageRelayFactory.java 6 server/src/main/java/org/apache/druid/messages/client/MessageRelays.java 104 server/src/main/java/org/apache/druid/messages/package-info.java 1 server/src/main/java/org/apache/druid/messages/server/MessageRelayMonitor.java 46 server/src/main/java/org/apache/druid/messages/server/MessageRelayResource.java 134 server/src/main/java/org/apache/druid/messages/server/Outbox.java 10 server/src/main/java/org/apache/druid/messages/server/OutboxImpl.java 142 server/src/main/java/org/apache/druid/metadata/BasicDataSourceExt.java 128 server/src/main/java/org/apache/druid/metadata/DerbyMetadataStorageActionHandler.java 25 server/src/main/java/org/apache/druid/metadata/DerbyMetadataStorageActionHandlerFactory.java 31 server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java 2153 server/src/main/java/org/apache/druid/metadata/LockFilterPolicy.java 49 server/src/main/java/org/apache/druid/metadata/MetadataRuleManager.java 16 server/src/main/java/org/apache/druid/metadata/MetadataRuleManagerConfig.java 24 server/src/main/java/org/apache/druid/metadata/MetadataRuleManagerProvider.java 7 server/src/main/java/org/apache/druid/metadata/MetadataStorage.java 10 server/src/main/java/org/apache/druid/metadata/MetadataStorageProvider.java 5 server/src/main/java/org/apache/druid/metadata/MetadataSupervisorManager.java 16 server/src/main/java/org/apache/druid/metadata/MySQLMetadataStorageActionHandler.java 23 server/src/main/java/org/apache/druid/metadata/MySQLMetadataStorageActionHandlerFactory.java 32 server/src/main/java/org/apache/druid/metadata/NoopMetadataStorageProvider.java 9 server/src/main/java/org/apache/druid/metadata/PendingSegmentRecord.java 143 server/src/main/java/org/apache/druid/metadata/PostgreSQLMetadataStorageActionHandler.java 23 server/src/main/java/org/apache/druid/metadata/PostgreSQLMetadataStorageActionHandlerFactory.java 32 server/src/main/java/org/apache/druid/metadata/ReplaceTaskLock.java 46 server/src/main/java/org/apache/druid/metadata/RetryTransactionException.java 8 server/src/main/java/org/apache/druid/metadata/SQLInputSourceDatabaseConnector.java 80 server/src/main/java/org/apache/druid/metadata/SQLMetadataConnector.java 976 server/src/main/java/org/apache/druid/metadata/SQLMetadataRuleManager.java 357 server/src/main/java/org/apache/druid/metadata/SQLMetadataRuleManagerProvider.java 64 server/src/main/java/org/apache/druid/metadata/SQLMetadataStorageActionHandler.java 898 server/src/main/java/org/apache/druid/metadata/SQLMetadataStorageActionHandlerFactory.java 20 server/src/main/java/org/apache/druid/metadata/SQLMetadataSupervisorManager.java 249 server/src/main/java/org/apache/druid/metadata/SQLServerMetadataStorageActionHandler.java 23 server/src/main/java/org/apache/druid/metadata/SQLServerMetadataStorageActionHandlerFactory.java 32 server/src/main/java/org/apache/druid/metadata/SegmentsMetadataManager.java 14 server/src/main/java/org/apache/druid/metadata/SegmentsMetadataManagerConfig.java 31 server/src/main/java/org/apache/druid/metadata/SegmentsMetadataManagerProvider.java 7 server/src/main/java/org/apache/druid/metadata/SortOrder.java 36 server/src/main/java/org/apache/druid/metadata/SqlSegmentsMetadataManager.java 580 server/src/main/java/org/apache/druid/metadata/SqlSegmentsMetadataManagerProvider.java 75 server/src/main/java/org/apache/druid/metadata/SqlSegmentsMetadataQuery.java 1277 server/src/main/java/org/apache/druid/metadata/input/InputSourceModule.java 28 server/src/main/java/org/apache/druid/metadata/input/SqlEntity.java 161 server/src/main/java/org/apache/druid/metadata/input/SqlInputFormat.java 29 server/src/main/java/org/apache/druid/metadata/input/SqlInputSource.java 132 server/src/main/java/org/apache/druid/metadata/input/SqlReader.java 66 server/src/main/java/org/apache/druid/metadata/segment/CachedSegmentMetadataTransaction.java 342 server/src/main/java/org/apache/druid/metadata/segment/DatasourceSegmentMetadataReader.java 58 server/src/main/java/org/apache/druid/metadata/segment/DatasourceSegmentMetadataWriter.java 37 server/src/main/java/org/apache/druid/metadata/segment/SegmentMetadataReadTransaction.java 15 server/src/main/java/org/apache/druid/metadata/segment/SegmentMetadataTransaction.java 14 server/src/main/java/org/apache/druid/metadata/segment/SegmentMetadataTransactionFactory.java 12 server/src/main/java/org/apache/druid/metadata/segment/SqlSegmentMetadataTransaction.java 491 server/src/main/java/org/apache/druid/metadata/segment/SqlSegmentMetadataTransactionFactory.java 164 server/src/main/java/org/apache/druid/metadata/segment/SqlSegmentsMetadataManagerV2.java 124 server/src/main/java/org/apache/druid/metadata/storage/derby/DerbyConnector.java 187 server/src/main/java/org/apache/druid/metadata/storage/derby/DerbyMetadataStorage.java 57 server/src/main/java/org/apache/druid/metadata/storage/derby/DerbyMetadataStorageDruidModule.java 44 server/src/main/java/org/apache/druid/metadata/storage/derby/DerbyMetadataStorageProvider.java 19 server/src/main/java/org/apache/druid/offheap/OffheapBufferGenerator.java 28 server/src/main/java/org/apache/druid/query/BrokerParallelMergeConfig.java 108 server/src/main/java/org/apache/druid/query/LocatedSegmentDescriptor.java 94 server/src/main/java/org/apache/druid/query/ResultLevelCachingQueryRunner.java 274 server/src/main/java/org/apache/druid/query/RetryQueryRunner.java 175 server/src/main/java/org/apache/druid/query/RetryQueryRunnerConfig.java 15 server/src/main/java/org/apache/druid/query/lookup/LookupIntrospectionResource.java 46 server/src/main/java/org/apache/druid/query/lookup/LookupListeningAnnouncerConfig.java 41 server/src/main/java/org/apache/druid/query/lookup/LookupListeningResource.java 109 server/src/main/java/org/apache/druid/query/lookup/LookupModule.java 59 server/src/main/java/org/apache/druid/query/lookup/LookupReferencesManager.java 654 server/src/main/java/org/apache/druid/query/lookup/LookupSerdeModule.java 54 server/src/main/java/org/apache/druid/query/lookup/LookupUtils.java 55 server/src/main/java/org/apache/druid/query/lookup/MapLookupExtractorFactory.java 119 server/src/main/java/org/apache/druid/rpc/DiscoveryServiceLocator.java 123 server/src/main/java/org/apache/druid/rpc/FixedServiceLocator.java 31 server/src/main/java/org/apache/druid/rpc/HttpResponseException.java 32 server/src/main/java/org/apache/druid/rpc/IgnoreHttpResponseHandler.java 31 server/src/main/java/org/apache/druid/rpc/RequestBuilder.java 121 server/src/main/java/org/apache/druid/rpc/RpcException.java 14 server/src/main/java/org/apache/druid/rpc/ServiceClient.java 23 server/src/main/java/org/apache/druid/rpc/ServiceClientFactory.java 5 server/src/main/java/org/apache/druid/rpc/ServiceClientFactoryImpl.java 25 server/src/main/java/org/apache/druid/rpc/ServiceClientImpl.java 410 server/src/main/java/org/apache/druid/rpc/ServiceClosedException.java 8 server/src/main/java/org/apache/druid/rpc/ServiceLocation.java 182 server/src/main/java/org/apache/druid/rpc/ServiceLocations.java 64 server/src/main/java/org/apache/druid/rpc/ServiceLocator.java 9 server/src/main/java/org/apache/druid/rpc/ServiceNotAvailableException.java 13 server/src/main/java/org/apache/druid/rpc/ServiceRetryPolicy.java 13 server/src/main/java/org/apache/druid/rpc/StandardRetryPolicy.java 139 server/src/main/java/org/apache/druid/rpc/guice/ServiceClientModule.java 122 server/src/main/java/org/apache/druid/rpc/indexing/NoopOverlordClient.java 138 server/src/main/java/org/apache/druid/rpc/indexing/OverlordClient.java 83 server/src/main/java/org/apache/druid/rpc/indexing/OverlordClientImpl.java 384 server/src/main/java/org/apache/druid/rpc/indexing/SegmentUpdateResponse.java 49 server/src/main/java/org/apache/druid/rpc/indexing/SpecificTaskRetryPolicy.java 63 server/src/main/java/org/apache/druid/rpc/indexing/SpecificTaskServiceLocator.java 199 server/src/main/java/org/apache/druid/rpc/indexing/TaskServiceClients.java 21 server/src/main/java/org/apache/druid/segment/FrameBasedInlineSegmentWrangler.java 28 server/src/main/java/org/apache/druid/segment/InlineSegmentWrangler.java 33 server/src/main/java/org/apache/druid/segment/LookupSegmentWrangler.java 36 server/src/main/java/org/apache/druid/segment/MapSegmentWrangler.java 25 server/src/main/java/org/apache/druid/segment/handoff/CoordinatorBasedSegmentHandoffNotifier.java 108 server/src/main/java/org/apache/druid/segment/handoff/CoordinatorBasedSegmentHandoffNotifierConfig.java 13 server/src/main/java/org/apache/druid/segment/handoff/CoordinatorBasedSegmentHandoffNotifierFactory.java 27 server/src/main/java/org/apache/druid/segment/handoff/NoopSegmentHandoffNotifierFactory.java 31 server/src/main/java/org/apache/druid/segment/handoff/SegmentHandoffNotifier.java 15 server/src/main/java/org/apache/druid/segment/handoff/SegmentHandoffNotifierFactory.java 5 server/src/main/java/org/apache/druid/segment/indexing/BatchIOConfig.java 15 server/src/main/java/org/apache/druid/segment/indexing/CombinedDataSchema.java 43 server/src/main/java/org/apache/druid/segment/indexing/DataSchema.java 436 server/src/main/java/org/apache/druid/segment/indexing/IOConfig.java 6 server/src/main/java/org/apache/druid/segment/indexing/IngestionSpec.java 35 server/src/main/java/org/apache/druid/segment/indexing/ReaderUtils.java 105 server/src/main/java/org/apache/druid/segment/indexing/TuningConfig.java 35 server/src/main/java/org/apache/druid/segment/join/BroadcastTableJoinableFactory.java 65 server/src/main/java/org/apache/druid/segment/join/LookupJoinableFactory.java 33 server/src/main/java/org/apache/druid/segment/loading/LeastBytesUsedStorageLocationSelectorStrategy.java 30 server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentKiller.java 57 server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPuller.java 190 server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusher.java 137 server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java 18 server/src/main/java/org/apache/druid/segment/loading/LocalFileTimestampVersionFinder.java 60 server/src/main/java/org/apache/druid/segment/loading/LocalLoadSpec.java 38 server/src/main/java/org/apache/druid/segment/loading/MostAvailableSizeStorageLocationSelectorStrategy.java 31 server/src/main/java/org/apache/druid/segment/loading/OmniDataSegmentArchiver.java 50 server/src/main/java/org/apache/druid/segment/loading/OmniDataSegmentKiller.java 75 server/src/main/java/org/apache/druid/segment/loading/OmniDataSegmentMover.java 45 server/src/main/java/org/apache/druid/segment/loading/RandomStorageLocationSelectorStrategy.java 23 server/src/main/java/org/apache/druid/segment/loading/RoundRobinStorageLocationSelectorStrategy.java 45 server/src/main/java/org/apache/druid/segment/loading/SegmentCacheManager.java 26 server/src/main/java/org/apache/druid/segment/loading/SegmentLoaderConfig.java 115 server/src/main/java/org/apache/druid/segment/loading/SegmentLocalCacheManager.java 555 server/src/main/java/org/apache/druid/segment/loading/StorageLocation.java 158 server/src/main/java/org/apache/druid/segment/loading/StorageLocationConfig.java 64 server/src/main/java/org/apache/druid/segment/loading/StorageLocationSelectorStrategy.java 17 server/src/main/java/org/apache/druid/segment/metadata/AbstractSegmentMetadataCache.java 768 server/src/main/java/org/apache/druid/segment/metadata/AvailableSegmentMetadata.java 115 server/src/main/java/org/apache/druid/segment/metadata/CentralizedDatasourceSchemaConfig.java 61 server/src/main/java/org/apache/druid/segment/metadata/CoordinatorSegmentMetadataCache.java 681 server/src/main/java/org/apache/druid/segment/metadata/DataSourceInformation.java 57 server/src/main/java/org/apache/druid/segment/metadata/FingerprintGenerator.java 69 server/src/main/java/org/apache/druid/segment/metadata/SegmentMetadataCacheConfig.java 62 server/src/main/java/org/apache/druid/segment/metadata/SegmentMetadataQuerySegmentWalker.java 210 server/src/main/java/org/apache/druid/segment/metadata/SegmentSchemaBackFillQueue.java 157 server/src/main/java/org/apache/druid/segment/metadata/SegmentSchemaCache.java 206 server/src/main/java/org/apache/druid/segment/metadata/SegmentSchemaManager.java 341 server/src/main/java/org/apache/druid/segment/realtime/ChatHandler.java 4 server/src/main/java/org/apache/druid/segment/realtime/ChatHandlerProvider.java 9 server/src/main/java/org/apache/druid/segment/realtime/ChatHandlerResource.java 48 server/src/main/java/org/apache/druid/segment/realtime/ChatHandlers.java 30 server/src/main/java/org/apache/druid/segment/realtime/FireHydrant.java 177 server/src/main/java/org/apache/druid/segment/realtime/NoopChatHandlerProvider.java 22 server/src/main/java/org/apache/druid/segment/realtime/SegmentGenerationMetrics.java 182 server/src/main/java/org/apache/druid/segment/realtime/ServiceAnnouncingChatHandlerProvider.java 92 server/src/main/java/org/apache/druid/segment/realtime/WindowedCursorFactory.java 29 server/src/main/java/org/apache/druid/segment/realtime/appenderator/Appenderator.java 76 server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorConfig.java 37 server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorDriverAddResult.java 70 server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorDriverMetadata.java 96 server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorDriverSegmentLockHelper.java 6 server/src/main/java/org/apache/druid/segment/realtime/appenderator/Appenderators.java 106 server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorsManager.java 74 server/src/main/java/org/apache/druid/segment/realtime/appenderator/BaseAppenderatorDriver.java 596 server/src/main/java/org/apache/druid/segment/realtime/appenderator/BatchAppenderator.java 1027 server/src/main/java/org/apache/druid/segment/realtime/appenderator/BatchAppenderatorDriver.java 149 server/src/main/java/org/apache/druid/segment/realtime/appenderator/Committed.java 91 server/src/main/java/org/apache/druid/segment/realtime/appenderator/DummyForInjectionAppenderatorsManager.java 105 server/src/main/java/org/apache/druid/segment/realtime/appenderator/PeonAppenderatorsManager.java 156 server/src/main/java/org/apache/druid/segment/realtime/appenderator/PublishedSegmentRetriever.java 9 server/src/main/java/org/apache/druid/segment/realtime/appenderator/SegmentAllocator.java 14 server/src/main/java/org/apache/druid/segment/realtime/appenderator/SegmentIdWithShardSpec.java 86 server/src/main/java/org/apache/druid/segment/realtime/appenderator/SegmentNotWritableException.java 9 server/src/main/java/org/apache/druid/segment/realtime/appenderator/SegmentPublisherHelper.java 93 server/src/main/java/org/apache/druid/segment/realtime/appenderator/SegmentSchemas.java 130 server/src/main/java/org/apache/druid/segment/realtime/appenderator/SegmentWithState.java 98 server/src/main/java/org/apache/druid/segment/realtime/appenderator/SegmentsAndCommitMetadata.java 101 server/src/main/java/org/apache/druid/segment/realtime/appenderator/SinkQuerySegmentWalker.java 509 server/src/main/java/org/apache/druid/segment/realtime/appenderator/SinkSchemaUtil.java 113 server/src/main/java/org/apache/druid/segment/realtime/appenderator/StreamAppenderator.java 1417 server/src/main/java/org/apache/druid/segment/realtime/appenderator/StreamAppenderatorDriver.java 333 server/src/main/java/org/apache/druid/segment/realtime/appenderator/TaskSegmentSchemaUtil.java 29 server/src/main/java/org/apache/druid/segment/realtime/appenderator/TransactionalSegmentPublisher.java 73 server/src/main/java/org/apache/druid/segment/realtime/appenderator/UnifiedIndexerAppenderatorsManager.java 493 server/src/main/java/org/apache/druid/segment/realtime/package-info.java 3 server/src/main/java/org/apache/druid/segment/realtime/sink/Committers.java 30 server/src/main/java/org/apache/druid/segment/realtime/sink/Sink.java 427 server/src/main/java/org/apache/druid/segment/realtime/sink/SinkSegmentReference.java 36 server/src/main/java/org/apache/druid/server/AsyncManagementForwardingServlet.java 176 server/src/main/java/org/apache/druid/server/BrokerDynamicConfigResource.java 40 server/src/main/java/org/apache/druid/server/BrokerQueryResource.java 97 server/src/main/java/org/apache/druid/server/ClientInfoResource.java 278 server/src/main/java/org/apache/druid/server/ClientQuerySegmentWalker.java 759 server/src/main/java/org/apache/druid/server/ClientQuerySegmentWalkerUtils.java 33 server/src/main/java/org/apache/druid/server/DruidNode.java 258 server/src/main/java/org/apache/druid/server/GuiceServletConfig.java 18 server/src/main/java/org/apache/druid/server/JettyUtils.java 45 server/src/main/java/org/apache/druid/server/LocalQuerySegmentWalker.java 82 server/src/main/java/org/apache/druid/server/NoopQuerySegmentWalker.java 19 server/src/main/java/org/apache/druid/server/QueryLaningStrategy.java 27 server/src/main/java/org/apache/druid/server/QueryLifecycle.java 366 server/src/main/java/org/apache/druid/server/QueryLifecycleFactory.java 65 server/src/main/java/org/apache/druid/server/QueryPrioritizationStrategy.java 18 server/src/main/java/org/apache/druid/server/QueryResource.java 502 server/src/main/java/org/apache/druid/server/QueryResponse.java 25 server/src/main/java/org/apache/druid/server/QueryResultPusher.java 356 server/src/main/java/org/apache/druid/server/QueryScheduler.java 227 server/src/main/java/org/apache/druid/server/QuerySchedulerConfig.java 25 server/src/main/java/org/apache/druid/server/QuerySchedulerProvider.java 24 server/src/main/java/org/apache/druid/server/QueryStats.java 39 server/src/main/java/org/apache/druid/server/QuerySwappingQueryRunner.java 28 server/src/main/java/org/apache/druid/server/RequestLogLine.java 148 server/src/main/java/org/apache/druid/server/ResourceIdPopulatingQueryRunner.java 37 server/src/main/java/org/apache/druid/server/ResponseContextConfig.java 32 server/src/main/java/org/apache/druid/server/SegmentManager.java 315 server/src/main/java/org/apache/druid/server/SetAndVerifyContextQueryRunner.java 55 server/src/main/java/org/apache/druid/server/StatusResource.java 230 server/src/main/java/org/apache/druid/server/SubqueryGuardrailHelper.java 98 server/src/main/java/org/apache/druid/server/SubqueryGuardrailHelperProvider.java 43 server/src/main/java/org/apache/druid/server/ZkPathsModule.java 10 server/src/main/java/org/apache/druid/server/audit/AuditLogger.java 43 server/src/main/java/org/apache/druid/server/audit/AuditManagerConfig.java 15 server/src/main/java/org/apache/druid/server/audit/AuditSerdeHelper.java 88 server/src/main/java/org/apache/druid/server/audit/LoggingAuditManager.java 59 server/src/main/java/org/apache/druid/server/audit/LoggingAuditManagerConfig.java 53 server/src/main/java/org/apache/druid/server/audit/SQLAuditManager.java 243 server/src/main/java/org/apache/druid/server/audit/SQLAuditManagerConfig.java 61 server/src/main/java/org/apache/druid/server/compaction/BaseCandidateSearchPolicy.java 60 server/src/main/java/org/apache/druid/server/compaction/CompactionCandidate.java 80 server/src/main/java/org/apache/druid/server/compaction/CompactionCandidateSearchPolicy.java 18 server/src/main/java/org/apache/druid/server/compaction/CompactionProgressResponse.java 37 server/src/main/java/org/apache/druid/server/compaction/CompactionRunSimulator.java 189 server/src/main/java/org/apache/druid/server/compaction/CompactionSegmentIterator.java 8 server/src/main/java/org/apache/druid/server/compaction/CompactionSimulateResult.java 20 server/src/main/java/org/apache/druid/server/compaction/CompactionStatistics.java 33 server/src/main/java/org/apache/druid/server/compaction/CompactionStatus.java 412 server/src/main/java/org/apache/druid/server/compaction/CompactionStatusResponse.java 39 server/src/main/java/org/apache/druid/server/compaction/CompactionStatusTracker.java 186 server/src/main/java/org/apache/druid/server/compaction/CompactionTaskStatus.java 31 server/src/main/java/org/apache/druid/server/compaction/DataSourceCompactibleSegmentIterator.java 376 server/src/main/java/org/apache/druid/server/compaction/FixedIntervalOrderPolicy.java 73 server/src/main/java/org/apache/druid/server/compaction/NewestSegmentFirstPolicy.java 22 server/src/main/java/org/apache/druid/server/compaction/PriorityBasedCompactionSegmentIterator.java 93 server/src/main/java/org/apache/druid/server/compaction/Table.java 52 server/src/main/java/org/apache/druid/server/coordination/BatchDataSegmentAnnouncer.java 398 server/src/main/java/org/apache/druid/server/coordination/BatchDataSegmentAnnouncerProvider.java 14 server/src/main/java/org/apache/druid/server/coordination/BroadcastDatasourceLoadingSpec.java 113 server/src/main/java/org/apache/druid/server/coordination/ChangeRequestHistory.java 249 server/src/main/java/org/apache/druid/server/coordination/ChangeRequestHttpSyncer.java 349 server/src/main/java/org/apache/druid/server/coordination/ChangeRequestsSnapshot.java 73 server/src/main/java/org/apache/druid/server/coordination/CuratorDataSegmentServerAnnouncer.java 67 server/src/main/java/org/apache/druid/server/coordination/DataSegmentAnnouncer.java 18 server/src/main/java/org/apache/druid/server/coordination/DataSegmentAnnouncerProvider.java 11 server/src/main/java/org/apache/druid/server/coordination/DataSegmentChangeCallback.java 6 server/src/main/java/org/apache/druid/server/coordination/DataSegmentChangeHandler.java 8 server/src/main/java/org/apache/druid/server/coordination/DataSegmentChangeRequest.java 16 server/src/main/java/org/apache/druid/server/coordination/DataSegmentChangeResponse.java 35 server/src/main/java/org/apache/druid/server/coordination/DataSegmentServerAnnouncer.java 18 server/src/main/java/org/apache/druid/server/coordination/DruidServerMetadata.java 138 server/src/main/java/org/apache/druid/server/coordination/LoadableDataSegment.java 49 server/src/main/java/org/apache/druid/server/coordination/NoopDataSegmentAnnouncer.java 30 server/src/main/java/org/apache/druid/server/coordination/SegmentBootstrapper.java 366 server/src/main/java/org/apache/druid/server/coordination/SegmentChangeRequestDrop.java 59 server/src/main/java/org/apache/druid/server/coordination/SegmentChangeRequestLoad.java 65 server/src/main/java/org/apache/druid/server/coordination/SegmentChangeRequestNoop.java 17 server/src/main/java/org/apache/druid/server/coordination/SegmentChangeStatus.java 100 server/src/main/java/org/apache/druid/server/coordination/SegmentLoadDropHandler.java 347 server/src/main/java/org/apache/druid/server/coordination/SegmentSchemasChangeRequest.java 30 server/src/main/java/org/apache/druid/server/coordination/ServerManager.java 292 server/src/main/java/org/apache/druid/server/coordination/ServerType.java 95 server/src/main/java/org/apache/druid/server/coordination/ZkCoordinator.java 71 server/src/main/java/org/apache/druid/server/coordination/package-info.java 3 server/src/main/java/org/apache/druid/server/coordinator/AutoCompactionSnapshot.java 224 server/src/main/java/org/apache/druid/server/coordinator/BytesAccumulatingResponseHandler.java 25 server/src/main/java/org/apache/druid/server/coordinator/CatalogDataSourceCompactionConfig.java 196 server/src/main/java/org/apache/druid/server/coordinator/CloneStatusManager.java 27 server/src/main/java/org/apache/druid/server/coordinator/ClusterCompactionConfig.java 101 server/src/main/java/org/apache/druid/server/coordinator/CompactionConfigValidationResult.java 30 server/src/main/java/org/apache/druid/server/coordinator/CoordinatorConfigManager.java 261 server/src/main/java/org/apache/druid/server/coordinator/CoordinatorDynamicConfig.java 547 server/src/main/java/org/apache/druid/server/coordinator/CoordinatorOverlordServiceConfig.java 33 server/src/main/java/org/apache/druid/server/coordinator/DataSourceCompactionConfig.java 50 server/src/main/java/org/apache/druid/server/coordinator/DataSourceCompactionConfigAuditEntry.java 71 server/src/main/java/org/apache/druid/server/coordinator/DataSourceCompactionConfigHistory.java 37 server/src/main/java/org/apache/druid/server/coordinator/DatasourceWhitelist.java 25 server/src/main/java/org/apache/druid/server/coordinator/DruidCluster.java 143 server/src/main/java/org/apache/druid/server/coordinator/DruidCompactionConfig.java 149 server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinator.java 707 server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinatorRuntimeParams.java 285 server/src/main/java/org/apache/druid/server/coordinator/InlineSchemaDataSourceCompactionConfig.java 347 server/src/main/java/org/apache/druid/server/coordinator/MetadataManager.java 100 server/src/main/java/org/apache/druid/server/coordinator/SegmentCountsPerInterval.java 55 server/src/main/java/org/apache/druid/server/coordinator/ServerCloneStatus.java 111 server/src/main/java/org/apache/druid/server/coordinator/ServerHolder.java 327 server/src/main/java/org/apache/druid/server/coordinator/UserCompactionTaskDimensionsConfig.java 54 server/src/main/java/org/apache/druid/server/coordinator/UserCompactionTaskGranularityConfig.java 66 server/src/main/java/org/apache/druid/server/coordinator/UserCompactionTaskIOConfig.java 47 server/src/main/java/org/apache/druid/server/coordinator/UserCompactionTaskQueryTuningConfig.java 68 server/src/main/java/org/apache/druid/server/coordinator/balancer/BalancerSegmentHolder.java 21 server/src/main/java/org/apache/druid/server/coordinator/balancer/BalancerStrategy.java 22 server/src/main/java/org/apache/druid/server/coordinator/balancer/BalancerStrategyFactory.java 49 server/src/main/java/org/apache/druid/server/coordinator/balancer/CachingCostBalancerStrategy.java 45 server/src/main/java/org/apache/druid/server/coordinator/balancer/CachingCostBalancerStrategyConfig.java 11 server/src/main/java/org/apache/druid/server/coordinator/balancer/CachingCostBalancerStrategyFactory.java 143 server/src/main/java/org/apache/druid/server/coordinator/balancer/ClusterCostCache.java 58 server/src/main/java/org/apache/druid/server/coordinator/balancer/CostBalancerStrategy.java 249 server/src/main/java/org/apache/druid/server/coordinator/balancer/CostBalancerStrategyFactory.java 9 server/src/main/java/org/apache/druid/server/coordinator/balancer/DisabledCachingCostBalancerStrategyFactory.java 12 server/src/main/java/org/apache/druid/server/coordinator/balancer/DiskNormalizedCostBalancerStrategy.java 29 server/src/main/java/org/apache/druid/server/coordinator/balancer/DiskNormalizedCostBalancerStrategyFactory.java 9 server/src/main/java/org/apache/druid/server/coordinator/balancer/RandomBalancerStrategy.java 46 server/src/main/java/org/apache/druid/server/coordinator/balancer/RandomBalancerStrategyFactory.java 9 server/src/main/java/org/apache/druid/server/coordinator/balancer/ReservoirSegmentSampler.java 114 server/src/main/java/org/apache/druid/server/coordinator/balancer/SegmentToMoveCalculator.java 182 server/src/main/java/org/apache/druid/server/coordinator/balancer/SegmentsCostCache.java 295 server/src/main/java/org/apache/druid/server/coordinator/balancer/ServerCostCache.java 65 server/src/main/java/org/apache/druid/server/coordinator/balancer/TierSegmentBalancer.java 158 server/src/main/java/org/apache/druid/server/coordinator/balancer/package-info.java 3 server/src/main/java/org/apache/druid/server/coordinator/config/CoordinatorKillConfigs.java 112 server/src/main/java/org/apache/druid/server/coordinator/config/CoordinatorPeriodConfig.java 32 server/src/main/java/org/apache/druid/server/coordinator/config/CoordinatorRunConfig.java 29 server/src/main/java/org/apache/druid/server/coordinator/config/DruidCoordinatorConfig.java 115 server/src/main/java/org/apache/druid/server/coordinator/config/HttpLoadQueuePeonConfig.java 51 server/src/main/java/org/apache/druid/server/coordinator/config/KillUnusedSegmentsConfig.java 126 server/src/main/java/org/apache/druid/server/coordinator/config/MetadataCleanupConfig.java 58 server/src/main/java/org/apache/druid/server/coordinator/duty/BalanceSegments.java 72 server/src/main/java/org/apache/druid/server/coordinator/duty/CloneHistoricals.java 126 server/src/main/java/org/apache/druid/server/coordinator/duty/CompactSegments.java 535 server/src/main/java/org/apache/druid/server/coordinator/duty/CoordinatorCustomDuty.java 15 server/src/main/java/org/apache/druid/server/coordinator/duty/CoordinatorCustomDutyGroup.java 40 server/src/main/java/org/apache/druid/server/coordinator/duty/CoordinatorCustomDutyGroups.java 23 server/src/main/java/org/apache/druid/server/coordinator/duty/CoordinatorDuty.java 8 server/src/main/java/org/apache/druid/server/coordinator/duty/CoordinatorDutyGroup.java 137 server/src/main/java/org/apache/druid/server/coordinator/duty/CoordinatorDutyUtils.java 72 server/src/main/java/org/apache/druid/server/coordinator/duty/DutyGroupStatus.java 68 server/src/main/java/org/apache/druid/server/coordinator/duty/KillAuditLog.java 19 server/src/main/java/org/apache/druid/server/coordinator/duty/KillCompactionConfig.java 93 server/src/main/java/org/apache/druid/server/coordinator/duty/KillDatasourceMetadata.java 43 server/src/main/java/org/apache/druid/server/coordinator/duty/KillRules.java 22 server/src/main/java/org/apache/druid/server/coordinator/duty/KillStalePendingSegments.java 83 server/src/main/java/org/apache/druid/server/coordinator/duty/KillSupervisors.java 22 server/src/main/java/org/apache/druid/server/coordinator/duty/KillSupervisorsCustomDuty.java 34 server/src/main/java/org/apache/druid/server/coordinator/duty/KillUnreferencedSegmentSchema.java 32 server/src/main/java/org/apache/druid/server/coordinator/duty/KillUnusedSegments.java 264 server/src/main/java/org/apache/druid/server/coordinator/duty/MarkEternityTombstonesAsUnused.java 100 server/src/main/java/org/apache/druid/server/coordinator/duty/MarkOvershadowedSegmentsAsUnused.java 93 server/src/main/java/org/apache/druid/server/coordinator/duty/MetadataAction.java 18 server/src/main/java/org/apache/druid/server/coordinator/duty/MetadataCleanupDuty.java 61 server/src/main/java/org/apache/druid/server/coordinator/duty/PrepareBalancerAndLoadQueues.java 153 server/src/main/java/org/apache/druid/server/coordinator/duty/RunRules.java 119 server/src/main/java/org/apache/druid/server/coordinator/duty/UnloadUnusedSegments.java 112 server/src/main/java/org/apache/druid/server/coordinator/loading/HttpLoadQueuePeon.java 566 server/src/main/java/org/apache/druid/server/coordinator/loading/LoadPeonCallback.java 6 server/src/main/java/org/apache/druid/server/coordinator/loading/LoadQueuePeon.java 22 server/src/main/java/org/apache/druid/server/coordinator/loading/LoadQueueTaskMaster.java 104 server/src/main/java/org/apache/druid/server/coordinator/loading/LoadingRateTracker.java 101 server/src/main/java/org/apache/druid/server/coordinator/loading/ReplicationThrottler.java 34 server/src/main/java/org/apache/druid/server/coordinator/loading/RoundRobinServerSelector.java 94 server/src/main/java/org/apache/druid/server/coordinator/loading/SegmentAction.java 18 server/src/main/java/org/apache/druid/server/coordinator/loading/SegmentHolder.java 130 server/src/main/java/org/apache/druid/server/coordinator/loading/SegmentLoadQueueManager.java 98 server/src/main/java/org/apache/druid/server/coordinator/loading/SegmentLoadingConfig.java 74 server/src/main/java/org/apache/druid/server/coordinator/loading/SegmentReplicaCount.java 83 server/src/main/java/org/apache/druid/server/coordinator/loading/SegmentReplicaCountMap.java 70 server/src/main/java/org/apache/druid/server/coordinator/loading/SegmentReplicationStatus.java 50 server/src/main/java/org/apache/druid/server/coordinator/loading/SegmentStatusInTier.java 45 server/src/main/java/org/apache/druid/server/coordinator/loading/StrategicSegmentAssigner.java 448 server/src/main/java/org/apache/druid/server/coordinator/rules/BroadcastDistributionRule.java 10 server/src/main/java/org/apache/druid/server/coordinator/rules/DropRule.java 10 server/src/main/java/org/apache/druid/server/coordinator/rules/ForeverBroadcastDistributionRule.java 47 server/src/main/java/org/apache/druid/server/coordinator/rules/ForeverDropRule.java 24 server/src/main/java/org/apache/druid/server/coordinator/rules/ForeverLoadRule.java 35 server/src/main/java/org/apache/druid/server/coordinator/rules/IntervalBroadcastDistributionRule.java 57 server/src/main/java/org/apache/druid/server/coordinator/rules/IntervalDropRule.java 56 server/src/main/java/org/apache/druid/server/coordinator/rules/IntervalLoadRule.java 66 server/src/main/java/org/apache/druid/server/coordinator/rules/LoadRule.java 100 server/src/main/java/org/apache/druid/server/coordinator/rules/PeriodBroadcastDistributionRule.java 68 server/src/main/java/org/apache/druid/server/coordinator/rules/PeriodDropBeforeRule.java 40 server/src/main/java/org/apache/druid/server/coordinator/rules/PeriodDropRule.java 53 server/src/main/java/org/apache/druid/server/coordinator/rules/PeriodLoadRule.java 76 server/src/main/java/org/apache/druid/server/coordinator/rules/Rule.java 26 server/src/main/java/org/apache/druid/server/coordinator/rules/Rules.java 23 server/src/main/java/org/apache/druid/server/coordinator/rules/SegmentActionHandler.java 9 server/src/main/java/org/apache/druid/server/coordinator/stats/CoordinatorRunStats.java 157 server/src/main/java/org/apache/druid/server/coordinator/stats/CoordinatorStat.java 50 server/src/main/java/org/apache/druid/server/coordinator/stats/Dimension.java 24 server/src/main/java/org/apache/druid/server/coordinator/stats/RowKey.java 74 server/src/main/java/org/apache/druid/server/coordinator/stats/Stats.java 155 server/src/main/java/org/apache/druid/server/emitter/ComposingEmitterConfig.java 15 server/src/main/java/org/apache/druid/server/emitter/ComposingEmitterModule.java 44 server/src/main/java/org/apache/druid/server/emitter/EmitterModule.java 134 server/src/main/java/org/apache/druid/server/emitter/ExtraServiceDimensions.java 14 server/src/main/java/org/apache/druid/server/emitter/HttpEmitterModule.java 110 server/src/main/java/org/apache/druid/server/emitter/HttpEmitterSSLClientConfig.java 53 server/src/main/java/org/apache/druid/server/emitter/HttpEmittingMonitor.java 41 server/src/main/java/org/apache/druid/server/emitter/LogEmitterModule.java 26 server/src/main/java/org/apache/druid/server/emitter/NoopEmitterModule.java 23 server/src/main/java/org/apache/druid/server/emitter/ParametrizedUriEmitterModule.java 50 server/src/main/java/org/apache/druid/server/emitter/ParametrizedUriEmitterSSLClientConfig.java 19 server/src/main/java/org/apache/druid/server/emitter/SwitchingEmitterConfig.java 24 server/src/main/java/org/apache/druid/server/emitter/SwitchingEmitterModule.java 55 server/src/main/java/org/apache/druid/server/http/BrokerResource.java 39 server/src/main/java/org/apache/druid/server/http/BrokerSyncStatus.java 69 server/src/main/java/org/apache/druid/server/http/CloneStatus.java 45 server/src/main/java/org/apache/druid/server/http/ClusterResource.java 130 server/src/main/java/org/apache/druid/server/http/ConfigSyncStatus.java 44 server/src/main/java/org/apache/druid/server/http/CoordinatorCompactionConfigsResource.java 115 server/src/main/java/org/apache/druid/server/http/CoordinatorCompactionResource.java 94 server/src/main/java/org/apache/druid/server/http/CoordinatorDutyStatus.java 17 server/src/main/java/org/apache/druid/server/http/CoordinatorDynamicConfigSyncer.java 186 server/src/main/java/org/apache/druid/server/http/CoordinatorDynamicConfigsResource.java 139 server/src/main/java/org/apache/druid/server/http/CoordinatorRedirectInfo.java 43 server/src/main/java/org/apache/druid/server/http/CoordinatorResource.java 122 server/src/main/java/org/apache/druid/server/http/DataSegmentPlus.java 126 server/src/main/java/org/apache/druid/server/http/DataSourcesResource.java 819 server/src/main/java/org/apache/druid/server/http/HistoricalResource.java 41 server/src/main/java/org/apache/druid/server/http/HostAndPortWithScheme.java 90 server/src/main/java/org/apache/druid/server/http/HttpMediaType.java 6 server/src/main/java/org/apache/druid/server/http/IntervalsResource.java 138 server/src/main/java/org/apache/druid/server/http/InventoryViewUtils.java 48 server/src/main/java/org/apache/druid/server/http/LookupCoordinatorResource.java 649 server/src/main/java/org/apache/druid/server/http/MetadataResource.java 407 server/src/main/java/org/apache/druid/server/http/OverlordProxyServlet.java 68 server/src/main/java/org/apache/druid/server/http/RedirectFilter.java 59 server/src/main/java/org/apache/druid/server/http/RedirectInfo.java 7 server/src/main/java/org/apache/druid/server/http/RulesResource.java 145 server/src/main/java/org/apache/druid/server/http/SegmentListerResource.java 275 server/src/main/java/org/apache/druid/server/http/SegmentLoadingCapabilities.java 35 server/src/main/java/org/apache/druid/server/http/SegmentLoadingMode.java 6 server/src/main/java/org/apache/druid/server/http/SegmentsToUpdateFilter.java 55 server/src/main/java/org/apache/druid/server/http/SelfDiscoveryResource.java 78 server/src/main/java/org/apache/druid/server/http/ServersResource.java 153 server/src/main/java/org/apache/druid/server/http/ServletResourceUtils.java 55 server/src/main/java/org/apache/druid/server/http/TiersResource.java 92 server/src/main/java/org/apache/druid/server/http/security/AbstractResourceFilter.java 63 server/src/main/java/org/apache/druid/server/http/security/ConfigResourceFilter.java 37 server/src/main/java/org/apache/druid/server/http/security/DatasourceResourceFilter.java 51 server/src/main/java/org/apache/druid/server/http/security/RulesResourceFilter.java 56 server/src/main/java/org/apache/druid/server/http/security/StateResourceFilter.java 34 server/src/main/java/org/apache/druid/server/initialization/AuthenticatorMapperModule.java 93 server/src/main/java/org/apache/druid/server/initialization/AuthorizerMapperModule.java 111 server/src/main/java/org/apache/druid/server/initialization/BatchDataSegmentAnnouncerConfig.java 40 server/src/main/java/org/apache/druid/server/initialization/CuratorDiscoveryConfig.java 15 server/src/main/java/org/apache/druid/server/initialization/ExternalStorageAccessSecurityModule.java 12 server/src/main/java/org/apache/druid/server/initialization/JdbcAccessSecurityConfig.java 47 server/src/main/java/org/apache/druid/server/initialization/ServerConfig.java 319 server/src/main/java/org/apache/druid/server/initialization/TLSServerConfig.java 150 server/src/main/java/org/apache/druid/server/initialization/ZkPathsConfig.java 89 server/src/main/java/org/apache/druid/server/initialization/jetty/BadRequestException.java 8 server/src/main/java/org/apache/druid/server/initialization/jetty/BadRequestExceptionMapper.java 19 server/src/main/java/org/apache/druid/server/initialization/jetty/ChatHandlerServerModule.java 78 server/src/main/java/org/apache/druid/server/initialization/jetty/CliIndexerServerModule.java 125 server/src/main/java/org/apache/druid/server/initialization/jetty/CustomExceptionMapper.java 29 server/src/main/java/org/apache/druid/server/initialization/jetty/DruidGuiceContainer.java 62 server/src/main/java/org/apache/druid/server/initialization/jetty/ForbiddenExceptionMapper.java 21 server/src/main/java/org/apache/druid/server/initialization/jetty/JettyBindings.java 87 server/src/main/java/org/apache/druid/server/initialization/jetty/JettyMonitoringConnectionFactory.java 50 server/src/main/java/org/apache/druid/server/initialization/jetty/JettyRequestLog.java 24 server/src/main/java/org/apache/druid/server/initialization/jetty/JettyServerInitUtils.java 105 server/src/main/java/org/apache/druid/server/initialization/jetty/JettyServerInitializer.java 7 server/src/main/java/org/apache/druid/server/initialization/jetty/JettyServerModule.java 508 server/src/main/java/org/apache/druid/server/initialization/jetty/LimitRequestsFilter.java 52 server/src/main/java/org/apache/druid/server/initialization/jetty/ResponseHeaderFilterHolder.java 75 server/src/main/java/org/apache/druid/server/initialization/jetty/ServiceUnavailableException.java 8 server/src/main/java/org/apache/druid/server/initialization/jetty/ServiceUnavailableExceptionMapper.java 18 server/src/main/java/org/apache/druid/server/initialization/jetty/ServletFilterHolder.java 22 server/src/main/java/org/apache/druid/server/initialization/jetty/StandardResponseHeaderFilterHolder.java 117 server/src/main/java/org/apache/druid/server/initialization/jetty/TaskIdResponseHeaderFilterHolder.java 15 server/src/main/java/org/apache/druid/server/listener/resource/AbstractListenerHandler.java 138 server/src/main/java/org/apache/druid/server/listener/resource/ListenerHandler.java 14 server/src/main/java/org/apache/druid/server/listener/resource/ListenerResource.java 156 server/src/main/java/org/apache/druid/server/log/ComposingRequestLoggerProvider.java 97 server/src/main/java/org/apache/druid/server/log/DefaultRequestLogEvent.java 89 server/src/main/java/org/apache/druid/server/log/DefaultRequestLogEventBuilderFactory.java 34 server/src/main/java/org/apache/druid/server/log/EmittingRequestLogger.java 38 server/src/main/java/org/apache/druid/server/log/EmittingRequestLoggerProvider.java 34 server/src/main/java/org/apache/druid/server/log/FileRequestLogger.java 188 server/src/main/java/org/apache/druid/server/log/FileRequestLoggerProvider.java 48 server/src/main/java/org/apache/druid/server/log/FilteredRequestLoggerProvider.java 111 server/src/main/java/org/apache/druid/server/log/LoggingRequestLogger.java 93 server/src/main/java/org/apache/druid/server/log/LoggingRequestLoggerProvider.java 26 server/src/main/java/org/apache/druid/server/log/NoopRequestLogger.java 18 server/src/main/java/org/apache/druid/server/log/NoopRequestLoggerProvider.java 14 server/src/main/java/org/apache/druid/server/log/RequestLogEvent.java 7 server/src/main/java/org/apache/druid/server/log/RequestLogEventBuilderFactory.java 11 server/src/main/java/org/apache/druid/server/log/RequestLogger.java 14 server/src/main/java/org/apache/druid/server/log/RequestLoggerProvider.java 7 server/src/main/java/org/apache/druid/server/log/StartupLoggingConfig.java 19 server/src/main/java/org/apache/druid/server/log/SwitchingRequestLoggerProvider.java 69 server/src/main/java/org/apache/druid/server/metrics/DataSourceTaskIdHolder.java 40 server/src/main/java/org/apache/druid/server/metrics/DruidSysMonitor.java 22 server/src/main/java/org/apache/druid/server/metrics/GroupByStatsMonitor.java 46 server/src/main/java/org/apache/druid/server/metrics/HistoricalMetricsMonitor.java 74 server/src/main/java/org/apache/druid/server/metrics/IndexerTaskCountStatsProvider.java 10 server/src/main/java/org/apache/druid/server/metrics/MetricsModule.java 176 server/src/main/java/org/apache/druid/server/metrics/MonitorsConfig.java 97 server/src/main/java/org/apache/druid/server/metrics/QueryCountStatsMonitor.java 58 server/src/main/java/org/apache/druid/server/metrics/QueryCountStatsProvider.java 8 server/src/main/java/org/apache/druid/server/metrics/SegmentRowCountDistribution.java 89 server/src/main/java/org/apache/druid/server/metrics/SegmentStatsMonitor.java 60 server/src/main/java/org/apache/druid/server/metrics/ServiceStatusMonitor.java 25 server/src/main/java/org/apache/druid/server/metrics/SubqueryCountStatsMonitor.java 56 server/src/main/java/org/apache/druid/server/metrics/SubqueryCountStatsProvider.java 68 server/src/main/java/org/apache/druid/server/metrics/TaskCountStatsMonitor.java 58 server/src/main/java/org/apache/druid/server/metrics/TaskCountStatsProvider.java 17 server/src/main/java/org/apache/druid/server/metrics/TaskSlotCountStatsMonitor.java 37 server/src/main/java/org/apache/druid/server/metrics/TaskSlotCountStatsProvider.java 17 server/src/main/java/org/apache/druid/server/metrics/WorkerTaskCountStatsMonitor.java 82 server/src/main/java/org/apache/druid/server/metrics/WorkerTaskCountStatsProvider.java 11 server/src/main/java/org/apache/druid/server/router/AvaticaConnectionBalancer.java 14 server/src/main/java/org/apache/druid/server/router/ConsistentHashAvaticaConnectionBalancer.java 26 server/src/main/java/org/apache/druid/server/router/ConsistentHasher.java 97 server/src/main/java/org/apache/druid/server/router/ManagementProxyConfig.java 11 server/src/main/java/org/apache/druid/server/router/RendezvousHashAvaticaConnectionBalancer.java 23 server/src/main/java/org/apache/druid/server/router/RendezvousHasher.java 31 server/src/main/java/org/apache/druid/server/router/Router.java 12 server/src/main/java/org/apache/druid/server/scheduling/HiLoQueryLaningStrategy.java 53 server/src/main/java/org/apache/druid/server/scheduling/ManualQueryLaningStrategy.java 58 server/src/main/java/org/apache/druid/server/scheduling/ManualQueryPrioritizationStrategy.java 15 server/src/main/java/org/apache/druid/server/scheduling/NoQueryLaningStrategy.java 23 server/src/main/java/org/apache/druid/server/scheduling/ThresholdBasedQueryPrioritizationStrategy.java 80 server/src/main/java/org/apache/druid/server/security/Access.java 92 server/src/main/java/org/apache/druid/server/security/Action.java 16 server/src/main/java/org/apache/druid/server/security/AllowAllAuthenticator.java 71 server/src/main/java/org/apache/druid/server/security/AllowAllAuthorizer.java 9 server/src/main/java/org/apache/druid/server/security/AllowHttpMethodsResourceFilter.java 49 server/src/main/java/org/apache/druid/server/security/AllowOptionsResourceFilter.java 49 server/src/main/java/org/apache/druid/server/security/AnonymousAuthenticator.java 86 server/src/main/java/org/apache/druid/server/security/AuthConfig.java 217 server/src/main/java/org/apache/druid/server/security/AuthTestUtils.java 20 server/src/main/java/org/apache/druid/server/security/AuthValidator.java 15 server/src/main/java/org/apache/druid/server/security/AuthenticationOnlyResourceFilter.java 26 server/src/main/java/org/apache/druid/server/security/AuthenticationResult.java 69 server/src/main/java/org/apache/druid/server/security/AuthenticationUtils.java 75 server/src/main/java/org/apache/druid/server/security/AuthenticationWrappingFilter.java 38 server/src/main/java/org/apache/druid/server/security/Authenticator.java 32 server/src/main/java/org/apache/druid/server/security/AuthenticatorMapper.java 22 server/src/main/java/org/apache/druid/server/security/AuthorizationResult.java 163 server/src/main/java/org/apache/druid/server/security/AuthorizationUtils.java 313 server/src/main/java/org/apache/druid/server/security/Authorizer.java 11 server/src/main/java/org/apache/druid/server/security/AuthorizerMapper.java 20 server/src/main/java/org/apache/druid/server/security/CustomCheckX509TrustManager.java 71 server/src/main/java/org/apache/druid/server/security/DefaultTLSCertificateChecker.java 30 server/src/main/java/org/apache/druid/server/security/DefaultTLSCertificateCheckerModule.java 16 server/src/main/java/org/apache/druid/server/security/Escalator.java 13 server/src/main/java/org/apache/druid/server/security/ForbiddenException.java 33 server/src/main/java/org/apache/druid/server/security/NoopEscalator.java 37 server/src/main/java/org/apache/druid/server/security/PreResponseAuthorizationCheckFilter.java 145 server/src/main/java/org/apache/druid/server/security/Resource.java 57 server/src/main/java/org/apache/druid/server/security/ResourceAction.java 55 server/src/main/java/org/apache/druid/server/security/ResourceType.java 31 server/src/main/java/org/apache/druid/server/security/SecuritySanityCheckFilter.java 65 server/src/main/java/org/apache/druid/server/security/TLSCertificateChecker.java 22 server/src/main/java/org/apache/druid/server/security/TLSCertificateCheckerModule.java 75 server/src/main/java/org/apache/druid/server/security/TLSUtils.java 221 server/src/main/java/org/apache/druid/server/security/TrustedDomainAuthenticator.java 125 server/src/main/java/org/apache/druid/server/security/UnsecuredResourceFilter.java 36