echauchot commented on pull request #14961:
URL: https://github.com/apache/flink/pull/14961#issuecomment-781967279


   @HuangZhenQiu to be honest I still have a doubt on the whole parquet support 
for DECIMAL. parquet 
[doc](https://github.com/apache/parquet-format/blob/master/LogicalTypes.md#decimal)
 says that the primitive type (int32, or int64) stores the unscaled value 
(before the decimal point) but I sill don't know where is the scaled value 
(after the decimal point) stored in the parquet field. As the support for int64 
in flink was already done through _BasicTypeInfo.INT_TYPE_INFO_ I did the same 
but I fear we lose the decimal part in those cases.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to