[ https://issues.apache.org/jira/browse/FLINK-16998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110549#comment-17110549 ]
Timo Walther commented on FLINK-16998: -------------------------------------- Changeflag has been added. Backwards compatibility will follow. Fixed in 1.12.0: f35679966eac9e3bb53a02bcdbd36dbd1341d405 Fixed in 1.11.0: 045ff18faec85b19baaa9691e24a1eccc5460d9b > Add a changeflag to Row type > ---------------------------- > > Key: FLINK-16998 > URL: https://issues.apache.org/jira/browse/FLINK-16998 > Project: Flink > Issue Type: Sub-task > Components: API / Core > Reporter: Timo Walther > Assignee: Timo Walther > Priority: Major > Labels: pull-request-available > > In Blink planner, the change flag of records travelling through the pipeline > are part of the record itself but not part of the logical schema. This > simplifies the architecture and API in many cases. > Which is why we aim adopt the same mechanism for > {{org.apache.flink.types.Row}}. > Take {{tableEnv.toRetractStream()}} as an example that returns either Scala > or Java {{Tuple2<Boolean, Row>}}. For FLIP-95 we need to support more update > kinds than just a binary boolean. > This means: > - Add a changeflag {{RowKind}} to to {{Row}} > - Update the {{Row.toString()}} method > - Update serializers in backwards compatible way -- This message was sent by Atlassian Jira (v8.3.4#803005)