通过connector的方式定义数据:
数据类型定义为:yldrate DECIMAL, pf__id VARCHAR(10), symbol_id VARCHAR(30)
数据库中yldrate数据前几条是这样的:
0.000072101337
0.000000000000
0.000000000000
0.000212493881
0.000078719845
0.000073023505
0.000070173309
0.000070168385
但是,pyflink读取出来转为pandas后都是:
     yldrate      
0       0  
1       0  
2       0  
3       0  
4       0  
5       0  
不知道是什么原因,导致精度损失,我要如何设置,使数据能够无损失读取?小白在线蹲大佬回复~拜托啦!

回复