Динамическое имя папки в dynamicWrite FileIO в конвейере потока данных - PullRequest
0 голосов
/ 01 декабря 2018

У меня есть 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?Папка должна называться по ключу, используемому для группировки.

...