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

Support json array explode to multi messages

    XMLWordPrintableJSON

    Details

      Description

      Currently our DeserializationSchema has supported to emit multi messages for one input record. There is some cases that the json data is not a json object in top level, for example:

      CREATE TABLE source (
        col1 int,
        col2 varchar
      ) WITH (
        ...
        'format' = 'json'
      )
      

      With following data.

      [
      {"col1": 1, "col2": "hello"},
      {"col1": 2, "col2": "flink"}
      ]
      

      CC Jark Wu

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              libenchao Benchao Li
            • Votes:
              2 Vote for this issue
              Watchers:
              12 Start watching this issue

              Dates

              • Created:
                Updated: