[MAHOUT-1736] H20 implementation for allreduceBlock

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.1
• Fix Version/s: 0.10.2
• Epic Link: Samsara-framework
• Sprint: Jul-2015
• Assignee: Anand Avati
• Reporter: Dmitriy Lyubimov
• Created: 10/Jun/15 22:20
• Updated: 07/Aug/15 15:56
• Resolved: 24/Jun/15 18:34

Description

allreduce aggregator on matrix blocks:

 override def allreduceBlock[K: ClassTag](drm: CheckpointedDrm[K], bmf: BlockMapFunc2[K], rf: BlockReduceFunc)
  : Matrix = ???

This is pretty important for custom aggregated statistics