Hier sind einige der Fragen, die ich habe:

ch habe zwei verschiedene Streastream1 undstream2 in der die Elemente in Ordnung sind.

1) Nun, wenn ichkeyBy Wird die Reihenfolge bei jedem dieser Streams beibehalten? (Da jede Gruppe hier nur an einen Task-Manager gesendet wird) Nach meinem Verständnis sind die Datensätze für eine Gruppe in Ordnung. Korrigieren Sie mich hier.

2) Nach demkeyBy auf beiden Streams mache ich Co-Group, um die passenden und nicht passenden Datensätze zu erhalten. Wird die Reihenfolge auch hier beibehalten?, Da dies auch auf @ funktionieKeyedStream. Ich benutzeEventTime, undAscendingTimestampExtractor zum Erzeugen vontimestamp undwatermark.

3) Nun möchte ich die Sequenzprüfung am @ durchführmatching_nonMatchingStream Ich komme von 2) mit map / flatmap. Muss ich das @ nochmal durchführkeyBy hier, oder wenn ich in kette bleibe wird dasmatching_nonMatchingStream run in sameTaskManager? Ich verstehe hier, dass die Kette hier funktionieren wird, korrigiere mich und werde verwirrt.

4)slotSharingGroup - Können Sie diesbezüglich weitere Informationen geben, wie im Dokument beschrieben: Legt die Slot-Sharing-Gruppe für diesen Vorgang fest. Parallele Instanzen von Vorgängen, die sich in derselben Slot-Sharing-Gruppe befinden, befinden sich im selbenTaskManager slot, falls möglich.