[
https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577867#comment-16577867
]
vinoyang commented on FLINK-10126:
----------------------------------
Hi [~wind_ljy] I just looked at it roughly and found that the method of the
same name of scala calls the warp method to wrap the DataSource into a DataSet.
I haven't looked at why it does this. And is it possible to provide a way to
return directly to the DataSource. As far as I understand it, the API behavior
of the two languages should be as consistent as possible. If we can simply
return the same signature method, then the problem will not be too complicated,
but if not, it needs to be rethought.
> There should be a Scala DataSource
> ----------------------------------
>
> Key: FLINK-10126
> URL: https://issues.apache.org/jira/browse/FLINK-10126
> Project: Flink
> Issue Type: Improvement
> Reporter: Alexis Sarda-Espinosa
> Assignee: vinoyang
> Priority: Minor
> Labels: datasource, scala
>
> In Java, an ExecutionEnvironment's createInput method returns a DataSource,
> whereas the Scala version returns a DataSet. There is no Scala DataSource
> wrapper, and the Scala DataSet does not provide the Java DataSource methods,
> such as getSplitDataProperties.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
