[ https://issues.apache.org/jira/browse/FLINK-16998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099750#comment-17099750 ]
Jark Wu commented on FLINK-16998: --------------------------------- That's right... Then I think it's reasonable to make the RowKind not-null.. > 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 > > 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)