From f21cab39c4122672f835196dc36e067361e39274 Mon Sep 17 00:00:00 2001 From: giwa Date: Mon, 11 Aug 2014 03:22:23 -0700 Subject: [PATCH] delete waste file --- .../main/python/streaming/test_oprations.py | 31 ------------------- 1 file changed, 31 deletions(-) delete mode 100644 examples/src/main/python/streaming/test_oprations.py diff --git a/examples/src/main/python/streaming/test_oprations.py b/examples/src/main/python/streaming/test_oprations.py deleted file mode 100644 index 70a62058286e9..0000000000000 --- a/examples/src/main/python/streaming/test_oprations.py +++ /dev/null @@ -1,31 +0,0 @@ -import sys -from operator import add - -from pyspark.conf import SparkConf -from pyspark.streaming.context import StreamingContext -from pyspark.streaming.duration import * - -if __name__ == "__main__": - conf = SparkConf() - conf.setAppName("PythonStreamingNetworkWordCount") - ssc = StreamingContext(conf=conf, duration=Seconds(1)) - class Buff: - result = list() - pass - Buff.result = list() - - test_input = ssc._testInputStream([range(1,4), range(4,7), range(7,10)]) - - fm_test = test_input.map(lambda x: (x, 1)) - fm_test.pyprint() - fm_test._test_output(Buff.result) - - ssc.start() - while True: - ssc.awaitTermination(50) - if len(Buff.result) == 3: - break - - ssc.stop() - print Buff.result -