可以通过xdb,在集群之间同步数据。例如以下代码可以将集群A服务器上的csv文件同步至集群B:
def writeData(dbName, tableName, data){
loadTable(dbName, tableName).append!(data)
}
def loadCsv(filePath, remoteServer, remotePort, username, password){
conn = xdb(remoteServer, remotePort, username, password)
t = loadText(filePath)
conn(writeData{"dfs://trade","trade", t})
}
loadCsv("/home/appadmin/hwf/trade.csv", "1.1.1.1", 8848, "admin", "111111")
filePath:服务器A上的文件路径
remoteServer/remotePort: 远端服务器连接信息