@Test
    public void testParse() throws IOException {
        T data = dynamicSchemaFormat.deserialize(source.getBytes(StandardCharsets.UTF_8));
        for (Entry<String, String> kvs : expectedValues.entrySet()) {
            String result = dynamicSchemaFormat.parse(data, kvs.getKey());
            Assert.assertEquals(kvs.getValue(), result);
        }
    }
Dynamic schema format base test

@param <T>
inlong-sort/sort-flink/base/src/test/java/org/apache/inlong/sort/base/format/DynamicSchemaFormatBaseTest.java