reference-apps
reference-apps copied to clipboard
An example on Structured Streaming
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