-
Slot(AsyncLocalizer localizer,
Map<String,Object> conf,
ContainerLauncher containerLauncher,
String host,
int port,
LocalState localState,
IStormClusterState clusterState,
ISupervisor supervisor,
AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments,
OnlyLatestExecutor<Integer> metricsExec,
WorkerMetricsProcessor metricsProcessor,
org.apache.storm.daemon.supervisor.SlotMetrics slotMetrics)
-
class
Implementation of WorkerMetricsProcessor that sends metric data to Nimbus for processing.
Configures metric processor (running on supervisor) to use the class specified in the conf.