Hi All,
I am wondering if Ignite has Spark Structured streaming sink? If I can use
any JDBC then my question really is Does Spark Structured Streaming has a
JDBC sink or do I need to use forEachWriter? I see the following code in
this link
<https://databricks.com/blog/2016/07/28/structured-streaming-in-apache-spark.html>
and
I can see that database name can be passed in the JDBC connection string,
however, I wonder how to pass a table name? Thanks!
inputDF.groupBy($"action", window($"time", "1 hour")).count()
.writeStream.format("jdbc")
.save("jdbc:mysql//…")
