Package org.apache.storm.daemon.worker
Class Worker
java.lang.Object
org.apache.storm.daemon.worker.Worker
- All Implemented Interfaces:
- DaemonCommon,- Shutdownable
- 
Constructor SummaryConstructorsConstructorDescriptionWorker(Map<String, Object> conf, IContext context, String topologyId, String assignmentId, int supervisorPort, int port, String workerId) Worker(Map<String, Object> conf, IContext context, String topologyId, String assignmentId, int supervisorPort, int port, String workerId, Supplier<SupervisorIfaceFactory> supervisorIfaceSupplier) TODO: should worker even take the topologyId as input? this should be deducible from cluster state (by searching through assignments) what about if there's inconsistency in assignments? -> but nimbus should guarantee this consistency.
- 
Method Summary
- 
Constructor Details- 
Workerpublic Worker(Map<String, Object> conf, IContext context, String topologyId, String assignmentId, int supervisorPort, int port, String workerId, Supplier<SupervisorIfaceFactory> supervisorIfaceSupplier) throws IOExceptionTODO: should worker even take the topologyId as input? this should be deducible from cluster state (by searching through assignments) what about if there's inconsistency in assignments? -> but nimbus should guarantee this consistency.- Parameters:
- conf- - Storm configuration
- context- -
- topologyId- - topology id
- assignmentId- - assignment id
- supervisorPort- - parent supervisor thrift server port
- port- - port on which the worker runs
- workerId- - worker id
- Throws:
- IOException
 
- 
Workerpublic Worker(Map<String, Object> conf, IContext context, String topologyId, String assignmentId, int supervisorPort, int port, String workerId) throws IOException- Throws:
- IOException
 
 
- 
- 
Method Details- 
main- Throws:
- Exception
 
- 
start- Throws:
- Exception
 
- 
doRefreshLoadpublic void doRefreshLoad()
- 
doHeartBeat- Throws:
- IOException
 
- 
doExecutorHeartbeatspublic void doExecutorHeartbeats()
- 
getCurrentBlobVersions- Throws:
- IOException
 
- 
updateBlobUpdates- Throws:
- IOException
 
- 
checkCredentialsChangedpublic void checkCredentialsChanged()
- 
checkLogConfigChangedpublic void checkLogConfigChanged()
- 
establishLogSettingCallbackpublic void establishLogSettingCallback()
- 
shutdownpublic void shutdown()- Specified by:
- shutdownin interface- Shutdownable
 
- 
isWaitingpublic boolean isWaiting()- Specified by:
- isWaitingin interface- DaemonCommon
 
 
-