Одиночная строка файла как событие Flume

Question

Я настроил свой источник потока как spooldir. У меня много CSV-файлов, и я хочу, чтобы мой агент Flume рассчитывал/обрабатывал каждую строку CSV как одно событие. Как настроить агент Flume для этого?

Спасибо.

Answer 1

источник spooldir имеет параметр deserializer; в документации говорится об этом:

Укажите десериализатор, используемый для анализа файла в событиях. По умолчанию выполняется разбор каждой строки в качестве события. Указанный класс должен реализовать EventDeserializer.Builder.

Поэтому он должен работать.