Package | Description |
---|---|
org.apache.storm.daemon.worker | |
org.apache.storm.utils |
Constructor and Description |
---|
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.
|
WorkerState(Map<String,Object> conf,
IContext mqContext,
String topologyId,
String assignmentId,
Supplier<SupervisorIfaceFactory> supervisorIfaceSupplier,
int port,
String workerId,
Map<String,Object> topologyConf,
IStateStorage stateStorage,
IStormClusterState stormClusterState,
Collection<IAutoCredentials> autoCredentials,
StormMetricRegistry metricRegistry,
Credentials initialCredentials) |
Modifier and Type | Class and Description |
---|---|
class |
SupervisorClient
Client for interacting with Supervisor server, now we use supervisor server mainly for cases below.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.