-
Notifications
You must be signed in to change notification settings - Fork 0
Message format
Proxy module accepts an array of components like following,
-
insert
[ { "dataset": "Wiki", "outputs": ["report"], "pattern": "scatter", "to": { "key": key, "date": "latest", "replica": "all" }, "body": values }, { "inputs": ["report"], "pattern": "reduction", "outputs": ["summary"], "body": reducer }, { "inputs": ["summary"], "dataset": "Wiki-report", "pattern": "scatter", "to": { "key": key, "date": "latest", "replica": "all" } } ]
-
search
[ { "dataset": "Wiki", "outputs": ["result"], "pattern": "broadcast", "to": { "replica": "random" }, "body": queries }, { "inputs": ["result"], "outputs": ["reduced"], "pattern": "reduction", "body": reducer }, { "inputs": ["reduced"], "pattern": "send", "to": replyTo, "body": finalizer } ]
-
facet_search
[ { "dataset": "Wiki", "outputs": ["main","facet"], "pattern": "broadcast", "to": { "replica": "random" }, "body": queries }, { "input": "main", "output": "main_reduced", "pattern": "reduction", "body": reduce_main }, { "input": "facet", "output": "facet_reduced", "pattern": "reduction", "body": reduce_facet }, { "input": ["main_reduced", "facet_reduced"], "pattern": "send", "to": replyTo, "body": finalizer } ]