Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-12251 Rework the Table API & SQL type system
  3. FLINK-20613

Update TableResult.collect()/TableResult.print() to the new type system

Attach filesAttach ScreenshotVotersWatch issueWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Release Note:
      Hide
      Table.execute().collect() might return slightly different results for column types and row kind. The most important differences include:
      * Structured types are represented as POJOs of the original class and not Row anymore.
      * Raw types are serialized according to the configuration in TableConfig.

      Show
      Table.execute().collect() might return slightly different results for column types and row kind. The most important differences include: * Structured types are represented as POJOs of the original class and not Row anymore. * Raw types are serialized according to the configuration in TableConfig.

      Description

      Currently, TableResult.collect()/TableResult.print() use old sink interfaces and old type system. Those methods are very important in the API and should be updated.

        Attachments

          Activity

            People

            • Assignee:
              twalthr Timo Walther
              Reporter:
              twalthr Timo Walther

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment