wuchong commented on code in PR #2525:
URL: https://github.com/apache/fluss/pull/2525#discussion_r2751336803
##########
fluss-common/src/main/java/org/apache/fluss/metadata/TableDescriptor.java:
##########
@@ -65,6 +65,10 @@ public final class TableDescriptor implements Serializable {
public static final String LOG_OFFSET_COLUMN = "_log_offset";
public static final String COMMIT_TIMESTAMP_COLUMN = "_commit_timestamp";
+ // Reserved column names for $binlog virtual table nested row fields
Review Comment:
It won't conflict, because the original columns names are nested undert
`before` and `after`. If user has a table `(id int, before string)` then the
schema of `$binlog` will be `(_change_type string, _log_offset bigint,
_commit_timestamp timestamp_ltz(3), before ROW<id int, before string>)`.
You can reference the original `before` column by `select before.before from
T`.,
--
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]
