[
https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14501360#comment-14501360
]
ASF GitHub Bot commented on FLINK-1909:
---------------------------------------
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/610
[FLINK-1909] [streaming] Type handling refactor for sources + scala api
This PR reworks the way sources handle type extraction, allowing for
missing types (with returns) and also fixes some issues around type handling
for the streaming Scala api.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/flink FLINK-1909
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/610.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #610
----
commit 7419cd5a080148afb2b6270aa07e588075c8fbc5
Author: Gyula Fora <gyf...@apache.org>
Date: 2015-04-18T13:37:41Z
[FLINK-1909] [streaming] Type handling refactor for sources + scala api
----
> 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)
