flume筆記(二)之Agent內部原理

2021-10-05 23:25:05 字數 687 閱讀 3476

首先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...