-
Notifications
You must be signed in to change notification settings - Fork 1.3k
[FLINK-30263] Introduce schemas table in table store #414
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
JingsongLi
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks @zjureel for the contribution, left comments.
| +-----------+----------------------------------------+----------------+--------------+-----------+-----------+ | ||
| | schema_id | fields | partition_keys | primary_keys | options | commonts | | ||
| +-----------+----------------------------------------+----------------+--------------+-----------+-----------+ | ||
| | 1 | [{"id":0,"name":"a","type":"BIGINT"... | ["k1"] | ["k1", "k2] | {} | my table | |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
In SQL-CLI, do we have option to show long field? I think we can use it here.
sql-client.display.max-column-width
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
In SQL-CLI, do we have option to show long field? I think we can use it here.
sql-client.display.max-column-width
The config sql-client.display.max-column-width is supported in streaming only, I have created a issue https://issues.apache.org/jira/browse/FLINK-30303 in Flink
...table-store-core/src/main/java/org/apache/flink/table/store/table/metadata/SchemasTable.java
Outdated
Show resolved
Hide resolved
...table-store-core/src/main/java/org/apache/flink/table/store/table/metadata/SchemasTable.java
Outdated
Show resolved
Hide resolved
3f11313 to
97f3e8e
Compare
JingsongLi
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
+1
Introduce schemas table in table store, user can query historical schemas of table through sql: SELECT * FROM Table$schemas