我有一个对象流（数千种类型），每个对象都有时间和其他一些字段，比如 A(a1,a2,t),B(b1,b2,b3,t),C(c1,c2,C3,t),D(d1,d2,t) ,
物体一个接一个地出现。
有数百个计算模型，每个模型将使用不同的对象。一个模型可能会这样：最后五次，a1<b1，d1=1，所以它使用对象a，b，d。另一个模型可能使用其他对象。
那么如何在flink中实现呢？我想我应该把输入流分成每个模型，但我不确定。我是Flink的新手，任何想法都欢迎。谢谢。