在 ForeachBatch 函数结构化 Straming 中,我想创建微批次中接收的数据帧的临时视图
func(tabdf, epoch_id):
tabaDf.createOrReplaceView("taba")
Run Code Online (Sandbox Code Playgroud)
但我收到以下错误:
org.apache.spark.sql.streaming.StreamingQueryException: Table or view not found: taba
Caused by: org.apache.spark.sql.catalyst.analysis.NoSuchTableException: Table or view 'taba' not found
Run Code Online (Sandbox Code Playgroud)
请任何人帮助我解决这个问题。
spark-streaming apache-spark-sql pyspark spark-structured-streaming