可以参考下述代码实现:
def writeData(ip2, port2){
conn = xdb(ip2, port2, "admin", "123456") // 建立和 ip2 数据库的连接
t = loadTable("dfs://demo1", "trades")
t2 = conn("select * from loadTable('dfs://demo2', 'trades') ")
t.append!(t2)
return true
}
conn1 = xdb("ip1", 8848, "admin", "123456") // 建立和 ip1 数据库的连接
conn1(writeData, "ip2", 8848)
详细说明可以参考文档:远程函数调用