首先channelselector的作用是將event 資料傳給哪乙個channel。其中它有兩種選擇策略,分別是 replicating(複製)和 multiplexing(多路復用)。 ▶
replicating
(複製):會將同乙個 event 資料發往所有的 channel,每乙個channel都發一遍。(預設)
eg:a1.sources.r1.selector.type = replicating (預設的寫不寫都可以)
▶ multiplexing
(多路復用):會根據相應的原則,將不同的 event 發往不同的 channel。
eg:a1.sources.r1.selector.type = multiplexing
首先sink processor 共 有 三 種 類 型 , 分 別 是 defaultsinkprocessor 、 loadbalancingsinkprocessor 和 failoversinkprocessor
▶ defaultsinkprocessor
:對應的是單個的sink。(預設) ▶
loadbalancingsinkprocessor
:對應的是sink group可以實現負載均衡的功能。 ▶
failoversinkprocessor
:對應的是sink group可以實現故障轉移的功能。
Flume之agent基本配置使用
這裡的agent名稱定義為agent,其他名稱同理 agent.sources r1 agent.channels c1 agent.sinks k1 sources 定義資源型別為nc,繫結主機為localhost,暴露埠為9999 agent.sources.r1.type netcat age...
CC1310片內韌體公升級筆記(二)
路徑 link cc13x0 sdk 1 60 00 21 docs proprietary rf proprietary rf users guide cc13x0 oad easylink oad onchip.html sect bim for on chip oad 一 oad公升級要求 1...
培訓筆記之java 二
第二天 i.判斷是不是數字的幾種方法 1 string score joptionpane.showinputdialog 請輸入數字 char scorearray score.tochararray for int i 0 i 9 scorearray i 0 2 正規表示式 public bo...