Сценарий высокого уровня: Я работаю над проверкой концепции, в которой мне нужно передать содержимое некоторых файлов журнала и выполнить шаблоны CEP для этих потоков данных.
Ситуация: По умолчанию Flink StreamExecutionEnvironment.readTextFile () считывает каждую строку данного файла и создает объект потока данных.Для некоторых наших файлов мы хотели бы собрать несколько строк и объединить их в один объект Data Stream.Я считаю, что нам нужно реализовать собственное средство чтения записей в Apache Flink, но мы не можем найти ни одного примера для этого.
Любая помощь / предложение будут оценены.