[HELIX-198] Unify helix code style, rb=13710
authorzzhang <zzhang5@uci.edu>
Wed, 21 Aug 2013 20:42:57 +0000 (13:42 -0700)
committerzzhang <zzhang5@uci.edu>
Wed, 21 Aug 2013 20:42:57 +0000 (13:42 -0700)
commitf414aad4c9b26fc767eaf373f7691f8e0487a598
tree8fb69780136ffe176deabe1cce97ba72e6b2e998
parent18f603aa091e8ab69e9b97568dceac87b2d29389
[HELIX-198] Unify helix code style, rb=13710
598 files changed:
helix-admin-webapp/src/main/java/org/apache/helix/webapp/HelixAdminWebApp.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/RestAdminApplication.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ClusterRepresentationUtil.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ClusterResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ClustersResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ConfigResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ConstraintResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ControllerResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ControllerStatusUpdateResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/CurrentStateResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/CurrentStatesResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ErrorResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ErrorsResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ExternalViewResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/IdealStateResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/InstanceResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/InstancesResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/JsonParameters.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ResourceGroupResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ResourceGroupsResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/SchedulerTasksResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/StateModelResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/StateModelsResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/StatusUpdateResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/StatusUpdatesResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ZkChildResource.java
helix-admin-webapp/src/main/java/org/apache/helix/webapp/resources/ZkPathResource.java
helix-admin-webapp/src/test/java/org/apache/helix/tools/AdminTestBase.java
helix-admin-webapp/src/test/java/org/apache/helix/tools/AdminTestHelper.java
helix-admin-webapp/src/test/java/org/apache/helix/tools/TestHelixAdminScenariosRest.java
helix-admin-webapp/src/test/java/org/apache/helix/tools/TestResetInstance.java
helix-admin-webapp/src/test/java/org/apache/helix/tools/TestResetPartitionState.java
helix-admin-webapp/src/test/java/org/apache/helix/tools/TestResetResource.java
helix-admin-webapp/src/test/java/org/apache/helix/webapp/TestClusterManagementWebapp.java
helix-agent/src/main/java/org/apache/helix/agent/AgentStateModel.java
helix-agent/src/main/java/org/apache/helix/agent/AgentStateModelFactory.java
helix-agent/src/main/java/org/apache/helix/agent/CommandAttribute.java
helix-agent/src/main/java/org/apache/helix/agent/CommandConfig.java
helix-agent/src/main/java/org/apache/helix/agent/HelixAgentMain.java
helix-agent/src/main/java/org/apache/helix/agent/ProcessMonitorThread.java
helix-agent/src/main/java/org/apache/helix/agent/SystemUtil.java
helix-agent/src/test/java/org/apache/helix/agent/TestHelixAgent.java
helix-core/src/main/java/org/apache/helix/AccessOption.java
helix-core/src/main/java/org/apache/helix/BaseDataAccessor.java
helix-core/src/main/java/org/apache/helix/ClusterMessagingService.java
helix-core/src/main/java/org/apache/helix/ConfigAccessor.java
helix-core/src/main/java/org/apache/helix/ConfigChangeListener.java
helix-core/src/main/java/org/apache/helix/ControllerChangeListener.java
helix-core/src/main/java/org/apache/helix/Criteria.java
helix-core/src/main/java/org/apache/helix/CurrentStateChangeListener.java
helix-core/src/main/java/org/apache/helix/ExternalCommand.java
helix-core/src/main/java/org/apache/helix/ExternalViewChangeListener.java
helix-core/src/main/java/org/apache/helix/GroupCommit.java
helix-core/src/main/java/org/apache/helix/HealthStateChangeListener.java
helix-core/src/main/java/org/apache/helix/HelixAdmin.java
helix-core/src/main/java/org/apache/helix/HelixConstants.java
helix-core/src/main/java/org/apache/helix/HelixDataAccessor.java
helix-core/src/main/java/org/apache/helix/HelixDefinedState.java
helix-core/src/main/java/org/apache/helix/HelixException.java
helix-core/src/main/java/org/apache/helix/HelixManager.java
helix-core/src/main/java/org/apache/helix/HelixManagerFactory.java
helix-core/src/main/java/org/apache/helix/HelixManagerProperties.java
helix-core/src/main/java/org/apache/helix/HelixProperty.java
helix-core/src/main/java/org/apache/helix/HelixTimerTask.java
helix-core/src/main/java/org/apache/helix/IdealStateChangeListener.java
helix-core/src/main/java/org/apache/helix/InstanceConfigChangeListener.java
helix-core/src/main/java/org/apache/helix/InstanceType.java
helix-core/src/main/java/org/apache/helix/LiveInstanceChangeListener.java
helix-core/src/main/java/org/apache/helix/LiveInstanceInfoProvider.java
helix-core/src/main/java/org/apache/helix/MessageListener.java
helix-core/src/main/java/org/apache/helix/NotificationContext.java
helix-core/src/main/java/org/apache/helix/PreConnectCallback.java
helix-core/src/main/java/org/apache/helix/PropertyKey.java
helix-core/src/main/java/org/apache/helix/PropertyPathConfig.java
helix-core/src/main/java/org/apache/helix/PropertyType.java
helix-core/src/main/java/org/apache/helix/ScopedConfigChangeListener.java
helix-core/src/main/java/org/apache/helix/ZNRecord.java
helix-core/src/main/java/org/apache/helix/ZNRecordAssembler.java
helix-core/src/main/java/org/apache/helix/ZNRecordBucketizer.java
helix-core/src/main/java/org/apache/helix/ZNRecordDelta.java
helix-core/src/main/java/org/apache/helix/ZNRecordUpdater.java
helix-core/src/main/java/org/apache/helix/alerts/AccumulateAggregator.java
helix-core/src/main/java/org/apache/helix/alerts/Aggregator.java
helix-core/src/main/java/org/apache/helix/alerts/Alert.java
helix-core/src/main/java/org/apache/helix/alerts/AlertComparator.java
helix-core/src/main/java/org/apache/helix/alerts/AlertParser.java
helix-core/src/main/java/org/apache/helix/alerts/AlertProcessor.java
helix-core/src/main/java/org/apache/helix/alerts/AlertValueAndStatus.java
helix-core/src/main/java/org/apache/helix/alerts/AlertsHolder.java
helix-core/src/main/java/org/apache/helix/alerts/DecayAggregator.java
helix-core/src/main/java/org/apache/helix/alerts/DivideOperator.java
helix-core/src/main/java/org/apache/helix/alerts/ExpandOperator.java
helix-core/src/main/java/org/apache/helix/alerts/ExpressionOperatorType.java
helix-core/src/main/java/org/apache/helix/alerts/ExpressionParser.java
helix-core/src/main/java/org/apache/helix/alerts/GreaterAlertComparator.java
helix-core/src/main/java/org/apache/helix/alerts/MultiplyOperator.java
helix-core/src/main/java/org/apache/helix/alerts/Operator.java
helix-core/src/main/java/org/apache/helix/alerts/Stat.java
helix-core/src/main/java/org/apache/helix/alerts/StatsHolder.java
helix-core/src/main/java/org/apache/helix/alerts/SumEachOperator.java
helix-core/src/main/java/org/apache/helix/alerts/SumOperator.java
helix-core/src/main/java/org/apache/helix/alerts/Tuple.java
helix-core/src/main/java/org/apache/helix/alerts/WindowAggregator.java
helix-core/src/main/java/org/apache/helix/controller/ExternalViewGenerator.java
helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java
helix-core/src/main/java/org/apache/helix/controller/HelixControllerMain.java
helix-core/src/main/java/org/apache/helix/controller/HierarchicalDataHolder.java
helix-core/src/main/java/org/apache/helix/controller/pipeline/AbstractBaseStage.java
helix-core/src/main/java/org/apache/helix/controller/pipeline/Pipeline.java
helix-core/src/main/java/org/apache/helix/controller/pipeline/PipelineRegistry.java
helix-core/src/main/java/org/apache/helix/controller/pipeline/Stage.java
helix-core/src/main/java/org/apache/helix/controller/pipeline/StageContext.java
helix-core/src/main/java/org/apache/helix/controller/pipeline/StageException.java
helix-core/src/main/java/org/apache/helix/controller/rebalancer/AutoRebalancer.java
helix-core/src/main/java/org/apache/helix/controller/rebalancer/CustomRebalancer.java
helix-core/src/main/java/org/apache/helix/controller/rebalancer/Rebalancer.java
helix-core/src/main/java/org/apache/helix/controller/rebalancer/SemiAutoRebalancer.java
helix-core/src/main/java/org/apache/helix/controller/rebalancer/util/ConstraintBasedAssignment.java
helix-core/src/main/java/org/apache/helix/controller/restlet/ZKPropertyTransferServer.java
helix-core/src/main/java/org/apache/helix/controller/restlet/ZNRecordUpdate.java
helix-core/src/main/java/org/apache/helix/controller/restlet/ZNRecordUpdateResource.java
helix-core/src/main/java/org/apache/helix/controller/restlet/ZkPropertyTransferApplication.java
helix-core/src/main/java/org/apache/helix/controller/restlet/ZkPropertyTransferClient.java
helix-core/src/main/java/org/apache/helix/controller/stages/AttributeName.java
helix-core/src/main/java/org/apache/helix/controller/stages/BestPossibleStateCalcStage.java
helix-core/src/main/java/org/apache/helix/controller/stages/BestPossibleStateOutput.java
helix-core/src/main/java/org/apache/helix/controller/stages/ClusterDataCache.java
helix-core/src/main/java/org/apache/helix/controller/stages/ClusterEvent.java
helix-core/src/main/java/org/apache/helix/controller/stages/CompatibilityCheckStage.java
helix-core/src/main/java/org/apache/helix/controller/stages/CurrentStateComputationStage.java
helix-core/src/main/java/org/apache/helix/controller/stages/CurrentStateOutput.java
helix-core/src/main/java/org/apache/helix/controller/stages/ExternalViewComputeStage.java
helix-core/src/main/java/org/apache/helix/controller/stages/HealthDataCache.java
helix-core/src/main/java/org/apache/helix/controller/stages/MessageGenerationOutput.java
helix-core/src/main/java/org/apache/helix/controller/stages/MessageGenerationPhase.java
helix-core/src/main/java/org/apache/helix/controller/stages/MessageSelectionStage.java
helix-core/src/main/java/org/apache/helix/controller/stages/MessageSelectionStageOutput.java
helix-core/src/main/java/org/apache/helix/controller/stages/MessageThrottleStage.java
helix-core/src/main/java/org/apache/helix/controller/stages/MessageThrottleStageOutput.java
helix-core/src/main/java/org/apache/helix/controller/stages/ReadClusterDataStage.java
helix-core/src/main/java/org/apache/helix/controller/stages/ReadHealthDataStage.java
helix-core/src/main/java/org/apache/helix/controller/stages/RebalanceIdealStateStage.java
helix-core/src/main/java/org/apache/helix/controller/stages/ResourceComputationStage.java
helix-core/src/main/java/org/apache/helix/controller/stages/StatsAggregationStage.java
helix-core/src/main/java/org/apache/helix/controller/stages/TaskAssignmentStage.java
helix-core/src/main/java/org/apache/helix/controller/strategy/AutoRebalanceStrategy.java
helix-core/src/main/java/org/apache/helix/examples/BootstrapHandler.java
helix-core/src/main/java/org/apache/helix/examples/BootstrapProcess.java
helix-core/src/main/java/org/apache/helix/examples/DummyParticipant.java
helix-core/src/main/java/org/apache/helix/examples/ExampleHelper.java
helix-core/src/main/java/org/apache/helix/examples/ExampleProcess.java
helix-core/src/main/java/org/apache/helix/examples/IdealStateBuilderExample.java
helix-core/src/main/java/org/apache/helix/examples/IdealStateExample.java
helix-core/src/main/java/org/apache/helix/examples/LeaderStandbyStateModelFactory.java
helix-core/src/main/java/org/apache/helix/examples/MasterSlaveStateModelFactory.java
helix-core/src/main/java/org/apache/helix/examples/OnlineOfflineStateModelFactory.java
helix-core/src/main/java/org/apache/helix/examples/Quickstart.java
helix-core/src/main/java/org/apache/helix/healthcheck/AccumulateAggregationType.java
helix-core/src/main/java/org/apache/helix/healthcheck/AggregationType.java
helix-core/src/main/java/org/apache/helix/healthcheck/AggregationTypeFactory.java
helix-core/src/main/java/org/apache/helix/healthcheck/DecayAggregationType.java
helix-core/src/main/java/org/apache/helix/healthcheck/DefaultHealthReportProvider.java
helix-core/src/main/java/org/apache/helix/healthcheck/DefaultPerfCounters.java
helix-core/src/main/java/org/apache/helix/healthcheck/HealthReportProvider.java
helix-core/src/main/java/org/apache/helix/healthcheck/HealthStatsAggregationTask.java
helix-core/src/main/java/org/apache/helix/healthcheck/HealthStatsAggregator.java
helix-core/src/main/java/org/apache/helix/healthcheck/ParticipantHealthReportCollector.java
helix-core/src/main/java/org/apache/helix/healthcheck/ParticipantHealthReportCollectorImpl.java
helix-core/src/main/java/org/apache/helix/healthcheck/ParticipantHealthReportTask.java
helix-core/src/main/java/org/apache/helix/healthcheck/PerformanceHealthReportProvider.java
helix-core/src/main/java/org/apache/helix/healthcheck/Stat.java
helix-core/src/main/java/org/apache/helix/healthcheck/StatHealthReportProvider.java
helix-core/src/main/java/org/apache/helix/healthcheck/WindowAggregationType.java
helix-core/src/main/java/org/apache/helix/josql/ClusterJosqlQueryProcessor.java
helix-core/src/main/java/org/apache/helix/josql/ZNRecordJosqlFunctionHandler.java
helix-core/src/main/java/org/apache/helix/josql/ZNRecordRow.java
helix-core/src/main/java/org/apache/helix/manager/zk/AbstractManager.java
helix-core/src/main/java/org/apache/helix/manager/zk/BasicZkSerializer.java
helix-core/src/main/java/org/apache/helix/manager/zk/ByteArraySerializer.java
helix-core/src/main/java/org/apache/helix/manager/zk/Cache.java
helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java
helix-core/src/main/java/org/apache/helix/manager/zk/ChainedPathZkSerializer.java
helix-core/src/main/java/org/apache/helix/manager/zk/ControllerManager.java
helix-core/src/main/java/org/apache/helix/manager/zk/ControllerManagerHelper.java
helix-core/src/main/java/org/apache/helix/manager/zk/CurStateCarryOverUpdater.java
helix-core/src/main/java/org/apache/helix/manager/zk/DefaultControllerMessageHandlerFactory.java
helix-core/src/main/java/org/apache/helix/manager/zk/DefaultParticipantErrorMessageHandlerFactory.java
helix-core/src/main/java/org/apache/helix/manager/zk/DefaultSchedulerMessageHandlerFactory.java
helix-core/src/main/java/org/apache/helix/manager/zk/DistributedControllerManager.java
helix-core/src/main/java/org/apache/helix/manager/zk/DistributedLeaderElection.java
helix-core/src/main/java/org/apache/helix/manager/zk/HelixGroupCommit.java
helix-core/src/main/java/org/apache/helix/manager/zk/ParticipantManager.java
helix-core/src/main/java/org/apache/helix/manager/zk/ParticipantManagerHelper.java
helix-core/src/main/java/org/apache/helix/manager/zk/PathBasedZkSerializer.java
helix-core/src/main/java/org/apache/helix/manager/zk/WriteThroughCache.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZKExceptionHandler.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZKHelixAdmin.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZKHelixDataAccessor.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZKHelixManager.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZKUtil.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZNRecordSerializer.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZNRecordStreamingSerializer.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZkAsyncCallbacks.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZkBaseDataAccessor.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZkCacheBaseDataAccessor.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZkCacheEventThread.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZkCallbackCache.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZkClient.java
helix-core/src/main/java/org/apache/helix/manager/zk/ZkStateChangeListener.java
helix-core/src/main/java/org/apache/helix/manager/zk/serializer/JacksonPayloadSerializer.java
helix-core/src/main/java/org/apache/helix/messaging/AsyncCallback.java
helix-core/src/main/java/org/apache/helix/messaging/CriteriaEvaluator.java
helix-core/src/main/java/org/apache/helix/messaging/DefaultMessagingService.java
helix-core/src/main/java/org/apache/helix/messaging/handling/AsyncCallbackService.java
helix-core/src/main/java/org/apache/helix/messaging/handling/BatchMessageHandler.java
helix-core/src/main/java/org/apache/helix/messaging/handling/BatchMessageWrapper.java
helix-core/src/main/java/org/apache/helix/messaging/handling/CurrentStateUpdate.java
helix-core/src/main/java/org/apache/helix/messaging/handling/GroupMessageHandler.java
helix-core/src/main/java/org/apache/helix/messaging/handling/HelixBatchMessageTask.java
helix-core/src/main/java/org/apache/helix/messaging/handling/HelixStateTransitionHandler.java
helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTask.java
helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java
helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskResult.java
helix-core/src/main/java/org/apache/helix/messaging/handling/MessageHandler.java
helix-core/src/main/java/org/apache/helix/messaging/handling/MessageHandlerFactory.java
helix-core/src/main/java/org/apache/helix/messaging/handling/MessageTask.java
helix-core/src/main/java/org/apache/helix/messaging/handling/MessageTaskInfo.java
helix-core/src/main/java/org/apache/helix/messaging/handling/MessageTimeoutTask.java
helix-core/src/main/java/org/apache/helix/messaging/handling/TaskExecutor.java
helix-core/src/main/java/org/apache/helix/model/AlertHistory.java
helix-core/src/main/java/org/apache/helix/model/AlertStatus.java
helix-core/src/main/java/org/apache/helix/model/Alerts.java
helix-core/src/main/java/org/apache/helix/model/ClusterConstraints.java
helix-core/src/main/java/org/apache/helix/model/ConfigScope.java
helix-core/src/main/java/org/apache/helix/model/ConstraintItem.java
helix-core/src/main/java/org/apache/helix/model/CurrentState.java
helix-core/src/main/java/org/apache/helix/model/Error.java
helix-core/src/main/java/org/apache/helix/model/ExternalView.java
helix-core/src/main/java/org/apache/helix/model/HealthStat.java
helix-core/src/main/java/org/apache/helix/model/HelixConfigScope.java
helix-core/src/main/java/org/apache/helix/model/IdealState.java
helix-core/src/main/java/org/apache/helix/model/InstanceConfig.java
helix-core/src/main/java/org/apache/helix/model/LeaderHistory.java
helix-core/src/main/java/org/apache/helix/model/LiveInstance.java
helix-core/src/main/java/org/apache/helix/model/Message.java
helix-core/src/main/java/org/apache/helix/model/Partition.java
helix-core/src/main/java/org/apache/helix/model/PauseSignal.java
helix-core/src/main/java/org/apache/helix/model/PersistentStats.java
helix-core/src/main/java/org/apache/helix/model/Resource.java
helix-core/src/main/java/org/apache/helix/model/ResourceAssignment.java
helix-core/src/main/java/org/apache/helix/model/StateModelDefinition.java
helix-core/src/main/java/org/apache/helix/model/StatusUpdate.java
helix-core/src/main/java/org/apache/helix/model/Transition.java
helix-core/src/main/java/org/apache/helix/model/builder/AutoModeISBuilder.java
helix-core/src/main/java/org/apache/helix/model/builder/AutoRebalanceModeISBuilder.java
helix-core/src/main/java/org/apache/helix/model/builder/ClusterConstraintsBuilder.java
helix-core/src/main/java/org/apache/helix/model/builder/ConfigScopeBuilder.java
helix-core/src/main/java/org/apache/helix/model/builder/ConstraintItemBuilder.java
helix-core/src/main/java/org/apache/helix/model/builder/CustomModeISBuilder.java
helix-core/src/main/java/org/apache/helix/model/builder/HelixConfigScopeBuilder.java
helix-core/src/main/java/org/apache/helix/model/builder/IdealStateBuilder.java
helix-core/src/main/java/org/apache/helix/model/builder/StateTransitionTableBuilder.java
helix-core/src/main/java/org/apache/helix/monitoring/ParticipantMonitor.java
helix-core/src/main/java/org/apache/helix/monitoring/SensorNameProvider.java
helix-core/src/main/java/org/apache/helix/monitoring/StatCollector.java
helix-core/src/main/java/org/apache/helix/monitoring/StateTransitionContext.java
helix-core/src/main/java/org/apache/helix/monitoring/StateTransitionDataPoint.java
helix-core/src/main/java/org/apache/helix/monitoring/ZKPathDataDumpTask.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/ClusterAlertItem.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/ClusterAlertItemMBean.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/ClusterAlertMBeanCollection.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/ClusterMBeanObserver.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/ClusterStatusMonitor.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/ClusterStatusMonitorMBean.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/HelixStageLatencyMonitor.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/HelixStageLatencyMonitorMBean.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/MessageQueueMonitor.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/MessageQueueMonitorMBean.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/ResourceMonitor.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/ResourceMonitorMBean.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/StateTransitionStatMonitor.java
helix-core/src/main/java/org/apache/helix/monitoring/mbeans/StateTransitionStatMonitorMBean.java
helix-core/src/main/java/org/apache/helix/package-info.java
helix-core/src/main/java/org/apache/helix/participant/CustomCodeCallbackHandler.java
helix-core/src/main/java/org/apache/helix/participant/CustomCodeInvoker.java
helix-core/src/main/java/org/apache/helix/participant/DistClusterControllerElection.java
helix-core/src/main/java/org/apache/helix/participant/DistClusterControllerStateModel.java
helix-core/src/main/java/org/apache/helix/participant/DistClusterControllerStateModelFactory.java
helix-core/src/main/java/org/apache/helix/participant/GenericLeaderStandbyModel.java
helix-core/src/main/java/org/apache/helix/participant/GenericLeaderStandbyStateModelFactory.java
helix-core/src/main/java/org/apache/helix/participant/HelixCustomCodeRunner.java
helix-core/src/main/java/org/apache/helix/participant/HelixStateMachineEngine.java
helix-core/src/main/java/org/apache/helix/participant/StateMachineEngine.java
helix-core/src/main/java/org/apache/helix/participant/statemachine/ScheduledTaskStateModel.java
helix-core/src/main/java/org/apache/helix/participant/statemachine/ScheduledTaskStateModelFactory.java
helix-core/src/main/java/org/apache/helix/participant/statemachine/StateModel.java
helix-core/src/main/java/org/apache/helix/participant/statemachine/StateModelFactory.java
helix-core/src/main/java/org/apache/helix/participant/statemachine/StateModelInfo.java
helix-core/src/main/java/org/apache/helix/participant/statemachine/StateModelParser.java
helix-core/src/main/java/org/apache/helix/participant/statemachine/StateTransitionError.java
helix-core/src/main/java/org/apache/helix/participant/statemachine/Transition.java
helix-core/src/main/java/org/apache/helix/spectator/RoutingTableProvider.java
helix-core/src/main/java/org/apache/helix/store/HelixPropertyListener.java
helix-core/src/main/java/org/apache/helix/store/HelixPropertyStore.java
helix-core/src/main/java/org/apache/helix/store/PropertyChangeListener.java
helix-core/src/main/java/org/apache/helix/store/PropertyJsonComparator.java
helix-core/src/main/java/org/apache/helix/store/PropertyJsonSerializer.java
helix-core/src/main/java/org/apache/helix/store/PropertySerializer.java
helix-core/src/main/java/org/apache/helix/store/PropertyStat.java
helix-core/src/main/java/org/apache/helix/store/PropertyStoreException.java
helix-core/src/main/java/org/apache/helix/store/ZNRecordJsonSerializer.java
helix-core/src/main/java/org/apache/helix/store/zk/PropertyItem.java
helix-core/src/main/java/org/apache/helix/store/zk/ZNode.java
helix-core/src/main/java/org/apache/helix/store/zk/ZkHelixPropertyStore.java
helix-core/src/main/java/org/apache/helix/store/zk/ZkListener.java
helix-core/src/main/java/org/apache/helix/tools/CLMLogFileAppender.java
helix-core/src/main/java/org/apache/helix/tools/ClusterSetup.java
helix-core/src/main/java/org/apache/helix/tools/ClusterStateVerifier.java
helix-core/src/main/java/org/apache/helix/tools/DefaultIdealStateCalculator.java
helix-core/src/main/java/org/apache/helix/tools/IdealCalculatorByConsistentHashing.java
helix-core/src/main/java/org/apache/helix/tools/IdealStateCalculatorByRush.java
helix-core/src/main/java/org/apache/helix/tools/IdealStateCalculatorByShuffling.java
helix-core/src/main/java/org/apache/helix/tools/IdealStateCalculatorForEspressoRelay.java
helix-core/src/main/java/org/apache/helix/tools/JmxDumper.java
helix-core/src/main/java/org/apache/helix/tools/LocalZKServer.java
helix-core/src/main/java/org/apache/helix/tools/MessagePoster.java
helix-core/src/main/java/org/apache/helix/tools/RUSHrHash.java
helix-core/src/main/java/org/apache/helix/tools/StateModelConfigGenerator.java
helix-core/src/main/java/org/apache/helix/tools/TestCommand.java
helix-core/src/main/java/org/apache/helix/tools/TestExecutor.java
helix-core/src/main/java/org/apache/helix/tools/TestTrigger.java
helix-core/src/main/java/org/apache/helix/tools/YAISCalculator.java
helix-core/src/main/java/org/apache/helix/tools/ZKDumper.java
helix-core/src/main/java/org/apache/helix/tools/ZKLogFormatter.java
helix-core/src/main/java/org/apache/helix/tools/ZkLogAnalyzer.java
helix-core/src/main/java/org/apache/helix/tools/ZkLogCSVFormatter.java
helix-core/src/main/java/org/apache/helix/tools/ZnodeOpArg.java
helix-core/src/main/java/org/apache/helix/tools/ZnodeValue.java
helix-core/src/main/java/org/apache/helix/util/HelixUtil.java
helix-core/src/main/java/org/apache/helix/util/PathUtils.java
helix-core/src/main/java/org/apache/helix/util/RebalanceUtil.java
helix-core/src/main/java/org/apache/helix/util/StatusUpdateUtil.java
helix-core/src/main/java/org/apache/helix/util/StringTemplate.java
helix-core/src/main/java/org/apache/helix/util/ZKClientPool.java
helix-core/src/main/java/org/apache/helix/util/ZNRecordUtil.java
helix-core/src/test/java/org/apache/helix/DummyProcessThread.java
helix-core/src/test/java/org/apache/helix/Mocks.java
helix-core/src/test/java/org/apache/helix/ScriptTestHelper.java
helix-core/src/test/java/org/apache/helix/TestConfigAccessor.java
helix-core/src/test/java/org/apache/helix/TestEspressoStorageClusterIdealState.java
helix-core/src/test/java/org/apache/helix/TestGetProperty.java
helix-core/src/test/java/org/apache/helix/TestGroupCommit.java
helix-core/src/test/java/org/apache/helix/TestHelixConfigAccessor.java
helix-core/src/test/java/org/apache/helix/TestHelixTaskExecutor.java
helix-core/src/test/java/org/apache/helix/TestHelixTaskHandler.java
helix-core/src/test/java/org/apache/helix/TestHelper.java
helix-core/src/test/java/org/apache/helix/TestHierarchicalDataStore.java
helix-core/src/test/java/org/apache/helix/TestListenerCallback.java
helix-core/src/test/java/org/apache/helix/TestParticipantHealthReportCollectorImpl.java
helix-core/src/test/java/org/apache/helix/TestPerfCounters.java
helix-core/src/test/java/org/apache/helix/TestPerformanceHealthReportProvider.java
helix-core/src/test/java/org/apache/helix/TestPropertyPathConfig.java
helix-core/src/test/java/org/apache/helix/TestRelayIdealStateCalculator.java
helix-core/src/test/java/org/apache/helix/TestRoutingTable.java
helix-core/src/test/java/org/apache/helix/TestShuffledIdealState.java
helix-core/src/test/java/org/apache/helix/TestZKCallback.java
helix-core/src/test/java/org/apache/helix/TestZKRoutingInfoProvider.java
helix-core/src/test/java/org/apache/helix/TestZNRecord.java
helix-core/src/test/java/org/apache/helix/TestZNRecordBucketizer.java
helix-core/src/test/java/org/apache/helix/TestZkBasis.java
helix-core/src/test/java/org/apache/helix/TestZkClientWrapper.java
helix-core/src/test/java/org/apache/helix/TestZkConnectionCount.java
helix-core/src/test/java/org/apache/helix/TestZnodeModify.java
helix-core/src/test/java/org/apache/helix/ZkHelixTestManager.java
helix-core/src/test/java/org/apache/helix/ZkTestHelper.java
helix-core/src/test/java/org/apache/helix/ZkUnitTestBase.java
helix-core/src/test/java/org/apache/helix/alerts/TestAddAlerts.java
helix-core/src/test/java/org/apache/helix/alerts/TestAddPersistentStats.java
helix-core/src/test/java/org/apache/helix/alerts/TestAlertValidation.java
helix-core/src/test/java/org/apache/helix/alerts/TestArrivingParticipantStats.java
helix-core/src/test/java/org/apache/helix/alerts/TestBaseStatsValidation.java
helix-core/src/test/java/org/apache/helix/alerts/TestEvaluateAlerts.java
helix-core/src/test/java/org/apache/helix/alerts/TestOperators.java
helix-core/src/test/java/org/apache/helix/alerts/TestStatsMatch.java
helix-core/src/test/java/org/apache/helix/controller/stages/BaseStageTest.java
helix-core/src/test/java/org/apache/helix/controller/stages/DummyClusterManager.java
helix-core/src/test/java/org/apache/helix/controller/stages/TestBestPossibleCalcStageCompatibility.java
helix-core/src/test/java/org/apache/helix/controller/stages/TestBestPossibleStateCalcStage.java
helix-core/src/test/java/org/apache/helix/controller/stages/TestClusterEvent.java
helix-core/src/test/java/org/apache/helix/controller/stages/TestCompatibilityCheckStage.java
helix-core/src/test/java/org/apache/helix/controller/stages/TestCurrentStateComputationStage.java
helix-core/src/test/java/org/apache/helix/controller/stages/TestMessageThrottleStage.java
helix-core/src/test/java/org/apache/helix/controller/stages/TestMsgSelectionStage.java
helix-core/src/test/java/org/apache/helix/controller/stages/TestParseInfoFromAlert.java
helix-core/src/test/java/org/apache/helix/controller/stages/TestRebalancePipeline.java
helix-core/src/test/java/org/apache/helix/controller/stages/TestResourceComputationStage.java
helix-core/src/test/java/org/apache/helix/controller/strategy/TestAutoRebalanceStrategy.java
helix-core/src/test/java/org/apache/helix/healthcheck/TestAddDropAlert.java
helix-core/src/test/java/org/apache/helix/healthcheck/TestAlertActionTriggering.java
helix-core/src/test/java/org/apache/helix/healthcheck/TestAlertFireHistory.java
helix-core/src/test/java/org/apache/helix/healthcheck/TestDummyAlerts.java
helix-core/src/test/java/org/apache/helix/healthcheck/TestExpandAlert.java
helix-core/src/test/java/org/apache/helix/healthcheck/TestSimpleAlert.java
helix-core/src/test/java/org/apache/helix/healthcheck/TestSimpleWildcardAlert.java
helix-core/src/test/java/org/apache/helix/healthcheck/TestStalenessAlert.java
helix-core/src/test/java/org/apache/helix/healthcheck/TestWildcardAlert.java
helix-core/src/test/java/org/apache/helix/integration/IntegrationTest.java
helix-core/src/test/java/org/apache/helix/integration/TestAddClusterV2.java
helix-core/src/test/java/org/apache/helix/integration/TestAddNodeAfterControllerStart.java
helix-core/src/test/java/org/apache/helix/integration/TestAddStateModelFactoryAfterConnect.java
helix-core/src/test/java/org/apache/helix/integration/TestAutoIsWithEmptyMap.java
helix-core/src/test/java/org/apache/helix/integration/TestAutoRebalance.java
helix-core/src/test/java/org/apache/helix/integration/TestAutoRebalancePartitionLimit.java
helix-core/src/test/java/org/apache/helix/integration/TestBasicSpectator.java
helix-core/src/test/java/org/apache/helix/integration/TestBatchMessage.java
helix-core/src/test/java/org/apache/helix/integration/TestBatchMessageWrapper.java
helix-core/src/test/java/org/apache/helix/integration/TestBucketizedResource.java
helix-core/src/test/java/org/apache/helix/integration/TestCMWithFailParticipant.java
helix-core/src/test/java/org/apache/helix/integration/TestCarryOverBadCurState.java
helix-core/src/test/java/org/apache/helix/integration/TestCleanupExternalView.java
helix-core/src/test/java/org/apache/helix/integration/TestClusterStartsup.java
helix-core/src/test/java/org/apache/helix/integration/TestCustomIdealState.java
helix-core/src/test/java/org/apache/helix/integration/TestCustomizedIdealStateRebalancer.java
helix-core/src/test/java/org/apache/helix/integration/TestDisable.java
helix-core/src/test/java/org/apache/helix/integration/TestDisableNode.java
helix-core/src/test/java/org/apache/helix/integration/TestDisablePartition.java
helix-core/src/test/java/org/apache/helix/integration/TestDistributedCMMain.java
helix-core/src/test/java/org/apache/helix/integration/TestDistributedClusterController.java
helix-core/src/test/java/org/apache/helix/integration/TestDriver.java
helix-core/src/test/java/org/apache/helix/integration/TestDrop.java
helix-core/src/test/java/org/apache/helix/integration/TestDropResource.java
helix-core/src/test/java/org/apache/helix/integration/TestEnablePartitionDuringDisable.java
helix-core/src/test/java/org/apache/helix/integration/TestErrorPartition.java
helix-core/src/test/java/org/apache/helix/integration/TestExpandCluster.java
helix-core/src/test/java/org/apache/helix/integration/TestExternalCmd.java
helix-core/src/test/java/org/apache/helix/integration/TestExternalViewUpdates.java
helix-core/src/test/java/org/apache/helix/integration/TestFailOverPerf1kp.java
helix-core/src/test/java/org/apache/helix/integration/TestHelixCustomCodeRunner.java
helix-core/src/test/java/org/apache/helix/integration/TestHelixInstanceTag.java
helix-core/src/test/java/org/apache/helix/integration/TestHelixUsingDifferentParams.java
helix-core/src/test/java/org/apache/helix/integration/TestInstanceAutoJoin.java
helix-core/src/test/java/org/apache/helix/integration/TestInvalidAutoIdealState.java
helix-core/src/test/java/org/apache/helix/integration/TestMessagePartitionStateMismatch.java
helix-core/src/test/java/org/apache/helix/integration/TestMessageThrottle.java
helix-core/src/test/java/org/apache/helix/integration/TestMessageThrottle2.java
helix-core/src/test/java/org/apache/helix/integration/TestMessagingService.java
helix-core/src/test/java/org/apache/helix/integration/TestNonOfflineInitState.java
helix-core/src/test/java/org/apache/helix/integration/TestNullReplica.java
helix-core/src/test/java/org/apache/helix/integration/TestParticipantErrorMessage.java
helix-core/src/test/java/org/apache/helix/integration/TestParticipantNameCollision.java
helix-core/src/test/java/org/apache/helix/integration/TestPauseSignal.java
helix-core/src/test/java/org/apache/helix/integration/TestRenamePartition.java
helix-core/src/test/java/org/apache/helix/integration/TestResetInstance.java
helix-core/src/test/java/org/apache/helix/integration/TestResetPartitionState.java
helix-core/src/test/java/org/apache/helix/integration/TestResetResource.java
helix-core/src/test/java/org/apache/helix/integration/TestRestartParticipant.java
helix-core/src/test/java/org/apache/helix/integration/TestSchedulerMessage.java
helix-core/src/test/java/org/apache/helix/integration/TestSchemataSM.java
helix-core/src/test/java/org/apache/helix/integration/TestSessionExpiryInTransition.java
helix-core/src/test/java/org/apache/helix/integration/TestStandAloneCMMain.java
helix-core/src/test/java/org/apache/helix/integration/TestStandAloneCMSessionExpiry.java
helix-core/src/test/java/org/apache/helix/integration/TestStartMultipleControllersWithSameName.java
helix-core/src/test/java/org/apache/helix/integration/TestStateTransitionTimeout.java
helix-core/src/test/java/org/apache/helix/integration/TestStatusUpdate.java
helix-core/src/test/java/org/apache/helix/integration/TestSwapInstance.java
helix-core/src/test/java/org/apache/helix/integration/TestZkCallbackHandlerLeak.java
helix-core/src/test/java/org/apache/helix/integration/TestZkReconnect.java
helix-core/src/test/java/org/apache/helix/integration/ZkIntegrationTestBase.java
helix-core/src/test/java/org/apache/helix/integration/ZkStandAloneCMTestBase.java
helix-core/src/test/java/org/apache/helix/integration/ZkStandAloneCMTestBaseWithPropertyServerCheck.java
helix-core/src/test/java/org/apache/helix/integration/manager/ClusterControllerManager.java
helix-core/src/test/java/org/apache/helix/integration/manager/ClusterDistributedController.java
helix-core/src/test/java/org/apache/helix/integration/manager/MockParticipantManager.java
helix-core/src/test/java/org/apache/helix/integration/manager/TestConsecutiveZkSessionExpiry.java
helix-core/src/test/java/org/apache/helix/integration/manager/TestControllerManager.java
helix-core/src/test/java/org/apache/helix/integration/manager/TestDistributedControllerManager.java
helix-core/src/test/java/org/apache/helix/integration/manager/TestParticipantManager.java
helix-core/src/test/java/org/apache/helix/integration/manager/TestStateModelLeak.java
helix-core/src/test/java/org/apache/helix/integration/manager/TestZkCallbackHandlerLeak.java
helix-core/src/test/java/org/apache/helix/integration/manager/ZkTestManager.java
helix-core/src/test/java/org/apache/helix/josql/TestClusterJosqlQueryProcessor.java
helix-core/src/test/java/org/apache/helix/josql/TestJosqlProcessor.java
helix-core/src/test/java/org/apache/helix/manager/MockListener.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestDefaultControllerMsgHandlerFactory.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestHandleNewSession.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestLiveInstanceBounce.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestWtCacheAsyncOpMultiThread.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestWtCacheAsyncOpSingleThread.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestWtCacheSyncOpSingleThread.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestZKLiveInstanceData.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestZKPropertyTransferServer.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestZKUtil.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestZNRecordSizeLimit.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestZkBaseDataAccessor.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestZkCacheAsyncOpSingleThread.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestZkCacheSyncOpSingleThread.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestZkClusterManager.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestZkHelixAdmin.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestZkManagerFlappingDetection.java
helix-core/src/test/java/org/apache/helix/manager/zk/TestZkStateChangeListener.java
helix-core/src/test/java/org/apache/helix/manager/zk/serializer/TestJacksonPayloadSerializer.java
helix-core/src/test/java/org/apache/helix/messaging/TestAsyncCallback.java
helix-core/src/test/java/org/apache/helix/messaging/TestAsyncCallbackSvc.java
helix-core/src/test/java/org/apache/helix/messaging/TestDefaultMessagingService.java
helix-core/src/test/java/org/apache/helix/messaging/handling/TestConfigThreadpoolSize.java
helix-core/src/test/java/org/apache/helix/messaging/handling/TestHelixTaskExecutor.java
helix-core/src/test/java/org/apache/helix/messaging/handling/TestResourceThreadpoolSize.java
helix-core/src/test/java/org/apache/helix/mock/controller/ClusterController.java
helix-core/src/test/java/org/apache/helix/mock/controller/MockController.java
helix-core/src/test/java/org/apache/helix/mock/controller/MockControllerProcess.java
helix-core/src/test/java/org/apache/helix/mock/participant/DummyProcess.java
helix-core/src/test/java/org/apache/helix/mock/participant/ErrTransition.java
helix-core/src/test/java/org/apache/helix/mock/participant/MockBootstrapModelFactory.java
helix-core/src/test/java/org/apache/helix/mock/participant/MockBootstrapStateModel.java
helix-core/src/test/java/org/apache/helix/mock/participant/MockEspressoHealthReportProvider.java
helix-core/src/test/java/org/apache/helix/mock/participant/MockHealthReportParticipant.java
helix-core/src/test/java/org/apache/helix/mock/participant/MockJobIntf.java
helix-core/src/test/java/org/apache/helix/mock/participant/MockMSModelFactory.java
helix-core/src/test/java/org/apache/helix/mock/participant/MockMSStateModel.java
helix-core/src/test/java/org/apache/helix/mock/participant/MockParticipant.java
helix-core/src/test/java/org/apache/helix/mock/participant/MockSchemataModelFactory.java
helix-core/src/test/java/org/apache/helix/mock/participant/MockSchemataStateModel.java
helix-core/src/test/java/org/apache/helix/mock/participant/MockTransition.java
helix-core/src/test/java/org/apache/helix/mock/participant/SleepTransition.java
helix-core/src/test/java/org/apache/helix/mock/participant/StoreAccessDiffNodeTransition.java
helix-core/src/test/java/org/apache/helix/mock/participant/StoreAccessOneNodeTransition.java
helix-core/src/test/java/org/apache/helix/mock/spectator/MockSpectatorProcess.java
helix-core/src/test/java/org/apache/helix/model/TestConstraint.java
helix-core/src/test/java/org/apache/helix/model/TestIdealState.java
helix-core/src/test/java/org/apache/helix/model/TestInstanceConfig.java
helix-core/src/test/java/org/apache/helix/model/builder/TestIdealStateBuilder.java
helix-core/src/test/java/org/apache/helix/monitoring/TestParticipantMonitor.java
helix-core/src/test/java/org/apache/helix/monitoring/TestStatCollector.java
helix-core/src/test/java/org/apache/helix/monitoring/mbeans/TestClusterAlertItemMBeanCollection.java
helix-core/src/test/java/org/apache/helix/monitoring/mbeans/TestClusterStatusMonitor.java
helix-core/src/test/java/org/apache/helix/monitoring/mbeans/TestResourceMonitor.java
helix-core/src/test/java/org/apache/helix/participant/MockZKHelixManager.java
helix-core/src/test/java/org/apache/helix/participant/TestDistControllerElection.java
helix-core/src/test/java/org/apache/helix/participant/TestDistControllerStateModel.java
helix-core/src/test/java/org/apache/helix/participant/TestDistControllerStateModelFactory.java
helix-core/src/test/java/org/apache/helix/participant/statemachine/TestStateModelParser.java
helix-core/src/test/java/org/apache/helix/store/TestJsonComparator.java
helix-core/src/test/java/org/apache/helix/store/TestPropertyStat.java
helix-core/src/test/java/org/apache/helix/store/TestPropertyStoreException.java
helix-core/src/test/java/org/apache/helix/store/zk/TestZkHelixPropertyStore.java
helix-core/src/test/java/org/apache/helix/tools/TestClusterSetup.java
helix-core/src/test/java/org/apache/helix/tools/TestHelixAdminCli.java
helix-core/src/test/java/org/apache/helix/util/TestZKClientPool.java
helix-style.xml [new file with mode: 0644]
recipes/distributed-lock-manager/src/main/java/org/apache/helix/lockmanager/Lock.java
recipes/distributed-lock-manager/src/main/java/org/apache/helix/lockmanager/LockFactory.java
recipes/distributed-lock-manager/src/main/java/org/apache/helix/lockmanager/LockManagerDemo.java
recipes/distributed-lock-manager/src/main/java/org/apache/helix/lockmanager/LockProcess.java
recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/Consumer.java
recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/ConsumerStateModel.java
recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/ConsumerStateModelFactory.java
recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/ConsumerThread.java
recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/Emitter.java
recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/SetupConsumerCluster.java
recipes/rabbitmq-consumer-group/src/main/java/org/apache/helix/recipes/rabbitmq/StartClusterManager.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/ChangeLog.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/ChangeLogGenerator.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/ChangeLogProcessor.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/ChangeLogReader.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/ChangeRecord.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/CheckpointFile.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/ExternalCommand.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/FileChangeWatcher.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/FileStore.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/FileStoreStateModel.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/FileStoreStateModelFactory.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/FileSystemWatchService.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/IntegrationTest.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/Replicator.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/RsyncDaemon.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/RsyncInvoker.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/SetupCluster.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/StartClusterManager.java
recipes/rsync-replicated-file-system/src/main/java/org/apache/helix/filestore/Test.java
recipes/service-discovery/src/main/java/org/apache/helix/servicediscovery/MyService.java
recipes/service-discovery/src/main/java/org/apache/helix/servicediscovery/ServiceDiscovery.java
recipes/service-discovery/src/main/java/org/apache/helix/servicediscovery/ServiceDiscoveryDemo.java
recipes/service-discovery/src/main/java/org/apache/helix/servicediscovery/ServiceMetadata.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/AnalyticsTaskFactory.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/CountTask.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/Dag.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/FilterTask.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/JoinTask.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/RedisTaskResultStore.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/ReportTask.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/Task.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/TaskCluster.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/TaskExecutionDemo.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/TaskFactory.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/TaskResultStore.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/TaskStateModel.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/TaskStateModelFactory.java
recipes/task-execution/src/main/java/org/apache/helix/taskexecution/Worker.java