Как Apache Beam реализует Scala zipWithIndex ()?

Question

Pcollection p1 = {"a", "b", "c"}

PCollection> p2 = p1.apply ("некоторая операция") // {(1, "a"), (2, "b"), (3, "c")}

Как получить результат с помощью Apache Beam, спасибо?