Package | Description |
---|---|
org.apache.storm.daemon.worker | |
org.apache.storm.metrics2 | |
org.apache.storm.task | |
org.apache.storm.utils |
Modifier and Type | Method and Description |
---|---|
StormMetricRegistry |
WorkerState.getMetricRegistry() |
Constructor and Description |
---|
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) |
Constructor and Description |
---|
TaskMetrics(WorkerTopologyContext context,
String componentId,
Integer taskid,
StormMetricRegistry metricRegistry) |
Constructor and Description |
---|
TopologyContext(StormTopology topology,
Map<String,Object> topoConf,
Map<Integer,String> taskToComponent,
Map<String,List<Integer>> componentToSortedTasks,
Map<String,Map<String,Fields>> componentToStreamToFields,
Map<String,Long> blobToLastKnownVersionShared,
String stormId,
String codeDir,
String pidDir,
Integer taskId,
Integer workerPort,
List<Integer> workerTasks,
Map<String,Object> defaultResources,
Map<String,Object> userResources,
Map<String,Object> executorData,
Map<Integer,Map<Integer,Map<String,IMetric>>> registeredMetrics,
AtomicBoolean openOrPrepareWasCalled,
StormMetricRegistry metricRegistry) |
Constructor and Description |
---|
JCQueue(String queueName,
int size,
int overflowLimit,
int producerBatchSz,
IWaitStrategy backPressureWaitStrategy,
String topologyId,
String componentId,
Integer taskId,
int port,
StormMetricRegistry metricRegistry) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.