Package park :: Package optim :: Module pmap :: Class Collector

Class Collector

source code

Abstract interface to map-reduce accumulator function.

Instance Methods

__call__(self, part)
Receive next part, storing it in the accumulated result

source code

finalize(self)
Called when all parts have been accumulated

source code

error(self, part, msg)
Exception seen on executing map or reduce.

source code

Inherited from object: __delattr__, __getattribute__, __hash__, __init__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __str__

Properties
Inherited from `object`: `__class__`

Method Details

error(self, part, msg)

source code

Exception seen on executing map or reduce. The collector can adjust the accumulated result appropriately to reflect the error.