这是我的一些查询:
我有两个不同的流stream1,stream2其中的元素是按顺序排列的。
1)现在,当我keyBy在这些流中的每一个上执行操作时,顺序会保持不变吗?(由于这里的每个小组将仅发送给一个任务管理器)我的理解是,记录将按小组的顺序排列,请在此处更正。
2)在keyBy两个流上之后,我正在共同分组以获取匹配和不匹配的记录。会将订单也保持在这里?因为这也适用于KeyedStream。我正在使用EventTime,并AscendingTimestampExtractor用于生成timestamp和watermark。
3)现在,我想matching_nonMatchingStream使用map / flatmap对2)得到的序列执行序列检查。我是否需要再次执行keyBy此处操作,或者如果保持连锁状态,则matching_nonMatchingStream运行是否相同TaskManager?我的理解是,链条将在这里起作用,纠正我,变得困惑。
4)slotSharingGroup-您能否根据文档详细说明:设置此操作的插槽共享组。TaskManager如果可能,在同一插槽共享组中的并行操作实例将位于同一插槽中。