Hi, trying to implement a transformer PTransform<PCollection<T>, PCollection<KV<Long, T>>> where the output keys would be generated element indexes (increasing, unique). What's the best way to implement this before the beam stateful DoFn is available? thx,a.
- howto zip pcollection with index Antony Mayi
- Re: howto zip pcollection with index Sourabh Bajaj
- Re: howto zip pcollection with index Lukasz Cwik
- Re: howto zip pcollection with index Ben Chambers
- Re: howto zip pcollection with index Robert Bradshaw
