[
https://issues.apache.org/jira/browse/FLINK-17848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zack LB updated FLINK-17848:
----------------------------
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|[https://github.com/apache/flink/blob/master/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala#L640]]
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.
was: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.
> Allow scala datastream api to create named sources
> --------------------------------------------------
>
> Key: FLINK-17848
> URL: https://issues.apache.org/jira/browse/FLINK-17848
> Project: Flink
> Issue Type: Improvement
> Components: API / DataStream, API / Scala
> Reporter: Zack LB
> Priority: Major
>
> 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|[https://github.com/apache/flink/blob/master/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala#L640]]
>
> 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
