@Override
    public LoadNode createLoadNode(StreamNode nodeInfo, Map<String, StreamField> constantFieldMap) {
        HudiSink hudiSink = (HudiSink) nodeInfo;
        Map<String, String> properties = parseProperties(hudiSink.getProperties());
        List<FieldInfo> fieldInfos = parseSinkFieldInfos(hudiSink.getSinkFieldList(), hudiSink.getSinkName());
        List<FieldRelation> fieldRelations = parseSinkFields(hudiSink.getSinkFieldList(), constantFieldMap);
        HudiConstant.CatalogType catalogType = HudiConstant.CatalogType.forName(hudiSink.getCatalogType());

        return new HudiLoadNode(
                hudiSink.getSinkName(),
                hudiSink.getSinkName(),
                fieldInfos,
                fieldRelations,
                null,
                null,
                null,
                properties,
                hudiSink.getDbName(),
                hudiSink.getTableName(),
                hudiSink.getPrimaryKey(),
                catalogType,
                hudiSink.getCatalogUri(),
                hudiSink.getWarehouse(),
                hudiSink.getExtList(),
                hudiSink.getPartitionKey());
    }
The Provider for creating Hudi extract or load nodes.
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/HudiProvider.java