Advertisement
Guest User

Untitled

a guest
Apr 23rd, 2019
88
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.35 KB | None | 0 0
  1. jvm = spark.sparkContext._jvm
  2. out_stream = jvm.org.apache.hadoop.fs.FileSystem.get(jvm.java.net.URI("adl://account.azuredatalakestore.net"),spark.sparkContext._jsc.hadoopConfiguration()).create(jvm.org.apache.hadoop.fs.Path("adl://account.azuredatalakestore.net/report.txt"))
  3. out_stream.write("oneLineContent".encode())
  4. out_stream.flush()
  5. out_stream.close()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement