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

[Anonymous]

У меня есть вот такая PCколлекция KV:

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

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"))
));

Как преобразовать эту PCollection в PCollectionList, содержащий внутри три подколлекции. Каждая подколлекция содержит объекты с одним и тем же ключом.

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

PCollectionList:
PCollection1 contains A and B
PCollection2 contains C and D
PCollection3 contains E, F and G

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

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