Skip to content

Latest commit

 

History

History
20 lines (16 loc) · 510 Bytes

README.md

File metadata and controls

20 lines (16 loc) · 510 Bytes

License

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.