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.

Reply via email to