Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-11818

Provide pipe transformation function for DataSet API

    XMLWordPrintableJSON

    Details

      Description

      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

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                yanghua vinoyang
                Reporter:
                yanghua vinoyang
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 10m
                  10m