如果你正在处理一对多的Map，你可能希望通过一个**flatMap()**函数来实现这一点，以支持从一个元素创建多个元素。由于你的payload已经接受了基于JSON的字符串，你可以将其解析为一个结构化的JSON对象，然后提取你需要的元素并将其发送到下游。
比如说：

// Function to take in a single JSON string and output multiple string elements
class TokenMaskingFunction: FlatMapFunction<String, String>{
    override fun flatMap(input: String, collector: Collector<String>) {
        try {
            // Construct your JSON node
            val structuredJson: JsonNode = mapper.readTree(input)
    
            // Capture your tokens
            val tokens: JsonNode = structuredJson.get("tokenList")
            if (tokens.isArray) {
                for (token in tokens) {
                    // Extract and mask your token before sending downstream
                    val maskedToken = maskFunction(token.toString())
                    collector.collect(maskedToken)
                }
            }
        } catch (e: Exception) {
            // Handle accordingly / log / ignore
        }
    }

    private fun mask(token: String): String { 
        // Do your masking here
    }

    companion object {
        // Define some static JSON parser here (static is important)
        val mapper = ObjectMapper()
    }
}

字符串
然后你只需要在从JSON字符串源Map后使用它：

streamEnv
    .fromSource(yourJsonStringSource)
    .flatMap(TokenMaskingFunction())
    .process(...)

型

我用Pattern类做了一个粗略的解决方案。它不是很有效，但对给定的例子有效。

public static void main(String[] args) {
        String val = " {\"tokenType\":\"email\",\"tokenList\":[\"token1\",\"token2\",\"token3\",\"token4\"]}";
        Pattern p = Pattern.compile("(?:\\G(?!^)|\"tokenList\":\\[)\"(?<elem>[^\"]*)\",?");
        Matcher m = p.matcher(val);
        int n  = 3;
        StringBuilder builder = new StringBuilder();
        while (m.find()) {
            String elem = m.group("elem");
            if (elem != null) {
                m.appendReplacement(builder, m.group().replace(elem, "*".repeat(n).concat(elem.substring(n))));
            }
        }
        m.appendTail(builder);
        System.out.println(builder);
    }

字符串