public RowType extractSchema(T data) {
        return extractSchema(data, extractPrimaryKeyNames(data));
    }
Extract operation

@param data The raw data
@return A operation replace a ddl
inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/format/AbstractDynamicSchemaFormat.java