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