command shell(flume command)
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参数被省略，将显示所有logical node到physical node的映射关系
exec
同步执行命令
Source file
执行脚本.
submit
异步执行命令
wait ms
设定一个时间，周期检查命令进程的状态(success or failure)
waitForNodesActive ms node1 ]
设定一个时间，检查node是否处于使用(configuring, active)状态
waitForNodesDone ms node1 ]
设定一个时间，检查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的状态
页:
[1]