You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Benchao Li (Jira)" <ji...@apache.org> on 2020/07/14 02:59:00 UTC

[jira] [Created] (FLINK-18590) Support json array explode to multi messages

Benchao Li created FLINK-18590:
----------------------------------

             Summary: Support json array explode to multi messages
                 Key: FLINK-18590
                 URL: https://issues.apache.org/jira/browse/FLINK-18590
             Project: Flink
          Issue Type: Improvement
          Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
            Reporter: Benchao Li


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:

{code:SQL}
CREATE TABLE source (
  col1 int,
  col2 varchar
) WITH (
  ...
  'format' = 'json'
)
{code}

With following data.

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

CC [~jark]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)