aboutsummaryrefslogtreecommitdiff
path: root/examples/src/main/python/cassandra_outputformat.py
diff options
context:
space:
mode:
Diffstat (limited to 'examples/src/main/python/cassandra_outputformat.py')
-rw-r--r--examples/src/main/python/cassandra_outputformat.py6
1 files changed, 4 insertions, 2 deletions
diff --git a/examples/src/main/python/cassandra_outputformat.py b/examples/src/main/python/cassandra_outputformat.py
index d144539e58..5d643eac92 100644
--- a/examples/src/main/python/cassandra_outputformat.py
+++ b/examples/src/main/python/cassandra_outputformat.py
@@ -15,6 +15,8 @@
# limitations under the License.
#
+from __future__ import print_function
+
import sys
from pyspark import SparkContext
@@ -46,7 +48,7 @@ cqlsh:test> SELECT * FROM users;
"""
if __name__ == "__main__":
if len(sys.argv) != 7:
- print >> sys.stderr, """
+ print("""
Usage: cassandra_outputformat <host> <keyspace> <cf> <user_id> <fname> <lname>
Run with example jar:
@@ -60,7 +62,7 @@ if __name__ == "__main__":
... fname text,
... lname text
... );
- """
+ """, file=sys.stderr)
exit(-1)
host = sys.argv[1]