[jira] [Created] (FLINK-22936) Support column comment in Schema and ResolvedSchema

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-22936) Support column comment in Schema and ResolvedSchema

Shang Yuanchun (Jira)
Jark Wu created FLINK-22936:
-------------------------------

             Summary: Support column comment in Schema and ResolvedSchema
                 Key: FLINK-22936
                 URL: https://issues.apache.org/jira/browse/FLINK-22936
             Project: Flink
          Issue Type: New Feature
          Components: Table SQL / API
            Reporter: Jark Wu
             Fix For: 1.14.0


In order to support column comment in catalog (FLINK-18958), we should first support column comment in Schema and ResolvedSchema.

The API is up to discuss. Currently, we already have 10 methods for adding a column in {{Schema}}. If we want to support column comment for each kind of column, the number of column methods may double. It's not easy to maintain in the long term, and make the API complex.

Another alternative is adding a new method {{comment(String)}} which will apply comment to the previous column. This is not a good builder style, but can make the building concise.
For example,

{code}
Schema.newBuilder()
                        .column("ts", DataTypes.TIMESTAMP(3)).comment("log timestamp")
                        .columnByExpression("proctime", "PROCTIME()").comment("processing time")
                        .watermark("ts", "ts - INTERVAL '5' SECOND")
                        .build()
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)