我写了一个简单的 demo供参考:
db = database("dfs://testdb", VALUE, 2022.01.01..2022.01.03)
t = table(1:0, [`time], [TIMESTAMP])
createPartitionedTable(dbHandle=db, table=t, tableName=`pt1, partitionColumns=`time)
s = extractTextSchema("D:/data/data1.csv")
update s set type="TIMESTAMP" where name = `a
loadTextEx(db, `pt1, `time, "D:/data/data1.csv", schema=s, transform=def(t):table(t.a+t.b as time))
select * from loadTable(db, `pt1)
csv 文件就是两列
a, b
2023.01.01 12:00:00, 120