我有我的闪光作业的checkpointing设置,它有2个滑动窗口(这些不是连接)和1个翻滚窗口连接。我的想法是,我并不真的需要保存join本身的状态,因为保存2滑动窗口本身的状态就足够了。Join最终成为20-30 to的状态,导致作业延迟和崩溃,并且检查点永远不会保存。public class CustomJoin implements JoinFunction<A, A, A>, ListCheck
所以我做了一个webservice (基于starlette),它的端点接受二进制体。我想把这个二进制的身体提供给fastavro。Starlette doc says,我可以用request.stream()以异步流的形式访问原始数据。async for chunk in request.stream():
# do something with chunk... 现在,我要将流提供给fastavro。) 我的问题是,有没有一种干净的方法可以