From 0df71118694f4d1ce4f49b97caa4631a2e13797a Mon Sep 17 00:00:00 2001 From: Ken Takagiwa Date: Wed, 16 Jul 2014 23:39:25 -0700 Subject: [PATCH] delete old file --- .../python/streaming/nerwork_wordcount.py | 22 ------------------- 1 file changed, 22 deletions(-) delete mode 100644 examples/src/main/python/streaming/nerwork_wordcount.py diff --git a/examples/src/main/python/streaming/nerwork_wordcount.py b/examples/src/main/python/streaming/nerwork_wordcount.py deleted file mode 100644 index 67dc28f7bf7f0..0000000000000 --- a/examples/src/main/python/streaming/nerwork_wordcount.py +++ /dev/null @@ -1,22 +0,0 @@ -import sys -from operator import add - -from pyspark.streaming.context import StreamingContext -from pyspark.streaming.duration import * - -if __name__ == "__main__": - if len(sys.argv) != 3: - print >> sys.stderr, "Usage: wordcount " - exit(-1) - ssc = StreamingContext(appName="PythonStreamingNetworkWordCount", duration=Seconds(1)) - - lines = ssc.socketTextStream(sys.argv[1], int(sys.argv[2])) - fm_lines = lines.flatMap(lambda x: x.split(" ")) - filtered_lines = fm_lines.filter(lambda line: "Spark" in line) - mapped_lines = fm_lines.map(lambda x: (x, 1)) - - fm_lines.pyprint() - filtered_lines.pyprint() - mapped_lines.pyprint() - ssc.start() - ssc.awaitTermination()