У меня есть PCollection<KV<String,String>>
.Я хочу сгруппировать данные по K и записать все значения для ключа K в файл (ы) в хранилище Google внутри папки с именем K. Предположим, у меня есть 2 записи после использования с помощью для группировки значений.
['a',[apple,as]],['b','bat,ball']
Я хочу записать весь файл с именем data_record.txt внутри имени папки «a» для «apple», as «и» b для «bat, ball».Как я могу создать динамические имена папок, используя FileIO.dynamicWrite
?Папка должна называться по ключу, используемому для группировки.