在将数据导入数据库之前,若需要对数据进行预处理,例如转换日期和时间数据类型,填充空值等,可以在调用loadTextEx函数时指定transform参数。过滤act列空值,可试试下面代码:
def dataTrans(t){ return select * from t where !isNull(act) } loadTextEx(dbHandle=db,tableName='trade', partitionColumns='timestamp',filename=path,transform=dataTrans)