Spark Rest Source

A Rest Api Structured Streaming DataSource

Example

spark.readStream
  .format("rest")
  .option("url", URL)
  .load
  .writeStream
  .format("console")
  .trigger(Trigger.ProcessingTime("10 seconds"))
  .start()
  .awaitTermination()

Here is a full example.