Apache Flink: Как я могу добавить заголовок к файлу CSV, используя приемник writeAsFormattedText? - PullRequest
0 голосов
/ 04 февраля 2019

Я использую API набора данных Apache Flink Framework для извлечения данных из различных источников, их преобразования и загрузки в различные приемники.В течение этого периода я работаю над некоторыми сценариями, в которых наборы данных POJO загружаются в файлы CSV.Для этой цели я использую метод writeAsFormattedText, если используется инфраструктура Flink, и соответствующие средства форматирования текста, чтобы избежать отображения наших данных в кортежи (и использовать writeTextAsCsv).Одно из моих требований - добавить строку заголовка поверх созданного файла CSV.Например,

id, name, age 1, john, 30 2, helen, 42

Как такое требование может быть удовлетворено с помощью API набора данных Apache Flink?

Заранее спасибо

...