from pyspark import SparkContext
if __name__ == "__main__":
    def myFunc(s):
        print("@@")
        words = s.split("n")
        print("##")
        return len(words)


    sc = SparkContext("local","test")
    sc.textFile("C:\TestLogs\sample.log").map(myFunc)
    print("**")

**