Join

This is used to join two streams on some condition at run time. It selects some attributes from this stream (stream where data is ingested) "iatr" and few from the joining stream "rstm", it also may compute few attributes using "catr" and then send the combined data to the output stream (third one). In the process it may also notify as required.

"join":[
   {
      "name":"myjoin1",
      "type":1,
      "tloc":30,
      "iatr":[
         "a",
         "b",
         "c",
         "e"
      ],
      "rstm":"s2",
      "ratr":[
         "j1",
         "j2",
         "j3"
      ],
      "jqry":{
         "cond":[
            "a",
            "b"
         ],
         "opid":11,
         "opnm":"myrule2",
         "args":[
            "a",
            "b"
         ]
      },
      "ostm":"s3"
   }
]

Let's look at this example. It's trying to join two streams, this (s1) and s2 and sending the output to stream s3. Output is union of set "iatr" and "ratr" (a, b, c, d, j1, j2, j3). The "jqry" is as defined here for more information.