Path Lines of Code helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ControllerStatusUpdateResource.java 55 helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/JobQueueResource.java 133 helix-agent/src/main/java/org/apache/helix/agent/ProcessMonitorThread.java 31 helix-common/src/main/java/org/apache/helix/constants/InstanceConstants.java 48 helix-core/src/main/java/org/apache/helix/BaseDataAccessor.java 54 helix-core/src/main/java/org/apache/helix/GroupCommit.java 129 helix-core/src/main/java/org/apache/helix/HelixConstants.java 41 helix-core/src/main/java/org/apache/helix/HelixDataAccessor.java 42 helix-core/src/main/java/org/apache/helix/HelixRebalanceException.java 22 helix-core/src/main/java/org/apache/helix/PropertyKey.java 423 helix-core/src/main/java/org/apache/helix/PropertyPathBuilder.java 492 helix-core/src/main/java/org/apache/helix/cloud/azure/AzureCloudInstanceInformationProcessor.java 109 helix-core/src/main/java/org/apache/helix/cloud/event/helix/DefaultCloudEventCallbackImpl.java 67 helix-core/src/main/java/org/apache/helix/common/caches/InstanceMessagesCache.java 394 helix-core/src/main/java/org/apache/helix/common/caches/TaskDataCache.java 238 helix-core/src/main/java/org/apache/helix/controller/ExternalViewGenerator.java 76 helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java 1241 helix-core/src/main/java/org/apache/helix/controller/changedetector/ChangeDetector.java 9 helix-core/src/main/java/org/apache/helix/controller/changedetector/trimmer/HelixPropertyTrimmer.java 67 helix-core/src/main/java/org/apache/helix/controller/dataproviders/BaseControllerDataProvider.java 866 helix-core/src/main/java/org/apache/helix/controller/dataproviders/ResourceControllerDataProvider.java 354 helix-core/src/main/java/org/apache/helix/controller/dataproviders/WorkflowControllerDataProvider.java 151 helix-core/src/main/java/org/apache/helix/controller/pipeline/AbstractBaseStage.java 48 helix-core/src/main/java/org/apache/helix/controller/rebalancer/AbstractRebalancer.java 424 helix-core/src/main/java/org/apache/helix/controller/rebalancer/DelayedAutoRebalancer.java 339 helix-core/src/main/java/org/apache/helix/controller/rebalancer/constraint/ExcessiveTopStateResolver.java 57 helix-core/src/main/java/org/apache/helix/controller/rebalancer/strategy/ConstraintRebalanceStrategy.java 220 helix-core/src/main/java/org/apache/helix/controller/rebalancer/strategy/MultiRoundCrushRebalanceStrategy.java 262 helix-core/src/main/java/org/apache/helix/controller/rebalancer/topology/Topology.java 260 helix-core/src/main/java/org/apache/helix/controller/rebalancer/util/DelayedRebalanceUtil.java 329 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/AssignmentMetadataStore.java 151 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/WagedInstanceCapacity.java 160 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/WagedRebalancer.java 468 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/model/AssignableNode.java 231 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/model/AssignableReplica.java 88 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/model/ClusterContext.java 170 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/model/ClusterModelProvider.java 380 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/model/OptimalAssignment.java 49 helix-core/src/main/java/org/apache/helix/controller/stages/BestPossibleStateCalcStage.java 482 helix-core/src/main/java/org/apache/helix/controller/stages/BestPossibleStateOutput.java 63 helix-core/src/main/java/org/apache/helix/controller/stages/CurrentStateComputationStage.java 323 helix-core/src/main/java/org/apache/helix/controller/stages/ExternalViewComputeStage.java 223 helix-core/src/main/java/org/apache/helix/controller/stages/IntermediateStateCalcStage.java 603 helix-core/src/main/java/org/apache/helix/controller/stages/ManagementModeStage.java 132 helix-core/src/main/java/org/apache/helix/controller/stages/MessageDispatchStage.java 149 helix-core/src/main/java/org/apache/helix/controller/stages/MessageGenerationPhase.java 364 helix-core/src/main/java/org/apache/helix/controller/stages/MessageSelectionStage.java 207 helix-core/src/main/java/org/apache/helix/controller/stages/MessageThrottleStage.java 139 helix-core/src/main/java/org/apache/helix/controller/stages/PersistAssignmentStage.java 190 helix-core/src/main/java/org/apache/helix/controller/stages/ReadClusterDataStage.java 91 helix-core/src/main/java/org/apache/helix/controller/stages/ResourceValidationStage.java 86 helix-core/src/main/java/org/apache/helix/controller/stages/TargetExteralViewCalcStage.java 97 helix-core/src/main/java/org/apache/helix/controller/stages/TopStateHandoffReportStage.java 325 helix-core/src/main/java/org/apache/helix/controller/stages/task/TaskSchedulingStage.java 169 helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java 674 helix-core/src/main/java/org/apache/helix/manager/zk/DefaultParticipantErrorMessageHandlerFactory.java 81 helix-core/src/main/java/org/apache/helix/manager/zk/ParticipantManager.java 402 helix-core/src/main/java/org/apache/helix/manager/zk/ZKHelixAdmin.java 2165 helix-core/src/main/java/org/apache/helix/manager/zk/ZKHelixDataAccessor.java 485 helix-core/src/main/java/org/apache/helix/manager/zk/ZKHelixManager.java 1181 helix-core/src/main/java/org/apache/helix/manager/zk/ZKUtil.java 466 helix-core/src/main/java/org/apache/helix/manager/zk/ZkBaseDataAccessor.java 1037 helix-core/src/main/java/org/apache/helix/manager/zk/ZkBucketDataAccessor.java 311 helix-core/src/main/java/org/apache/helix/manager/zk/ZkCacheBaseDataAccessor.java 697 helix-core/src/main/java/org/apache/helix/manager/zk/ZkCallbackCache.java 213 helix-core/src/main/java/org/apache/helix/manager/zk/client/ZkConnectionManager.java 23 helix-core/src/main/java/org/apache/helix/messaging/CriteriaEvaluator.java 126 helix-core/src/main/java/org/apache/helix/messaging/DefaultMessagingService.java 302 helix-core/src/main/java/org/apache/helix/messaging/handling/BatchMessageHandler.java 170 helix-core/src/main/java/org/apache/helix/messaging/handling/HelixBatchMessageTask.java 87 helix-core/src/main/java/org/apache/helix/messaging/handling/HelixStateTransitionHandler.java 339 helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTask.java 318 helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java 1100 helix-core/src/main/java/org/apache/helix/messaging/handling/MultiTypeMessageHandlerFactory.java 15 helix-core/src/main/java/org/apache/helix/model/AlertHistory.java 12 helix-core/src/main/java/org/apache/helix/model/AlertStatus.java 33 helix-core/src/main/java/org/apache/helix/model/Alerts.java 36 helix-core/src/main/java/org/apache/helix/model/ClusterConfig.java 638 helix-core/src/main/java/org/apache/helix/model/ClusterConstraints.java 103 helix-core/src/main/java/org/apache/helix/model/ConstraintItem.java 55 helix-core/src/main/java/org/apache/helix/model/ControllerHistory.java 174 helix-core/src/main/java/org/apache/helix/model/Error.java 12 helix-core/src/main/java/org/apache/helix/model/HealthStat.java 66 helix-core/src/main/java/org/apache/helix/model/IdealState.java 443 helix-core/src/main/java/org/apache/helix/model/InstanceConfig.java 819 helix-core/src/main/java/org/apache/helix/model/LiveInstance.java 104 helix-core/src/main/java/org/apache/helix/model/MaintenanceSignal.java 56 helix-core/src/main/java/org/apache/helix/model/Message.java 520 helix-core/src/main/java/org/apache/helix/model/PersistentStats.java 39 helix-core/src/main/java/org/apache/helix/model/ResourceConfig.java 578 helix-core/src/main/java/org/apache/helix/model/StateModelDefinition.java 272 helix-core/src/main/java/org/apache/helix/model/builder/ConfigScopeBuilder.java 82 helix-core/src/main/java/org/apache/helix/model/builder/ConstraintItemBuilder.java 65 helix-core/src/main/java/org/apache/helix/model/builder/StateTransitionTableBuilder.java 105 helix-core/src/main/java/org/apache/helix/monitoring/ZKPathDataDumpTask.java 100 helix-core/src/main/java/org/apache/helix/monitoring/mbeans/ClusterMBeanObserver.java 50 helix-core/src/main/java/org/apache/helix/monitoring/mbeans/ClusterStatusMonitor.java 880 helix-core/src/main/java/org/apache/helix/monitoring/mbeans/InstanceMonitor.java 190 helix-core/src/main/java/org/apache/helix/monitoring/mbeans/JobMonitor.java 137 helix-core/src/main/java/org/apache/helix/monitoring/mbeans/MonitorLevel.java 6 helix-core/src/main/java/org/apache/helix/monitoring/mbeans/ResourceMonitor.java 400 helix-core/src/main/java/org/apache/helix/monitoring/mbeans/StateTransitionStatMonitor.java 73 helix-core/src/main/java/org/apache/helix/participant/HelixStateMachineEngine.java 239 helix-core/src/main/java/org/apache/helix/participant/statemachine/ScheduledTaskStateModel.java 80 helix-core/src/main/java/org/apache/helix/participant/statemachine/StateModel.java 48 helix-core/src/main/java/org/apache/helix/spectator/RoutingDataCache.java 154 helix-core/src/main/java/org/apache/helix/spectator/RoutingTable.java 348 helix-core/src/main/java/org/apache/helix/spectator/RoutingTableProvider.java 721 helix-core/src/main/java/org/apache/helix/task/AbstractTaskDispatcher.java 915 helix-core/src/main/java/org/apache/helix/task/AssignableInstanceManager.java 389 helix-core/src/main/java/org/apache/helix/task/JobDispatcher.java 374 helix-core/src/main/java/org/apache/helix/task/TaskDriver.java 904 helix-core/src/main/java/org/apache/helix/task/TaskState.java 13 helix-core/src/main/java/org/apache/helix/task/TaskStateModelFactory.java 131 helix-core/src/main/java/org/apache/helix/task/TaskUtil.java 687 helix-core/src/main/java/org/apache/helix/task/ThreadCountBasedTaskAssignmentCalculator.java 90 helix-core/src/main/java/org/apache/helix/task/UserContentStore.java 39 helix-core/src/main/java/org/apache/helix/task/WorkflowConfig.java 469 helix-core/src/main/java/org/apache/helix/task/WorkflowContext.java 221 helix-core/src/main/java/org/apache/helix/task/WorkflowDispatcher.java 391 helix-core/src/main/java/org/apache/helix/task/assigner/AssignableInstance.java 266 helix-core/src/main/java/org/apache/helix/tools/ClusterExternalViewVerifier.java 98 helix-core/src/main/java/org/apache/helix/tools/ClusterSetup.java 1345 helix-core/src/main/java/org/apache/helix/tools/ClusterStateVerifier.java 584 helix-core/src/main/java/org/apache/helix/tools/ClusterVerifiers/BestPossibleExternalViewVerifier.java 346 helix-core/src/main/java/org/apache/helix/tools/DefaultIdealStateCalculator.java 398 helix-core/src/main/java/org/apache/helix/tools/StateModelConfigGenerator.java 40 helix-core/src/main/java/org/apache/helix/tools/TestExecutor.java 661 helix-core/src/main/java/org/apache/helix/tools/TestTrigger.java 37 helix-core/src/main/java/org/apache/helix/tools/ZnodeOpArg.java 49 helix-core/src/main/java/org/apache/helix/tools/commandtools/ZkGrep.java 437 helix-core/src/main/java/org/apache/helix/tools/commandtools/ZkLogCSVFormatter.java 261 helix-core/src/main/java/org/apache/helix/util/HelixUtil.java 358 helix-core/src/main/java/org/apache/helix/util/InstanceValidationUtil.java 281 helix-core/src/main/java/org/apache/helix/util/MessageUtil.java 82 helix-core/src/main/java/org/apache/helix/util/StatusUpdateUtil.java 403 helix-core/src/main/java/org/apache/helix/util/ZKClientPool.java 57 helix-core/src/main/java/org/apache/helix/util/ZNRecordUtil.java 78 helix-core/src/main/scripts/integration-test/script/dds_driver.py 887 helix-front/src/app/cluster/cluster-detail/cluster-detail.component.ts 198 helix-front/src/app/cluster/shared/cluster.model.ts 30 helix-front/src/app/history/history-list/history-list.component.ts 48 helix-front/src/app/history/shared/history.service.ts 41 helix-front/src/app/resource/shared/resource.model.ts 119 helix-front/src/app/shared/node-viewer/node-viewer.component.html 282 helix-lock/src/main/java/org/apache/helix/lock/helix/HelixLockScope.java 39 helix-lock/src/main/java/org/apache/helix/lock/helix/ZKDistributedNonblockingLock.java 374 helix-rest/src/main/java/org/apache/helix/rest/clusterMaintenanceService/MaintenanceManagementService.java 761 helix-rest/src/main/java/org/apache/helix/rest/clusterMaintenanceService/StoppableInstancesSelector.java 219 helix-rest/src/main/java/org/apache/helix/rest/common/HelixRestNamespace.java 76 helix-rest/src/main/java/org/apache/helix/rest/common/datamodel/RestSnapShot.java 30 helix-rest/src/main/java/org/apache/helix/rest/server/HelixRestMain.java 125 helix-rest/src/main/java/org/apache/helix/rest/server/HelixRestServer.java 270 helix-rest/src/main/java/org/apache/helix/rest/server/ServerContext.java 305 helix-rest/src/main/java/org/apache/helix/rest/server/resources/AbstractResource.java 171 helix-rest/src/main/java/org/apache/helix/rest/server/resources/helix/ClusterAccessor.java 1116 helix-rest/src/main/java/org/apache/helix/rest/server/resources/helix/InstancesAccessor.java 333 helix-rest/src/main/java/org/apache/helix/rest/server/resources/helix/PerInstanceAccessor.java 741 helix-rest/src/main/java/org/apache/helix/rest/server/resources/helix/ResourceAssignmentOptimizerAccessor.java 315 helix-rest/src/main/java/org/apache/helix/rest/server/resources/zookeeper/ZooKeeperAccessor.java 162 helix-rest/src/main/java/org/apache/helix/rest/server/service/ClusterService.java 9 helix-rest/src/main/java/org/apache/helix/rest/server/service/InstanceServiceImpl.java 51 helix-view-aggregator/src/main/java/org/apache/helix/view/aggregator/HelixViewAggregator.java 311 helix-view-aggregator/src/main/java/org/apache/helix/view/dataprovider/SourceClusterDataProvider.java 153 meta-client/src/main/java/org/apache/helix/metaclient/api/ChildChangeListener.java 9 meta-client/src/main/java/org/apache/helix/metaclient/api/ConnectStateChangeListener.java 5 meta-client/src/main/java/org/apache/helix/metaclient/api/MetaClientInterface.java 121 meta-client/src/main/java/org/apache/helix/metaclient/constants/MetaClientConstants.java 11 meta-client/src/main/java/org/apache/helix/metaclient/datamodel/DataRecord.java 16 meta-client/src/main/java/org/apache/helix/metaclient/exception/MetaClientException.java 68 meta-client/src/main/java/org/apache/helix/metaclient/factories/MetaClientConfig.java 99 meta-client/src/main/java/org/apache/helix/metaclient/impl/zk/ZkMetaClient.java 469 meta-client/src/main/java/org/apache/helix/metaclient/impl/zk/ZkMetaClientCache.java 169 meta-client/src/main/java/org/apache/helix/metaclient/impl/zk/factory/ZkMetaClientConfig.java 88 meta-client/src/main/java/org/apache/helix/metaclient/impl/zk/util/ZkMetaClientUtil.java 287 meta-client/src/main/java/org/apache/helix/metaclient/policy/ExponentialBackoffReconnectPolicy.java 22 meta-client/src/main/java/org/apache/helix/metaclient/recipes/leaderelection/LeaderElectionClient.java 255 recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/Consumer.java 87 recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/ConsumerStateModel.java 68 recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/ConsumerThread.java 65 recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/Emitter.java 37 recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/StartClusterManager.java 28 recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/ChangeLogReader.java 99 recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/StartClusterManager.java 28 recipes/task-execution/src/main/java/org/apache/helix/taskexecution/Worker.java 97 zookeeper-api/src/main/java/org/apache/helix/zookeeper/api/client/RealmAwareZkClient.java 377 zookeeper-api/src/main/java/org/apache/helix/zookeeper/constant/ZkSystemPropertyKeys.java 14 zookeeper-api/src/main/java/org/apache/helix/zookeeper/datamodel/serializer/ZNRecordJacksonSerializer.java 37 zookeeper-api/src/main/java/org/apache/helix/zookeeper/datamodel/serializer/ZNRecordSerializer.java 102 zookeeper-api/src/main/java/org/apache/helix/zookeeper/impl/client/FederatedZkClient.java 544 zookeeper-api/src/main/java/org/apache/helix/zookeeper/impl/client/SharedZkClient.java 506 zookeeper-api/src/main/java/org/apache/helix/zookeeper/impl/client/ZkClient.java 178 zookeeper-api/src/main/java/org/apache/helix/zookeeper/impl/factory/ZkConnectionManager.java 80 zookeeper-api/src/main/java/org/apache/helix/zookeeper/introspect/CodehausJacksonIntrospector.java 222 zookeeper-api/src/main/java/org/apache/helix/zookeeper/routing/HttpZkFallbackRoutingDataReader.java 35 zookeeper-api/src/main/java/org/apache/helix/zookeeper/zkclient/ZkClient.java 1981 zookeeper-api/src/main/java/org/apache/helix/zookeeper/zkclient/ZkConnection.java 227 zookeeper-api/src/main/java/org/apache/helix/zookeeper/zkclient/callback/ZkAsyncCallbacks.java 241