我的连接语句如下:
login("admin", "123456")
if(existsDatabase("dfs://rangedb")){
dropDatabase("dfs://rangedb")
}
n = 1000000
ID = rand(10, n)
TM1 = take(2000..2020, n)
TM2 = take(1990..2000, n)
x = rand(1.0, n)
y = rand(2.0, n)
tag1 = take(`A`B`C, n)
tag2 = take(`C`D`F, n)
t1 = table(TM1 as TM, ID, x, tag1 as tag)
t2 = table(TM2 as TM, ID, y, tag2 as tag)
db = database("dfs://rangedb", RANGE, 0 5 10)
pt1 = db.createPartitionedTable(t1, `pt1, `ID)
pt1.append!(t1)
pt2 = db.createPartitionedTable(t2, `pt2, `ID)
pt2.append!(t2)
select * from aj(t1, t2, `ID`tag);
报如下错误:
The last joining column for asof join must be an integer or temporal vector.
请问哪里不对?
asof join的最后一个连接列通常为时间类型,也可为整数类型、UUID或IPADDR类型。这里的tag是string,所以不支持作为最后一个连接列。