[FLINK-17695] Simplify SourceOperator by using a utility SimpleVersionedListState

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: API / DataStream
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 14/May/20 13:59
• Updated: 16/May/20 15:32
• Resolved: 16/May/20 15:31

Description

The SourceOperator has some boiler plate code taking the bytes out of the ListState<byte[]> and applying the SimpleVersionedSerializer to turn them into the splits.

This repeated code can be simply encapsulated in a utility class SimpleVersionedListState<T> which wraps a ListState<byte[]> and applies the serialization and de-serialization.