Может ли Flume добавить заголовок к данным?

Я имею дело с такими данными, как: {"a":1,"b":2}, и я хочу, чтобы Flume добавлял заголовок ко всем данным, таким как {"header":self_define,"content":{"a":1,"b":2}}

Я читал некоторые материалы о перехватчиках Flume, но кажется, что их можно использовать только для изменения выходного пути приемников. Есть ли способ добиться этого или мне нужно разработать класс перехватчика самостоятельно?

Любая помощь приветствуется.


person user2894829    schedule 26.03.2020    source источник


Ответы (1)


Попробуйте использовать Flume Morphline Interceptor:

Flume MorphlineInterceptor выполняет преобразования морфлайна в перехваченных событиях. Например, morphline может игнорировать события или изменять или вставлять определенные заголовки событий, используя сопоставление шаблонов на основе регулярных выражений.

person yanis    schedule 10.06.2020