This operator can be used to synchronize different input streams regarding their start-timestamps. In opposite to Union operator the inputs are not merged, but send to different output ports, i.e. an element coming over input port 1 will be send to output port 1.
This operator has no parameters
synced = SYNCHRONIZE(source1,source2,source3)
p1 = RENAME({isNoOp = 'true'},1:synced)
p2 = RENAME({isNoOp = 'true'},2:synced)
p3 = RENAME({isNoOp = 'true'},3:synced) |