Count the words in a sentence

dataflow-wordcount.py

import apache_beam as beam

from log_elements import LogElements

lines = [
    "apple orange grape banana apple banana",
    "banana orange banana papaya"
]

with beam.Pipeline() as p:

  (p | beam.Create(lines)

   | beam.FlatMap(lambda sentence: sentence.split())
   | beam.combiners.Count.PerElement()
   | beam.MapTuple(lambda k, v: k + ":" + str(v))

   | LogElements())

'''
Answer:
apple:2
orange:2
grape:1
banana:4
papaya:1