Как преобразовать KV в Apache Bean в PcollectionList ⇐ JAVA

[Anonymous]

У меня есть Pcollection kv, как это: < /p>

Код: Выделить всё

PCollection input = pipeline.apply(Create.of(
KV.of(0, new MyObject("A")),
KV.of(0, new MyObject("B")),
KV.of(1, new MyObject("C")),
KV.of(1, new MyObject("D")),
KV.of(2, new MyObject("E")),
KV.of(2, new MyObject("F")),
KV.of(2, new MyObject("G"))
));
< /code>
Как я могу преобразовать этот Pcollection в PcollectionList, который содержит три подколлекции внутри. Каждая субболка содержит объекты с одной и той же ключом. < /P>
PCollectionList:
PCollection1 contains A and B
PCollection2 contains C and D
PCollection3 contains E, F and G

Максимальное количество ключей неизвестно и может отличаться от времени.

Подробнее здесь: https://stackoverflow.com/questions/792 ... ectionlist