Hi Jose, so basically, you create two PCollections with the same keys and then you join/filter/flatten ?
Regards JB On 30/07/2018 15:09, Jose Bermeo wrote: > Hi, question guys. > > I have to filter an unbounded collection based on data from a redshift > DB. I cannot use a side input as redshift data could change. One way to > do it would be to group common elements, make a query to filter each > group, finally flatten the pipe again.Do you know if this is the best > way to do it? and what would be the way to run the query agains redshift?. > > Thaks. -- Jean-Baptiste Onofré jbono...@apache.org http://blog.nanthrax.net Talend - http://www.talend.com
