how to emit a deletion event for all data in iterating of production logic

[vtygoss]

Hi, Flink community!


I have a problem when iterating the  data production logic.   e.g. 


data production procedure: …-> Table A(change log stream) -> Table B(change log 
stream) ->Table C(change log stream) ….


production logic of Table B:  insert into table B select * from Table A where 
a>0; 
new production logic of Table B: insert into table B select * from Table A 
where a<0; 


So how to emit a deletion event for all data in Table B in order to trigger 
deletion of old data in Table C? is there a better way for this scenario? 


Thanks for your suggestion!


Best Regards!