Basic beam read file and operations

basicBeam.py

# https://beam.apache.org/documentation/transforms/python/aggregation/combinevalues/
# 
import apache_beam as beam
import csv

if __name__ == '__main__':
    with beam.Pipeline('DirectRunner') as pipeline:
        (pipeline 
        | "Read File" >> beam.io.ReadFromText('test.txt')
        | 'Split' >> (
            beam.FlatMap(
                lambda x: x.split(" "))
        | 'PairWithOne' >> beam.Map(lambda x: (x, 1))
        | 'GroupAndSum' >> beam.CombinePerKey(sum))
        | "Get all" >> beam.Map(lambda x: x[1])
        | "Sum" >> beam.CombineGlobally(sum)
        | "Print" >> beam.Map(print)
        #| "Write to file" >> beam.io.WriteToText('test_data.txt')
        )