想在datastream中使用flatmap的ObjectMapper.readTree()

可以使用以下代码将 `ObjectMapper` 和 `readTree` 方法应用于 `FlatMapFunction`：

import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.util.Collector;

public class JsonFlatMapFunction implements FlatMapFunction<String, JsonNode> {

    private transient ObjectMapper jsonParser;

    @Override
    public void flatMap(String value, Collector<JsonNode> out) throws Exception {
        if (jsonParser == null) {
            jsonParser = new ObjectMapper();
        }
        JsonNode jsonNode = jsonParser.readTree(value);
        out.collect(jsonNode);
    }
}

然后在 `DataStream` 上使用 `flatMap` 方法并传入上面定义的 `JsonFlatMapFunction`：

DataStream<String> input = ...;
DataStream<JsonNode> jsonNodes = input.flatMap(new JsonFlatMapFunction());

这将将每个输入字符串解析为 `JsonNode` 并将其作为单独的记录发出。