Hey Community

Assuming there are 3 groups,
A, B, C

Each group represents a set of data about employees and salaries.
Group A ( 0-20K $)
Group B (20K$ - 50K$)
Group C ( > 50K$)

Is it possible to process stream data from single source containing information 
about employees and salaries and split the data into different DB schemas on 
the same DB? (Single Sink - Single Connection)

I Encountered Side output and dynamic tables
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/side_output/
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/concepts/dynamic_tables/

I'm not sure it's the right way.

If there is a better way , enlighten me

Thank you,

Tamir.



[https://my-email-signature.link/signature.gif?u=1088647&e=157381362&v=5b500d0966d3f9bbc086da472e39b98dc7887af72523b19939d26faf9b682d82]

Confidentiality: This communication and any attachments are intended for the 
above-named persons only and may be confidential and/or legally privileged. Any 
opinions expressed in this communication are not necessarily those of NICE 
Actimize. If this communication has come to you in error you must take no 
action based on it, nor must you copy or show it to anyone; please 
delete/destroy and inform the sender by e-mail immediately.
Monitoring: NICE Actimize may monitor incoming and outgoing e-mails.
Viruses: Although we have taken steps toward ensuring that this e-mail and 
attachments are free from any virus, we advise that in keeping with good 
computing practice the recipient should ensure they are actually virus free.

Reply via email to