|
command shell(flume command)
help
| 帮助
| connect master:port
| 登录master
| config logicalnode source sink
| 为逻辑节点配置一个source到sink的映射
| getnodestatus
| 获得节点状态(HELLO, CONFIGURING, ACTIVE, IDLE, ERROR, DECOMMISSIONED, LOST )
HELLO, node启动时
CONFIGURING, node被配置后
ACTIVE, 一个event从source送达到sink
IDLE, source中所有evnet发送完毕后
ERROR, 节点故障退出,数据没有flush
DECOMMISSIONED, node被master移除
LOST, master长时间未收到node心跳
| getconfigs
| 获得配置
| getmappings [physical node]
| 如果physical node参数被省略,将显示所有logical node到physical node的映射关系
| exec
| 同步执行命令
| Source file
| 执行脚本.
| submit
| 异步执行命令
| wait ms [cmdid]
| 设定一个时间,周期检查命令进程的状态(success or failure)
| waitForNodesActive ms node1 [node2 […]]
| 设定一个时间,检查node是否处于使用(configuring, active)状态
| waitForNodesDone ms node1 [node2 […]]
| 设定一个时间,检查node是否处于未用(IDLE, ERROR, LOST)状态
| quit
| 退出
|
command shell(exec & submit command)
双引号
| 包含转义字符的java string
| 单引号
| 能引住除单引号之外的所有字符
| noop
| touch master, 不做操作
| config logicalnode source sink
| 为逻辑节点配置source到sink的映射
| multiconfig flumespec
| | unconfig logicalnode
| 取消逻辑节点的配置,影响master调整故障转移列表(failover list)
| refreshAll logicalnode
| 刷新
| save filename
| 保存current configuration到master硬盘
| load filename
| 从master中加载current configuration
| map physicalnode logicalnode
| 配置物理节点到逻辑节点的映射关系,master的配置将被同步到logicalnode
| spawn physicalnode logicalnode
| 恢复
| decommission logicalnode
| | unmap physicalnode logicalnode
| 取消映射
| unmapAll
| 全部取消
| purge logicalnode
| 清除状态,类似重启一个logical node, 适用于(DECOMMISSIONED、 LOST)状态
| purgeAll
| 清除所有logical node的状态
|
|
|
|