Class Index

A B C D E F G H I J L M N O P Q R S T W Y Z

A

AbstractBaseStage  
AccessOption  
AccumulateAggregationType  
AccumulateAggregator  
AgentStateModel  
AgentStateModelFactory  
AggregationType  
AggregationTypeFactory  
Aggregator  
Alert  
AlertComparator  
AlertHistory  
AlertParser  
AlertProcessor  
Alerts  
Alerts.AlertsProperty  
AlertsHolder  
AlertStatus  
AlertStatus.AlertsProperty  
AlertValueAndStatus  
AnalyticsTaskFactory  
AsyncCallback  
AsyncCallbackService  
AsyncCallbackService.AsyncCallbackMessageHandler  
AttributeName  
AutoModeISBuilder  
AutoRebalanceModeISBuilder  

B

BaseDataAccessor<T>  
BasicZkSerializer Basic path based serializer which ignores the path and delegates serialization into a regular ZkSerializer  
BatchMessageHandler  
BatchMessageWrapper default implementation of handling start/end of batch messages  
BestPossibleStateCalcStage For partition compute best possible (instance,state) pair based on IdealState,StateModel,LiveInstance  
BestPossibleStateOutput  
BootstrapHandler  
BootstrapHandler.BootstrapStateModel  
BootstrapProcess This process does little more than handling the state transition messages. 
BootstrapProcess.CustomMessageHandlerFactory  
ByteArraySerializer  

C

