This operator works similar as a join with a one-to-one condition. It can be used in cases where the simple outputs of different sources need to be combined into one tuple, without having a join-condition. A typical scenario are different sensor values comming from different input operators that should be combined into one measurement.

Parameter

  • WaitForAllChanged (Boolean): If true, there is only output when there has been input on all ports
  • BufferNewInputElements (Boolean): If WaitForAllChanged is set, specifies, if new Input should be buffered or overrides older Input that hast not been transfered yet
  • outputOnHeartsbeat (Boolean): In this case, each time a heartbeat is received, the current state of the tuple is send, i.e. this ignores if there are not new elements for each input.

Example

combined = COMBINE({waitForAllChanged=true, BufferNewInputElements=false},source1,source2,source3,source4)
  • No labels