在transform 中用 temporalParse 转一下,例如:
// 打开数据库连接
db = database("dfs://snapshot_L2_TSDB")
//定义时间日期的格式转化使之与创建的库相匹配 按照日期和hash分区
def transType(mutable memTable)
{
return memTable.replaceColumn!(`DataTimeStamp,datetimeParse( "20221001"+string(memTable.DataTimeStamp),"yyyyMMddHH:mm:ss.SSS"))
}
//导入
tmpTB=loadTextEx(dbHandle=db, tableName=`snapshot_L2_TSDB_t, partitionColumns=`DataTimeStamp`SecurityID, filename=dataFilePath,schema=schemaTB ,sortColumns = `SecurityID`DataTimeStamp,transform=transType );