Поддерживает ли Flink функцию бокового вывода в наборе данных (пакетный API)? Если нет, как обрабатывать действительные и недействительные записи при загрузке из файла?
Apache Flink - API набора данных - Дополнительные выходы
Ответы (1)
Вы всегда можете сделать что-то вроде этого:
DataSet<EventOrInvalidRecord> goodAndBadTogether = input.map(new CreateObjectIfPossible())
goodAndBadTogether.filter(new KeepOnlyGood())...
goodAndBadTogether.filter(new KeepOnlyBad())...
Другой разумный вариант в некоторых случаях - использовать DataStream API, даже если у вас нет потоковых источников.
person
David Anderson
schedule
03.02.2020
