twalthr commented on a change in pull request #13618:
URL: https://github.com/apache/flink/pull/13618#discussion_r509437891
##########
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java
##########
@@ -262,6 +266,25 @@ public DataType toPhysicalRowDataType() {
return ROW(fields);
}
+ /**
+ * Converts all persisted columns of this schema into a (possibly
nested) row data type.
+ *
+ * <p>This method returns the query-to-sink schema.
+ *
+ * <p>Note: Computed columns and virtual columns are excluded in the
returned row data type.
+ *
+ * @see DataTypes#ROW(Field...)
+ * @see #toRowDataType()
+ * @see #toPhysicalRowDataType()
+ */
+ public DataType toPersistedRowDataType() {
Review comment:
I thought we should give users a method to show the `query-to-sink`
schema. It is not used for connectors and also not very useful in the planner.
That's why it is in a separate commit. I can remove it again.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
