假设节点A上有一个名为“tg”的共享表,节点B如何执行查询?
t=table(1..10 as id, take("aaa", 10) as str)
share t as tg
您可以使用RPC或remoteRun。
1.B 和 A 属于同一簇。使用RPC更方便。
def readShareTab(tabName, size){
return select * from objByName(tabName) limit size
}
rpc(`A, readShareTab, "tg", 10)
2.B 位于不同的集群中。
使用remoteRun更方便。
def readShareTab(tabName, size){
return select * from objByName(tabName) limit size
}
conn = xdb("1.1.1.1", 8848, "admin", "123456")
remoteRun(conn, readShareTab, "tg", 10)