例如,我有一个100MB的文件,我使用结构化流来处理它。我希望每次读取10MB,然后输出结果,再次读取10MB,然后处理它。但结构化流似乎直接读取100MB到处理中,并等待新数据处理。
发布于 2020-06-29 16:59:31
结构化流媒体现在支持Rate Source,使用rowsPerSecond可以获得您想要的一定数量的数据。
https://stackoverflow.com/questions/59112729
相似问题