slinkydeveloper commented on a change in pull request #17906:
URL: https://github.com/apache/flink/pull/17906#discussion_r759172992
##########
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/Projection.java
##########
@@ -39,9 +49,24 @@
// sealed class
private Projection() {}
- /** Project the provided {@link DataType} using this {@link Projection}. */
+ /**
+ * Projects a (possibly nested) row data type by returning a new data type
that only includes
+ * fields of the given index paths.
+ *
+ * <p>Note on naming: Sometimes, it may get name conflicts when extract
fields from the row
Review comment:
I reworded this comment to explain it better, wdyt?
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
