小编Nar*_*kar的帖子

Spark Structure Streaming 中的临时视图

在 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

0
推荐指数
1
解决办法
3355
查看次数