...
- Create a stream for each input.
- Create an calculate stream to perform the join.
- Make the pipe from one of the streams a pull pipe and the pipe from the other is a lookup pipe.
- In the join stream, for each record on the pull pipe, cycle thru all the records from the lookup pipe for that key and flag those records where there is a match based on a date range.
- Date ranges should be calculated based on converting dates to integers. Note : there is a dateDiff function in PhixFlow that will give the difference in milliseconds between 2 dates
See Also
...