Re: 回复: Flink SQL处理Array型的JSON

Tue, 21 Jul 2020 03:24:59 -0700 

如果不等待最新版本的话也可以这样

将 纯数组的数据作为字符串 从source消费，增加自定义的json解析函数，判断 isArray 之后 遍历进行 collect

if (Objects.nonNull(str)) {
                if (isArray) {
                    JsonNode node = objectMapper.readTree(str);
                    if (node.isArray()) {
                        Iterator<JsonNode> nodeIterator = node.elements();
                        while (nodeIterator.hasNext()) {
                           
collect(deserializationSchema.deserialize(nodeIterator.next().toString().getBytes()));
                        }
                    }
                } else {
                   
collect(deserializationSchema.deserialize(str.getBytes()));
                }
            }



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复