Advertisement
Guest User

Untitled

a guest
Jun 25th, 2019
124
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.21 KB | None | 0 0
  1. sc = SparkContext.getOrCreate()
  2. hive_context = HiveContext(sc)
  3.  
  4. query = hive_context.sql("CREATE TABLE TEST (ID INT)")
  5.  
  6. pyspark MyScript.py
  7.  
  8. Heart beat
  9. Heart beat
  10. Heart beat
  11. Heart beat
  12. ...
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement