[BEAM-9256] Use SortedMapState for optimization of @RequiresTimeSortedInput

• Type: Improvement
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: sdk-java-core
• Labels: Clarified
• Assignee: Unassigned
• Reporter: Jan Lukavský
• Created: 06/Feb/20 11:18
• Updated: 04/Jun/22 14:47

Description

The current implementation of @RequiresTimeSortedInput uses BagState, which is read and sorted upon watermark update. This can be improved once SortedMapState is available.