[FLINK-17848] Allow scala datastream api to create named sources

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: API / DataStream, API / Scala
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: Zack LB
• Created: 20/May/20 16:45
• Updated: 14/Nov/21 22:38

Description

Currently you can only provide a custom name to a source operator from the java API. There is no matching API on the scala API. It would be nice to allow scala to also name sources something custom.

I'm referring to this api specifically

The change would be as simple as adding a default parameter to that method which mirrors the java api's default value "Custom Source". Or if preferred could duplicate the method with a required argument that then passes the value to the java function.