如何使用“触发器一次”触发器控制Spark结构化流媒体中每个触发器处理的文件量?我正在尝试使用Spark Structured Streaming的特性Trigger once来模拟类似批处理的设置。但是,我在运行初始批处理时遇到了一些问题,因为我有很多历史数据,因此我还使用选项 ...2024-04-27 已阅读: n次