?
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的狀態 |
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號聯系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
