Hi Lec,
You can use `StreamTableEnvironment#toRetractStream(table, Row.class)` to
get a `DataStream>`.
The true Boolean flag indicates an add message, a false flag indicates a
retract (delete) message. So you can just simply apply
a flatmap function after this to ignore the false messages. Then y
Cheng Shi created FLINK-17550:
-
Summary: set a retract switch
Key: FLINK-17550
URL: https://issues.apache.org/jira/browse/FLINK-17550
Project: Flink
Issue Type: New Feature
Reporter
Hi:
During the execution of flink, especially the sql API, many operations
in DataStream are not available. In many cases, we don't care about the
DELETE record when retracting. Is it possible to set a switch so that the
DELETE record when retracting is not processed? In other words, the
downs
