diff options
Diffstat (limited to 'extras/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py')
| -rw-r--r-- | extras/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/extras/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py b/extras/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py index f428f64da3..51f8c5ca66 100644 --- a/extras/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py +++ b/extras/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py @@ -54,6 +54,8 @@ See http://spark.apache.org/docs/latest/streaming-kinesis-integration.html for more details on the Kinesis Spark Streaming integration. """ +from __future__ import print_function + import sys from pyspark import SparkContext |