Apache Helix
Package Index
|
Class Index
org.apache.helix
org.apache.helix.agent
org.apache.helix.alerts
org.apache.helix.api
org.apache.helix.api.accessor
org.apache.helix.api.config
org.apache.helix.api.id
org.apache.helix.controller
org.apache.helix.controller.context
org.apache.helix.controller.pipeline
org.apache.helix.controller.rebalancer
org.apache.helix.controller.rebalancer.config
org.apache.helix.controller.rebalancer.util
org.apache.helix.controller.restlet
org.apache.helix.controller.serializer
org.apache.helix.controller.stages
org.apache.helix.controller.strategy
org.apache.helix.examples
org.apache.helix.filestore
org.apache.helix.healthcheck
org.apache.helix.lock
org.apache.helix.lock.zk
org.apache.helix.lockmanager
org.apache.helix.manager.zk
org.apache.helix.manager.zk.serializer
org.apache.helix.messaging
org.apache.helix.messaging.handling
org.apache.helix.model
org.apache.helix.model.builder
org.apache.helix.model.util
org.apache.helix.monitoring
org.apache.helix.monitoring.mbeans
org.apache.helix.participant
org.apache.helix.participant.statemachine
org.apache.helix.recipes.rabbitmq
org.apache.helix.servicediscovery
org.apache.helix.spectator
org.apache.helix.store
org.apache.helix.store.zk
org.apache.helix.taskexecution
org.apache.helix.tools
org.apache.helix.userdefinedrebalancer
org.apache.helix.util
org.apache.helix.webapp
org.apache.helix.webapp.resources
Classes
BestPossibleStateCalcStage
BestPossibleStateOutput
ClusterDataCache
ClusterEvent
CompatibilityCheckStage
CurrentStateComputationStage
CurrentStateOutput
ExternalViewComputeStage
HealthDataCache
MessageGenerationStage
MessageOutput
MessageSelectionStage
MessageSelectionStage.Bounds
MessageThrottleStage
PersistAssignmentStage
PersistContextStage
ReadClusterDataStage
ReadHealthDataStage
ResourceComputationStage
ResourceCurrentState
StatsAggregationStage
TaskAssignmentStage
Enums
AttributeName
Package Index
|
Class Index
Summary:
Ctors
|
Methods
|
Inherited Methods
|
[Expand All]
public class
MessageThrottleStage
extends
AbstractBaseStage
java.lang.Object
↳
org.apache.helix.controller.pipeline.AbstractBaseStage
↳
org.apache.helix.controller.stages.MessageThrottleStage
Summary
Public Constructors
MessageThrottleStage
()
Public Methods
void
process
(
ClusterEvent
event)
Actual callback processing logic
[Expand]
Inherited Methods
From class
org.apache.helix.controller.pipeline.AbstractBaseStage
void
addLatencyToMonitor
(
ClusterEvent
event, long latency)
String
getStageName
()
Get the name of the stage
void
init
(
StageContext
context)
Initialize a stage
void
postProcess
()
Called after process() on each callback
void
preProcess
()
Called before process() on each callback
void
process
(
ClusterEvent
event)
Actual callback processing logic
void
release
()
Destruct a stage
From class
java.lang.Object
Object
clone
()
boolean
equals
(
Object
arg0)
void
finalize
()
final
Class
<?>
getClass
()
int
hashCode
()
final void
notify
()
final void
notifyAll
()
String
toString
()
final void
wait
()
final void
wait
(long arg0, int arg1)
final void
wait
(long arg0)
From interface
org.apache.helix.controller.pipeline.Stage
abstract
String
getStageName
()
Get the name of the stage
abstract void
init
(
StageContext
context)
Initialize a stage
abstract void
postProcess
()
Called after process() on each callback
abstract void
preProcess
()
Called before process() on each callback
abstract void
process
(
ClusterEvent
event)
Actual callback processing logic
abstract void
release
()
Destruct a stage
Public Constructors
public
MessageThrottleStage
()
Public Methods
public void
process
(
ClusterEvent
event)
Actual callback processing logic
Throws
Exception