结构化流式处理可以控制数据到达的速度吗?

Question

例如，我的文件大小为 100MB，我使用结构化流来处理它。我想每次读取 10MB，然后输出结果，再次读取 10MB，然后处理它。但结构化流似乎直接读取 100MB 的处理并等待新数据处理。

Answer 1

结构化流式处理现在支持速率源，并且使用 rowsPerSecond 可以获取所需数量的数据。