I've got a situation in which I want to run a streaming expression across the cluster, but the actual effect is to join docs exclusively within a core, and update that same core with the merger of the corresponding documents (a denormalization). Composite id's should keep it all in the same core so in theory this could all be done within a node, but I haven't found a way to either
1.) Send an expression to a node/core such that it won't run on any other core, and just execute locally. 2.) Tell the expression that the whole thing can be pushed down to to the node/core. I'm pondering the possibility of a local() expression that takes an expression as an argument and distributes it to the nodes with a context or parameter that indicates that all operations should be performed within the node i.e. search() expressions would run with distrib=false.... But I've yet to investigate if that's really feasible. So any thoughts on that? Any reasons it wouldn't be a good idea to create something of that sort (hopefully to be contributed, but need to clear that still). -Gus
