Я новичок в Spark и его библиотеках!
У меня есть случай, когда мне нужно отправить набор данных на store() пользовательского приемника, а затем передать данные из этого пользовательского приемника.
Я получаю набор данных таким образом внутри пользовательского класса приемника:
Dataset<Row> jdbcDF = spark.read()
.format("jdbc")
.option("url", "jdbc:mysql:dbserver")
.option("dbtable", "schema.tablename")
.option("user", "username")
.option("password", "password")
.load();
Теперь я хочу использовать этот набор данных в качестве потоковых данных, поэтому мне нужно сохранить этот набор данных в store() класса Receiver:
store(jdbcDF);
Возможна ли трансляция таким образом?
p.s Structured Streaming Programming не используется
Заранее спасибо!
