mbruns

RWR JSON on Intervals

Jun 10th, 2022 (edited)
168
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
SPARK 0.19 KB | None | 0 0
  1. spark
  2.   .readStream
  3.   .select($"value".cast("string").alias("jsonData"))
  4.   .select(from_json($"jsonData",jsonSchema).alias("payload"))
  5.   .writeStream
  6.   .trigger("1 seconds")
  7.   .start()
Add Comment
Please, Sign In to add comment