Because these are not exposed in the usual API, its not possible (or difficult) to create custom structured streaming sources.
Consequently, one has to create streaming sources in packages under org.apache.spark.sql. Any pointers or info is greatly appreciated.
