spark-structured-streaming

尝试在同一pyspark结构化流作业中写入和读取增量表。可以';看不到数据

PySpark作业是否可以在增量表中写入,并在同一代码中从该表中读取?使用以下命令运行代码时不会出错。我正在尝试将我要刷新到Kafka的数据可视化到Delta表中,以确保数据流动良好,底层组件也工作良好。即使向我的主题发送了流量,我也可以看到一个空表。任何形式的帮助都会有帮助。