On Thu, Nov 18, 2010 at 11:58 AM, DUGALEIX Michaël <[email protected]> wrote: > Hello plumbers, > > Is there a stage which can combine an input of N1 records and an input of N2 > records to give an output of N1xN2 records in the following way :
Something like this: PIPE ( end \ ) \ < 1 txt | s: synch | j: juxtapose | cons \ < 2 txt | instore | dup * | s: | outstore | j: With 'instore' you buffer the entire stream and get a "token" that is duplicated. This way 'outstore' produces multiple copies of your input stream. The 'synch' stage will pace the records on the first pipeline segment to make them flow with the tokens in the 2nd segment. This way a full set of records is presented at the 'juxtapose' while it is holding a record from the first stream. | Rob
