Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-19976 FLIP-136: Improve interoperability between DataStream and Table API
  3. FLINK-22590

Add Scala implicit conversions for new API methods

    XMLWordPrintableJSON

Details

    • Hide
      The Scala implicits that convert between DataStream API and Table API have been updated to the new methods of FLIP-136.

      The changes might require an update of pipelines that used `toTable` or implicit conversions from `Table` to `DataStream[Row]`.
      Show
      The Scala implicits that convert between DataStream API and Table API have been updated to the new methods of FLIP-136. The changes might require an update of pipelines that used `toTable` or implicit conversions from `Table` to `DataStream[Row]`.

    Description

      FLINK-19980 should also be exposed through Scala's implicit conversions. To allow a fluent API such as `table.toDataStream(...)`

      Attachments

        Issue Links

          links to

          Web Link GitHub Pull Request #16440

          Activity

            People

              twalthr Timo Walther
              twalthr Timo Walther
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: