Need Suggestions on the Requirement!!

Posted by Puneet Kinra-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Need-Suggestions-on-the-Requirement-tp17938.html

Hi

Actually we are building a CRM (offer management tool) ,Currently Working on that..

1)  Multiple Streaming Table Sources.

2)  We are hitting a query on those Tables for getting aggregated values.

3)  Want to store the output of these aggregated values into the another table & then want to run the 

selection criteria.

Ex. 

Source A----->Table Registered as Table1 (AppendMode)----->Select count(*) as TableCount1 from Table1 group by UID ----> Count Per Subscriber(retract Stream) .

 

Source B----->Table Registered as Table2 (AppendMode)----->Select count(*) as TableCount2 from Table2 group by UID----> Count Per Subscriber(retract Stream) .

Now want to put this aggregator into the third table keeping Key UID (upsert Mode) & then want to run selection criteria on the third table

example :select * from Table3 where TableCount1==?  && TableCount1== ?

--