I
- Input type of Task FarmO
- Output type of Task FarmT
- Type of the parallelized stagepublic class TaskFarmHistoryService<I,O,T extends ITaskFarmDuplicable<I,O>> extends Object
Constructor and Description |
---|
TaskFarmHistoryService(DynamicTaskFarmStage<I,O,T> taskFarmStage)
Create a task farm history service for the specified task farm.
|
Modifier and Type | Method and Description |
---|---|
ThroughputHistory |
getHistory() |
long |
getLastPullThroughputOfPipe(IMonitorablePipe pipe) |
long |
getLastPushThroughputOfPipe(IMonitorablePipe pipe) |
void |
monitorPipes()
Records another throughput sum measurement of all pipes in the task farm of this service.
|
public TaskFarmHistoryService(DynamicTaskFarmStage<I,O,T> taskFarmStage)
taskFarmStage
- specified task farmpublic ThroughputHistory getHistory()
public void monitorPipes()
public long getLastPullThroughputOfPipe(IMonitorablePipe pipe)
pipe
- specified monitorable pipepublic long getLastPushThroughputOfPipe(IMonitorablePipe pipe)
pipe
- specified monitorable pipeCopyright © 2015–2020. All rights reserved.