pjml.stream.reduce.accumulator.Accumulator¶

class pjml.stream.reduce.accumulator.Accumulator(iterator: Iterator[pjdata.content.data.Data], start: List[Union[List[str], numpy.ndarray]], step_func: Callable[[pjdata.content.data.Data, List[Union[List[str], numpy.ndarray]]], Tuple[pjdata.content.data.Data, List[Union[List[str], numpy.ndarray]]]], summ_func: Callable[[List[Union[List[str], numpy.ndarray]]], Union[List[str], numpy.ndarray]])[source]¶

Cumulative iterator that returns a final/result value.

The enclosed iterator should be finite.

__init__(iterator: Iterator[pjdata.content.data.Data], start: List[Union[List[str], numpy.ndarray]], step_func: Callable[[pjdata.content.data.Data, List[Union[List[str], numpy.ndarray]]], Tuple[pjdata.content.data.Data, List[Union[List[str], numpy.ndarray]]]], summ_func: Callable[[List[Union[List[str], numpy.ndarray]]], Union[List[str], numpy.ndarray]]) → None¶

Methods

__init__(iterator, start, numpy.ndarray]], …)

Attributes

`result`
`stream_exception`