Gyula Fora created FLINK-1909: --------------------------------- Summary: Refactor streaming scala api to use returns for adding typeinfo Key: FLINK-1909 URL: https://issues.apache.org/jira/browse/FLINK-1909 Project: Flink Issue Type: Bug Components: Scala API, Streaming Reporter: Gyula Fora Assignee: Gyula Fora Priority: Minor
Currently the streaming scala api uses transform to pass the extracted type information instead of .returns. This leads to a lot of code duplication. -- This message was sent by Atlassian JIRA (v6.3.4#6332)