CollectionMapper currently delegates forEach method to the stream instead of the underlying collection. This can cause issues since stream serializes the function across to be executed on all nodes. This should instead delegate to the actualCollection to allow for local operation.