{"shas":[["f69a671049bbc31497ef0d62f8747fb5cd1560c7","a39dbb756d57905e91bf33fc53d0bfa157039f7f@kung-fu-laptop.(none)","Moving to new, simpler interface for distributed processing. Added new method:\n\ndef distDo(distOp: (T, IndexedEmit, DistContext) => Unit, outputs: GenSeq[CollectionId]):GenSeq[DistIterable[Any]]\n\ndistOp processes one element and moves it to 0 or more output collections. Output Collections are untyped but the interface RichDistProcessable contains the strongly typed versions.\n\n Introduced RichDistProcessable interface for simpler versions of distDo and flatten.\n\nWork in progress... Yet to connect new interface with backend.","Vojin Jovanovic"]],"repo":"scala-incubator/distributed-collections","actor":"vjovanovic","ref":"refs/heads/master","size":1,"head":"f69a671049bbc31497ef0d62f8747fb5cd1560c7","actor_gravatar":"3dcbfe479e16ee31dbae3fc84f3c681c","push_id":30162650}