public final class StateStatistics extends Object
AbstractStage
.Modifier and Type | Method and Description |
---|---|
static long |
getActiveWaitingTime(AbstractStage stage) |
static List<StateChange> |
getStates(AbstractStage stage)
This method is used to collect the List of States
|
static void |
sendingFailed(AbstractStage stage)
This method is called by Pipes if the sending of the next element needs to be delayed because of full Queue.
|
static void |
sendingSucceeded(AbstractStage stage)
This method is called when the element is successfully added to the Pipe.
|
public static List<StateChange> getStates(AbstractStage stage)
public static void sendingFailed(AbstractStage stage)
public static void sendingSucceeded(AbstractStage stage)
public static long getActiveWaitingTime(AbstractStage stage)
stage
- Copyright © 2015–2020. All rights reserved.