1TB 前後のデータを取り込むために Flume を実装しようとしています。このために、多重化チャネルセレクターを使用しようとしています。
多重化チャネル セレクタの使用方法を示すいくつかの使用可能な例があります。
私の質問は、イベントのヘッダー コンテンツをどのように判断できるかということです。
たとえば、以下の構成では、状態としてヘッダーを持つ多重化チャネル セレクターを使用しており、マッピングは CN、ID、IN などに行われます。
spoolDirAgent.sources.source1.selector.type = multiplexing
spoolDirAgent.sources.source1.selector.header = State
spoolDirAgent.sources.source1.selector.mapping.CN = channel1
spoolDirAgent.sources.source1.selector.mapping.IN = channel2
spoolDirAgent.sources.source1.selector.mapping.ID = channel2
spoolDirAgent.sources.source1.selector.defalut = channel1
また、可能であれば、flume ソースでイベント ヘッダーを使用する方法を教えてください。
前もって感謝します！