Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- jvm = spark.sparkContext._jvm
- 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"))
- out_stream.write("oneLineContent".encode())
- out_stream.flush()
- out_stream.close()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement