[ https://issues.apache.org/jira/browse/FLINK-11818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16789267#comment-16789267 ]
Fabian Hueske commented on FLINK-11818: --------------------------------------- Hi, I would not add it to the core API, i.e., the DataSet class. We try to keep this API rather lean. It might be a fit for DataSetUtils. > Provide pipe transformation function for DataSet API > ---------------------------------------------------- > > Key: FLINK-11818 > URL: https://issues.apache.org/jira/browse/FLINK-11818 > Project: Flink > Issue Type: Improvement > Components: API / DataSet > Reporter: vinoyang > Assignee: vinoyang > Priority: Major > > We have some business requirements that require the data handled by Flink to > interact with some external programs (such as Python/Perl/shell scripts). > There is no such function in the existing DataSet API, although it can be > implemented by the map function, but it is not concise. It would be helpful > if we could provide a pipe[1] function like Spark. > [1]: > https://spark.apache.org/docs/latest/rdd-programming-guide.html#transformations -- This message was sent by Atlassian JIRA (v7.6.3#76005)