Guest User

Untitled

a guest
Feb 22nd, 2018
66
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.14 KB | None | 0 0
  1. yield op.counters.Increment(key, value)
  2.  
  3. | beam.ParDo(TestDoFn()) # ('key',value)をyieldするprocess
  4. | beam.combiners.Count.PerElement()
Add Comment
Please, Sign In to add comment