getAsyncReplicationTasks
语法
getAsyncReplicationTasks([n])
参数
n 是一个可选参数,表示从 asyncReplicationWorkDir 指定的路径读取的任务数量。若不指定 n,则表示获取所有任务。
详情
启用集群间的异步复制后,在主集群的数据节点上执行,返回该节点从 asyncReplicationWorkDir 指定的路径读取的需要发送的任务。运行此函数前,异步复制应当处于 stop 状态。
返回一个表,包含以下列:
Skip: 布尔值,表示是否跳过此任务。True 表示跳过
Cid: 任务编号
Function: 任务对应的函数命令
Args: 函数的参数个数
例子
$ getAsyncReplicationTasks();
Skip |
Cid |
Function |
Args |
---|---|---|---|
false |
5 |
dropTable(database('dfs://test_copy'),'pt1') |
0 |
true |
6 |
append!{database('dfs://test_copy'),'pt2')} |
1 |