public interface Manager
Interface for workplaces to interact with the global state of computation.
Modifier and Type | Method and Description |
---|---|
io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>> |
globalStatistics()
Returns a read-only view of global statistics map.
|
boolean |
isStopConditionReached() |
void |
postStatistics(long id,
io.vavr.collection.Map<java.lang.Object,java.lang.Object> statistics)
Posts provided statistics globally, mapping them to the workplace ID.
|
<T> io.vavr.collection.Seq<T> |
statisticsForKey(java.lang.Object key,
java.lang.Class<T> valuesClass) |
void postStatistics(long id, io.vavr.collection.Map<java.lang.Object,java.lang.Object> statistics)
Posts provided statistics globally, mapping them to the workplace ID.
id
- workplace idstatistics
- statistics as a mapio.vavr.collection.Map<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>> globalStatistics()
Returns a read-only view of global statistics map.
<T> io.vavr.collection.Seq<T> statisticsForKey(java.lang.Object key, java.lang.Class<T> valuesClass)
boolean isStopConditionReached()