You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Zack Loebel-Begelman (Jira)" <ji...@apache.org> on 2020/05/20 16:47:00 UTC

[jira] [Commented] (FLINK-17848) Allow scala datastream api to create named sources

    [ https://issues.apache.org/jira/browse/FLINK-17848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112437#comment-17112437 ] 

Zack Loebel-Begelman commented on FLINK-17848:
----------------------------------------------

I'm happy to cut a PR, ideally backporting to 1.9 since that is what I'm currently using. 

Seems like we could either duplicate the code, or provide the same name (or maybe something different, like "Custom Scala Source") in the scala API. 

> 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 / Scala
>            Reporter: Zack Loebel-Begelman
>            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.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)