??????????

Wed, 26 Jun 2024 01:39:26 -0700 

????



---- ???????????? ----
| ?????? | ????????<[email protected]> |
| ???? | 2024??06??26?? 16:38 |
| ?????? | user-zh<[email protected]> |
| ?????? | |
| ???? | ?????????? |
????







&nbsp;





------------------&nbsp;????????&nbsp;------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2024??6??26??(??????) ????4:36
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;??????????






















?? 2024-06-26 15:07:45??"15868861416" <[email protected]&gt; ??????
&gt;????????????ID??PRICE??????????NUMBER??????????????flink-sql????number??????????iceberg??decimal????????????
&gt;
&gt;
&gt;| |
&gt;????
&gt;|
&gt;|
&gt;[email protected]
&gt;|
&gt;
&gt;
&gt;---- ???????????? ----
&gt;| ?????? | Yanquan Lv<[email protected]&gt; |
&gt;| ???????? | 2024??06??26?? 14:46 |
&gt;| ?????? | <[email protected]&gt; |
&gt;| ???? | Re: ??????cdc????oracle???????????? |
&gt;?????????? ID ?? PRINCE ?????????? decimal ????decimal ???????????????????? 
BASE64 ????
&gt;
&gt;????????????????????????????????????????
&gt;
&gt;Map<String, Object&gt; customConverterConfigs = new HashMap<&gt;();
&gt;customConverterConfigs.put(JsonConverterConfig.DECIMAL_FORMAT_CONFIG,
&gt;"numeric");
&gt;JsonDebeziumDeserializationSchema schema = new
&gt;JsonDebeziumDeserializationSchema(includeSchema,
&gt;customConverterConfigs);
&gt;
&gt;
&gt;
&gt;
&gt;[email protected] <[email protected]&gt; ??2024??6??25?????? 
17:26??????
&gt;
&gt;??????????
&gt;"ID" "NAME"&nbsp;&nbsp; 
"ADDTIME"&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
"PRICE"
&gt;1 "aa"&nbsp;&nbsp;&nbsp;&nbsp; 2024-6-25 
14:21:33&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 12.22
&gt;
&gt;???????? 15868861416
&gt;?????????? 2024-06-25 17:19
&gt;???????? [email protected]
&gt;?????? ??????cdc????oracle????????????
&gt;????????oracle????DEBEZIUM.PRODUCTS????????????????????????????????
&gt;
&gt;
&gt;
&gt;
&gt;| |
&gt;????
&gt;|
&gt;|
&gt;[email protected]
&gt;|
&gt;
&gt;
&gt;---- ???????????? ----
&gt;| ?????? | [email protected]<[email protected]&gt; |
&gt;| ???????? | 2024??06??25?? 15:54 |
&gt;| ?????? | user-zh<[email protected]&gt; |
&gt;| ???? | cdc????oracle???????????? |
&gt;??????????????
&gt;JdbcIncrementalSource<String&gt; oracleChangeEventSource =
&gt;new OracleSourceBuilder()
&gt;.hostname("host")
&gt;.port(1521)
&gt;.databaseList("ORCLCDB")
&gt;.schemaList("DEBEZIUM")
&gt;.tableList("DEBEZIUM.PRODUCTS")
&gt;.username("username")
&gt;.password("password")
&gt;.deserializer(new JsonDebeziumDeserializationSchema())
&gt;.includeSchemaChanges(true) // output the schema changes as well
&gt;.startupOptions(StartupOptions.initial())
&gt;.debeziumProperties(debeziumProperties)
&gt;.splitSize(2)
&gt;.build();
&gt;????????????
&gt;
&gt;{"before":null,"after":{"ID":{"scale":0,"value":"AQ=="},"NAME":"aa","ADDTIME":1719325293000,"PRICE":"BMY="},"source":{"version":"1.9.8.Final","connector":"oracle","name":"oracle_logminer","ts_ms":0,"snapshot":"false","db":"ORCL","sequence":null,"schema":"CDC","table":"ORDER_CDC","txId":null,"scn":"0","commit_scn":null,"lcr_position":null,"rs_id":null,"ssn":0,"redo_thread":null},"op":"r","ts_ms":1719301769186,"transaction":null}
&gt;
&gt;??????????PRICE????????????ID??????????????????????????
&gt;

回复