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