Package com.scivicslab.pojoactor.core.accumulator

Class BufferedAccumulator

java.lang.Object

com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator

All Implemented Interfaces:

Accumulator

public class BufferedAccumulator
extends Object
implements Accumulator

An accumulator that buffers results and outputs them on getSummary().

This accumulator collects all results in memory and returns them grouped by source when getSummary() is called. This is useful for batch processing and report generation.

Example Output

 === Execution Results ===

 [node-localhost]
   cpu: AMD Ryzen 7 7700 8-Core Processor
   gpu: NVIDIA GeForce RTX 4080
   memory: 62Gi
 

Since:

2.8.0

Author:

devteam@scivics-lab.com

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	BufferedAccumulator.ResultEntry	A single result entry.

Constructor Summary

Constructors

Constructor	Description
BufferedAccumulator()

Method Summary

Modifier and Type	Method	Description
void	add(String source, String type, String data)	Adds a result to this accumulator.
void	clear()	Clears all accumulated results.
int	getCount()	Returns the number of results that have been added.
List<BufferedAccumulator.ResultEntry>	getResults()	Returns an unmodifiable list of all result entries.
String	getSummary()	Returns a formatted summary of all accumulated results.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BufferedAccumulator

public BufferedAccumulator()

Method Details

add

public void add(String source,
 String type,
 String data)

Description copied from interface: Accumulator

Adds a result to this accumulator.

Specified by:

add in interface Accumulator

Parameters:

source - the source identifier (e.g., actor name like "node-localhost")

type - the type of result (e.g., "cpu", "memory", "error")

data - the result data as a string

getSummary

public String getSummary()

Description copied from interface: Accumulator

Returns a formatted summary of all accumulated results.

The format of the summary depends on the implementation. For example, StreamingAccumulator returns a simple count, while BufferedAccumulator returns all results grouped by source.

Specified by:

getSummary in interface Accumulator

Returns:

the formatted summary string

getCount

public int getCount()

Description copied from interface: Accumulator

Returns the number of results that have been added.

Specified by:

getCount in interface Accumulator

Returns:

the count of added results

clear

public void clear()

Description copied from interface: Accumulator

Clears all accumulated results.

After calling this method, the accumulator should be in its initial state, as if no results had been added.

Specified by:

clear in interface Accumulator

getResults

public List<BufferedAccumulator.ResultEntry> getResults()

Returns an unmodifiable list of all result entries.

Returns:

the list of result entries