"""SimpleApp.py""" from pyspark import SparkContext logFile = "<Local system Input data folder>/InputData.txt" # Should be some file on your system sc = SparkContext("local", "Simple App") logData = sc.textFile(logFile).cache() numFs = logData.filter(lambda s: 'F' in s).count() numMs = logData.filter(lambda s: 'M' in s).count() print("Lines with F: %i, lines with M: %i" % (numFs,numMs))