Uses of Interface
org.apache.storm.messaging.IContext
Package
Description
-
Uses of IContext in org.apache.storm.daemon.supervisor
Modifier and TypeMethodDescriptionstatic ContainerLauncher
ContainerLauncher.make
(Map<String, Object> conf, String supervisorId, int supervisorPort, IContext sharedContext, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker, Supervisor.Iface localSupervisor) Factory to create the right container launcher for the config and the environment.ModifierConstructorDescriptionLocalContainer
(Map<String, Object> conf, String supervisorId, int supervisorPort, int port, LocalAssignment assignment, IContext sharedContext, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker, Supervisor.Iface localSupervisor) LocalContainerLauncher
(Map<String, Object> conf, String supervisorId, int supervisorPort, IContext sharedContext, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker, Supervisor.Iface localSupervisor) Supervisor
(Map<String, Object> conf, IContext sharedContext, ISupervisor iSupervisor, StormMetricsRegistry metricsRegistry) Constructor for supervisor daemon. -
Uses of IContext in org.apache.storm.daemon.worker
ModifierConstructorDescriptionWorker
(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?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) -
Uses of IContext in org.apache.storm.messaging
Modifier and TypeMethodDescriptionstatic IContext
TransportFactory.makeContext
(Map<String, Object> topoConf, StormMetricRegistry metricRegistry) -
Uses of IContext in org.apache.storm.messaging.local
-
Uses of IContext in org.apache.storm.messaging.netty