导入CSV文件时,如何进行数据类型转换

导入CSV文件时,如何进行数据类型转换

请先 登录 后评论

最佳答案 2021-11-06 15:28

定义一个参数转换的函数,参数为mutable  t,返回t的类型转换的结果,在导入数据时,把这个函数赋值给transform参数。

举例如下:

def transform_type(mutable  t)

{

return t.replaceColumn!(`DateTime,datetimeParse(string(t.DateTime),"yyyyMMdd")).replaceColumn!(`SecurityID,t.SecurityID + `.SH)

}


loadTextEx(dbHandle=db,tableName=`sh_k_day,partitionColumns=`DateTime`SecurityID,filename="/home/ychan/data/sh/20210901/Day.csv",transform = transform_type,schema = schema_snapshot,skipRows=1)

请先 登录 后评论

其它 0 个回答