Package org.apache.storm.nimbus
package org.apache.storm.nimbus
-
ClassDescriptionA service for distributing master assignments to supervisors, this service makes the assignments notification asynchronous.The interface for leader election.A plugin interface that gets invoked any time there is an action for a topology.Interface for strategy to recover heartbeats when master gains leadership.A callback function when nimbus gains leadership.Test for nimbus heartbeats max throughput, This is a client to collect the statistics.Wait for a node to report worker heartbeats until a configured timeout.Factory class for recovery strategy.