Cache<T>  
CallbackHandler  
ChainedPathZkSerializer  
ChainedPathZkSerializer.Builder  
ChangeLog  
ChangeLogGenerator  
ChangeLogProcessor Processes the change log and invokes rsync for every change on the remote machine  
ChangeLogReader  
ChangeRecord  
CheckpointFile  
CLMLogFileAppender  
ClusterAlertItem  
ClusterAlertItemMBean  
ClusterAlertMBeanCollection  
ClusterAlertMBeanCollection.ClusterAlertSummaryMBean  
ClusterConstraints  
ClusterConstraints.ConstraintAttribute  
ClusterConstraints.ConstraintType  
ClusterConstraints.ConstraintValue  
ClusterConstraintsBuilder  
ClusterDataCache Reads the data from the cluster using data accessor. 
ClusterEvent  
ClusterJosqlQueryProcessor  
ClusterMBeanObserver  
ClusterMessagingService Provides the ability to
  • Send message to a specific component in the cluster[ participant, controller, Spectator(probably not needed) ]
  • Broadcast message to all participants
  • Send message to instances that hold a specific resource
  • Asynchronous request response api. 
  • ClusterRepresentationUtil  
    ClusterResource  
    ClusterSetup  
    ClustersResource  
    ClusterStateVerifier  
    ClusterStateVerifier.BestPossAndExtViewZkVerifier verifier that verifies best possible state and external view  
    ClusterStateVerifier.MasterNbInExtViewVerifier  
    ClusterStateVerifier.Verifier  
    ClusterStateVerifier.ZkVerifier  
    ClusterStatusMonitor  
    ClusterStatusMonitorMBean  
    CMConnector  
    CommandAttribute  
    CommandConfig  
    CommandConfig.Builder builder for command-config  
    CompatibilityCheckStage controller checks if participant version is compatible  
    ConfigAccessor  
    ConfigChangeListener This interface is deprecated. replaced by InstanceConfigChangeListener  
    ConfigResource  
    ConfigScope This class is deprecated. replaced by HelixConfigScope  
    ConfigScopeBuilder This class is deprecated. replaced by HelixConfigScopeBuilder  
    ConstraintItem  
    ConstraintItemBuilder  
    ConstraintResource  
    Consumer  
    ConsumerStateModel  
    ConsumerStateModelFactory  
    ConsumerThread  
    ControllerChangeListener  
    ControllerResource  
    ControllerStatusUpdateResource  
    CountTask  
    Criteria  
    Criteria.DataSource  
    CriteriaEvaluator  
    CurrentState Current states of partitions in a resource  
    CurrentState.CurrentStateProperty  
    CurrentStateChangeListener  
    CurrentStateComputationStage For each LiveInstances select currentState and message whose sessionId matches sessionId from LiveInstance Get Partition,State for all the resources computed in previous State [ResourceComputationStage]  
    CurrentStateOutput  
    CurrentStateResource  
    CurrentStatesResource  
    CurrentStateUpdate  
    CustomCodeCallbackHandler Callback interface to running custom code on Helix participant manager The custom code will be triggered on user specified cluster changes  
    CustomCodeInvoker  
    CustomModeISBuilder  

    D

    Dag  
    Dag.Node  
    DecayAggregationType  
    DecayAggregator  
    DefaultControllerMessageHandlerFactory  
    DefaultControllerMessageHandlerFactory.DefaultControllerMessageHandler  
    DefaultIdealStateCalculator DefaultIdealStateCalculator tries to optimally allocate master/slave partitions among espresso storage nodes. 
    DefaultMessagingService  
    DefaultParticipantErrorMessageHandlerFactory DefaultParticipantErrorMessageHandlerFactory works on controller side. 
    DefaultParticipantErrorMessageHandlerFactory.ActionOnError  
    DefaultParticipantErrorMessageHandlerFactory.DefaultParticipantErrorMessageHandler  
    DefaultPerfCounters  
    DefaultSchedulerMessageHandlerFactory  
    DefaultSchedulerMessageHandlerFactory.DefaultSchedulerMessageHandler  
    DefaultSchedulerMessageHandlerFactory.SchedulerAsyncCallback  
    DistClusterControllerElection  
    DistClusterControllerStateModel  
    DistClusterControllerStateModelFactory  
    DivideOperator  
    DummyParticipant  
    DummyParticipant.DummyMSModelFactory  
    DummyParticipant.DummyMSStateModel  

    E

    Emitter  
    Error  
    ErrorResource  
    ErrorsResource  
    EspressoResource  
    EspressoStorageMockNode  
    EspressoStorageMockStateModelFactory  
    EspressoStorageMockStateModelFactory.EspressoStorageMockStateModel  
    ExampleHelper  
    ExampleProcess  
    ExpandOperator  
    ExpressionOperatorType  
    ExpressionParser  
    ExternalCommand  
    ExternalCommand  
    ExternalView External view is an aggregation (across all instances) of current states for the partitions in a resource  
    ExternalViewChangeListener  
    ExternalViewComputeStage  
    ExternalViewGenerator  
    ExternalViewResource  

    F

    FileChangeWatcher  
    FileStore  
    FileStoreStateModel  
    FileStoreStateModelFactory  
    FileSystemWatchService  
    FilterTask  
    FnvHashFunction  

    G

    GenericHelixController Cluster Controllers main goal is to keep the cluster state as close as possible to Ideal State. 
    GenericLeaderStandbyModel  
    GenericLeaderStandbyStateModelFactory  
    GreaterAlertComparator  
    GroupCommit  
    GroupMessageHandler  

    H

    HashFunction  
    HealthDataCache  
    HealthReportProvider  
    HealthStat  
    HealthStat.HealthStatProperty  
    HealthStateChangeListener  
    HealthStatsAggregationTask  
    HelixAdmin  
    HelixAdminWebApp  
    HelixAgentMain  
    HelixBatchMessageTask  
    HelixConfigScope config-scope that replaces @link ConfigScope  
    HelixConfigScope.ConfigScopeProperty  
    HelixConfigScopeBuilder config-scope builder that replaces @link ConfigScopeBuilder  
    HelixConstants  
    HelixConstants.ChangeType  
    HelixConstants.ClusterConfigType  
    HelixConstants.StateModelToken  
    HelixControllerMain  
    HelixCustomCodeRunner This provides the ability for users to run a custom code in exactly one process using a LeaderStandBy state model. 
    HelixDataAccessor Interface used to interact with Helix Data Types like IdealState, Config, LiveInstance, Message, ExternalView etc PropertyKey represent the HelixData type. 
    HelixDefinedState helix defined states ERROR : when errors happen during state transitions, transit to ERROR state participant will also invoke state-model.on-err(), ignore errors in state-model.on-err() when drop resource in ERROR state and not disabled, controller sends ERROR->DROPPED transition if errors happen in ERROR->DROPPED transition, participant will disable resource/partition when disable resource/partition in ERROR state, resource/partition will be marked disabled but controller not send any transitions when reset resource/partition in ERROR state and not disabled controller send ERROR->initial-state transition if errors happen in ERROR->initial-state transition, remain in ERROR state DROPPED : when drop resource in a non-ERROR state and not disabled controller sends all the transitions from current-state to initial-state then sends initial-state->DROPPED transition 
    HelixException  
    HelixGroupCommit<T>  
    HelixManager Class that represents the Helix Agent. 
    HelixManagerFactory  
    HelixManagerProperties hold helix-manager properties read from helix-core/src/main/resources/cluster-manager.properties  
    HelixProperty A wrapper class for ZNRecord. 
    HelixProperty.HelixPropertyAttribute  
    HelixPropertyListener  
    HelixPropertyStore<T>  
    HelixStageLatencyMonitor  
    HelixStageLatencyMonitorMBean  
    HelixStateMachineEngine  
    HelixStateTransitionHandler  
    HelixStateTransitionHandler.HelixStateMismatchException  
    HelixTask  
    HelixTaskExecutor  
    HelixTaskResult  
    HelixTimerTask  
    HelixUtil  
    HierarchicalDataHolder<T> Generic class that will read the data given the root path. 

    I

    IdealCalculatorByConsistentHashing  
    IdealCalculatorByConsistentHashing.FnvHash The default string hash function. 
    IdealCalculatorByConsistentHashing.HashFunction Interface to calculate the hash function value of a string  
    IdealState The ideal states of all partition in a resource  
    IdealState.IdealStateModeProperty  
    IdealState.IdealStateProperty  
    IdealStateBuilder  
    IdealStateBuilderExample  
    IdealStateCalculatorByRush  
    IdealStateCalculatorByShuffling  
    IdealStateCalculatorForEspressoRelay  
    IdealStateChangeListener  
    IdealStateExample Ideal state json format file used in this example for CUSTOMIZED ideal state mode

     {
     "id" : "TestDB",
     "mapFields" : {
       "TestDB_0" : {
         "localhost_12918" : "MASTER",
         "localhost_12919" : "SLAVE",
         "localhost_12920" : "SLAVE"
       },
       "TestDB_1" : {
         "localhost_12918" : "MASTER",
         "localhost_12919" : "SLAVE",
         "localhost_12920" : "SLAVE"
       },
       "TestDB_2" : {
         "localhost_12918" : "MASTER",
         "localhost_12919" : "SLAVE",
         "localhost_12920" : "SLAVE"
       },
       "TestDB_3" : {
         "localhost_12918" : "MASTER",
         "localhost_12919" : "SLAVE",
         "localhost_12920" : "SLAVE"
       }
     },
     "listFields" : {
     },
     "simpleFields" : {
       "IDEAL_STATE_MODE" : "CUSTOMIZED",
       "NUM_PARTITIONS" : "4",
       "REPLICAS" : "3",
       "STATE_MODEL_DEF_REF" : "MasterSlave",
       "STATE_MODEL_FACTORY_NAME" : "DEFAULT"
     }
     }
     
     
    IdealStateResource  
    InstanceConfig Instance configurations  
    InstanceConfig.InstanceConfigProperty  
    InstanceConfigChangeListener  
    InstanceResource  
    InstancesResource  
    InstanceType CONTROLLER: cluster managing component is a controller PARTICIPANT: participate in the cluster state changes SPECTATOR: interested in the state changes in the cluster CONTROLLER_PARTICIPANT: special participant that competes for the leader of CONTROLLER_CLUSTER used in cluster controller of distributed mode {@HelixControllerMain }  
    IntegrationTest  

    J

    JmxDumper  
    JoinTask  
    JsonParameters  

    L

    LeaderHistory  
    LeaderStandbyStateModelFactory  
    LeaderStandbyStateModelFactory.LeaderStandbyStateModel  
    LiveInstance Instance that connects to zookeeper  
    LiveInstance.LiveInstanceProperty  
    LiveInstanceChangeListener  
    LiveInstanceInfoProvider  
    LocalZKServer Provides ability to start zookeeper locally on a particular port  
    Lock  
    LockFactory  
    LockManagerDemo  
    LockProcess  

    M

    MasterSlaveStateModelFactory  
    MasterSlaveStateModelFactory.MasterSlaveStateModel  
    Message  
    Message.Attributes  
    Message.MessageState  
    Message.MessageType  
    MessageGenerationOutput  
    MessageGenerationPhase Compares the currentState, pendingState with IdealState and generate messages  
    MessageHandler Provides the base class for all message handlers. 
    MessageHandler.ErrorCode  
    MessageHandler.ErrorType  
    MessageHandlerFactory  
    MessageListener  
    MessagePoster  
    MessageQueueMonitor  
    MessageQueueMonitorMBean  
    MessageSelectionStage  
    MessageSelectionStage.Bounds  
    MessageSelectionStageOutput  
    MessageTask  
    MessageTaskInfo  
    MessageThrottleStage  
    MessageThrottleStageOutput  
    MessageTimeoutTask  
    MockEspressoService  
    MockNode  
    MockNodeFactory  
    MockRunner Hello world!  
    MultiplyOperator  
    MyService  

    N

    NotificationContext  
    NotificationContext.MapKey  
    NotificationContext.Type  

    O

    OnlineOfflineStateModelFactory  
    OnlineOfflineStateModelFactory.OnlineOfflineStateModel  
    Operator  

    P

    ParticipantHealthReportCollector  
    ParticipantHealthReportCollectorImpl  
    ParticipantMonitor  
    Partition The name of a resource  
    PathBasedZkSerializer  
    PauseSignal  
    PerformanceHealthReportProvider  
    PersistentStats  
    PersistentStats.PersistentStatsProperty  
    Pipeline  
    PipelineRegistry  
    PreConnectCallback  
    ProcessMonitorThread thread for monitoring a pid  
    PropertyChangeListener<T> Callback interface on property changes 
    PropertyItem  
    PropertyJsonComparator<T>  
    PropertyJsonSerializer<T>  
    PropertyKey  
    PropertyKey.Builder  
    PropertyPathConfig  
    PropertySerializer<T> Serializer interface for property store  
    PropertyStat  
    PropertyStoreException This exception class can be used to indicate any exception during operation on the propertystore  
    PropertyType  

    Q

    Quickstart  

    R

    ReadClusterDataStage  
    ReadHealthDataStage  
    RebalanceIdealStateStage Check and invoke custom implementation idealstate rebalancers. 
    Rebalancer Allows one to come up with custom implementation of a rebalancer. 
    RebalanceUtil  
    RedisTaskResultStore  
    Replicator  
    ReportTask  
    Resource A resource contains a set of partitions  
    ResourceAssignment  
    ResourceComputationStage This stage computes all the resources in a cluster. 
    ResourceGroupResource  
    ResourceGroupsResource  
    ResourceMonitor  
    ResourceMonitorMBean  
    RestAdminApplication  
    RoutingTableProvider  
    RsyncDaemon  
    RsyncInvoker  
    RUSHrHash  

    S

    ScheduledTaskStateModel  
    ScheduledTaskStateModelFactory  
    SchedulerTasksResource This resource can be used to send scheduler tasks to the controller. 
    ScopedConfigChangeListener  
    SensorNameProvider  
    ServiceDiscovery  
    ServiceDiscoveryDemo  
    ServiceMetadata  
    SetupCluster  
    SetupConsumerCluster  
    Stage Logically independent unit in processing callbacks for cluster changes  
    StageContext  
    StageException  
    StartClusterManager  
    StartClusterManager  
    Stat  
    Stat  
    StatCollector  
    StateMachineEngine Helix participant manager uses this class to register/remove state model factory State model factory creates state model that handles state transition messages  
    StateModel  
    StateModelConfigGenerator  
    StateModelDefinition Describe the state model  
    StateModelDefinition.Builder  
    StateModelDefinition.StateModelDefinitionProperty  
    StateModelFactory<T extends StateModel>  
    StateModelInfo  
    StateModelParser Finds the method in stateModel to generate  
    StateModelResource  
    StateModelsResource  
    StateTransitionContext  
    StateTransitionDataPoint  
    StateTransitionError  
    StateTransitionStatMonitor  
    StateTransitionStatMonitor.LATENCY_TYPE  
    StateTransitionStatMonitorMBean  
    StateTransitionTableBuilder  
    StatHealthReportProvider  
    StatsAggregationStage For each LiveInstances select currentState and message whose sessionId matches sessionId from LiveInstance Get Partition,State for all the resources computed in previous State [ResourceComputationStage]  
    StatsHolder  
    StatusUpdate  
    StatusUpdateResource  
    StatusUpdatesResource  
    StatusUpdateUtil Util class to create statusUpdates ZK records and error ZK records. 
    StatusUpdateUtil.Level  
    StatusUpdateUtil.StatusUpdateContents  
    StatusUpdateUtil.TaskStatus  
    StatusUpdateUtil.Transition  
    StopServiceResource  
    StringTemplate  
    SumEachOperator  
    SumOperator  
    SystemUtil  
    SystemUtil.ProcessStateCode PROCESS STATE CODES  

    T

    Task  
    TaskAssignmentStage  
    TaskCluster  
    TaskExecutionDemo  
    TaskExecutor  
    TaskFactory  
    TaskResultStore  
    TaskStateModel  
    TaskStateModelFactory  
    Test  
    TestCommand  
    TestCommand.CommandType  
    TestCommand.NodeOpArg  
    TestExecutor a test is structured logically as a list of commands a command has three parts: COMMAND | TRIGGER | ARG'S COMMAND could be: modify, verify, start, stop TRIGGER is optional and consists of start-time, timeout, and expect-value which means the COMMAND is triggered between [start-time, start-time + timeout] and is triggered when the value in concern equals to expect-value ARG's format depends on COMMAND if COMMAND is modify/verify, arg is in form of: in which key is k1 for SIMPLE, k1|index for LIST, and k1|k2 for MAP field if COMMAND is start/stop, arg is a thread handler  
    TestExecutor.ZnodePropertyType SIMPLE: simple field change LIST: list field change MAP: map field change ZNODE: entire znode change  
    TestTrigger  
    Transition  
    Transition  
    Tuple<T>  

    W

    WindowAggregationType  
    WindowAggregator  
    Worker Generic Worker that is a HELIX Participant which on start up joins the cluster and waits for state transitions from Helix. 
    WriteThroughCache<T>  

    Y

    YAISCalculator  

    Z

    ZkAsyncCallbacks  
    ZkBaseDataAccessor<T>  
    ZkCacheBaseDataAccessor<T>  
    ZkCacheEventThread  
    ZkCallbackCache<T>  
    ZkChildResource  
    ZkClient ZKClient does not provide some functionalities, this will be used for quick fixes if any bug found in ZKClient or if we need additional features but can't wait for the new ZkClient jar Ideally we should commit the changes we do here to ZKClient. 
    ZKClientPool  
    ZKDumper Dumps the Zookeeper file structure on to Disk  
    ZKExceptionHandler  
    ZKHelixAdmin  
    ZKHelixDataAccessor  
    ZKHelixManager  
    ZkHelixPropertyStore<T>  
    ZkListener  
    ZkLogAnalyzer  
    ZkLogCSVFormatter  
    ZKLogFormatter  
    ZKPathDataDumpTask  
    ZkPathResource  
    ZkPropertyTransferApplication Restlet application for ZkPropertyTransfer server  
    ZkPropertyTransferClient  
    ZKPropertyTransferServer Controller side restlet server that receives ZNRecordUpdate requests from clients, and batch the ZNRecordUpdate and apply them to zookeeper. 
    ZkStateChangeListener  
    ZKUtil  
    ZNode  
    ZnodeOpArg  
    ZnodeValue  
    ZNRecord Generic Record Format to store data at a Node This can be used to store simpleFields mapFields listFields  
    ZNRecordAssembler  
    ZNRecordBucketizer  
    ZNRecordDelta  
    ZNRecordDelta.MergeOperation  
    ZNRecordJosqlFunctionHandler  
    ZNRecordJsonSerializer  
    ZNRecordRow A Normalized form of ZNRecord  
    ZNRecordSerializer  
    ZNRecordStreamingSerializer  
    ZNRecordUpdate Unit of transfered ZNRecord updates. 
    ZNRecordUpdate.OpCode  
    ZNRecordUpdater  
    ZNRecordUpdateResource REST resource for ZkPropertyTransfer server to receive PUT requests that submits ZNRecordUpdates  
    ZNRecordUtil