Details
-
Sub-task
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
None
-
None
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