回复:回复:[DISCUSS] [FLINK-23122] Provide the Dynamic register converter

2021-06-24 Thread 云华
override the type conversion . -- 发件人:Timo Walther 发送时间:2021年6月24日(星期四) 21:06 收件人:dev 主 题:Re: 回复:[DISCUSS] [FLINK-23122] Provide the Dynamic register converter Hi Jack, thanks for sharing your proposal with us. I totally understand the issue

Re: 回复:[DISCUSS] [FLINK-23122] Provide the Dynamic register converter

2021-06-24 Thread Timo Walther
发件人:Jark Wu 发送时间:2021年6月23日(星期三) 23:13 收件人:dev ; 云华 主 题:Re: [DISCUSS] [FLINK-23122] Provide the Dynamic register converter Hi, `TIMESTAMP_WITH_TIME_ZONE` is not supported in the Flink SQL engine, even though it is listed in the type API. I think what you are looking for is the RawValue

回复:[DISCUSS] [FLINK-23122] Provide the Dynamic register converter

2021-06-24 Thread 云华
Jark Wu 发送时间:2021年6月23日(星期三) 23:13 收件人:dev ; 云华 主 题:Re: [DISCUSS] [FLINK-23122] Provide the Dynamic register converter Hi, `TIMESTAMP_WITH_TIME_ZONE` is not supported in the Flink SQL engine, even though it is listed in the type API. I think what you are looking for is the RawValueType which c

Re: [DISCUSS] [FLINK-23122] Provide the Dynamic register converter

2021-06-23 Thread Jark Wu
Hi, `TIMESTAMP_WITH_TIME_ZONE` is not supported in the Flink SQL engine, even though it is listed in the type API. I think what you are looking for is the RawValueType which can be used as user-defined type. You can use `DataTypes.RAW(TypeInformation)` to define a Raw type with the given TypeIn

[DISCUSS] [FLINK-23122] Provide the Dynamic register converter

2021-06-23 Thread 云华
Hi everyone, I want to rework type conversion system in connector and flink table module to be resuable and scalability. I Postgres system, the type '_citext' will not supported in org.apache.flink.connector.jdbc.catalog.PostgresCatalog#fromJDBCType. what's more, org.apache.flink.table.runti