StreamingFileSink настроить имя файла для RowFormat - PullRequest
0 голосов
/ 09 июля 2020

Мне нужно настроить имена файлов для файлов, созданных StreamingFileSink. Я использую ParquetAvroWriters.forGenericRecord для создания паркетных файлов. Обнаружено, что я не могу использовать .withOutputFileConfig(), когда использую .forBulkFormat() (который доступен при использовании .forRowFormat().

...