Package | Description |
---|---|
org.apache.storm.daemon | |
org.apache.storm.daemon.worker | |
org.apache.storm.executor | |
org.apache.storm.grouping |
Modifier and Type | Method and Description |
---|---|
void |
GrouperFactory.BasicLoadAwareCustomStreamGrouping.refreshLoad(LoadMapping loadMapping) |
Modifier and Type | Method and Description |
---|---|
LoadMapping |
WorkerState.getLoadMapping() |
Modifier and Type | Method and Description |
---|---|
void |
IRunningExecutor.loadChanged(LoadMapping loadMapping) |
void |
ExecutorShutdown.loadChanged(LoadMapping loadMapping) |
void |
Executor.reflectNewLoadMapping(LoadMapping loadMapping) |
Modifier and Type | Method and Description |
---|---|
void |
LoadAwareShuffleGrouping.refreshLoad(LoadMapping loadMapping) |
void |
LoadAwareCustomStreamGrouping.refreshLoad(LoadMapping loadMapping) |
Copyright © 2019 The Apache Software Foundation. All rights reserved.