There are examples illustrating Streaming with SQL processing. I suppose, in Spark 2 the preferred way of processing streaming data with SQL queries is Spark Structured Streaming. Makes sense to rework at least one example to illustrate this technique. Candidates are:
- LogAnalyzerStreamingSQL
- LogAnalyzerStreamingImportDirectory