Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- sc = SparkContext.getOrCreate()
- hive_context = HiveContext(sc)
- query = hive_context.sql("CREATE TABLE TEST (ID INT)")
- pyspark MyScript.py
- Heart beat
- Heart beat
- Heart beat
- Heart beat
- ...
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement