@Override
    public LoadNode createLoadNode(StreamNode nodeInfo, Map<String, StreamField> constantFieldMap) {
        OceanBaseSink oceanBaseSink = (OceanBaseSink) nodeInfo;
        Map<String, String> properties = parseProperties(oceanBaseSink.getProperties());
        FieldTypeMappingStrategy fieldTypeMappingStrategy =
                fieldTypeStrategyFactory.getInstance(SinkType.MYSQL);
        List<FieldInfo> fieldInfos = parseSinkFieldInfos(oceanBaseSink.getSinkFieldList(), oceanBaseSink.getSinkName(),
                fieldTypeMappingStrategy);
        List<FieldRelation> fieldRelations = parseSinkFields(oceanBaseSink.getSinkFieldList(), constantFieldMap);

        return new OceanBaseLoadNode(
                oceanBaseSink.getSinkName(),
                oceanBaseSink.getSinkName(),
                fieldInfos,
                fieldRelations,
                Lists.newArrayList(),
                null,
                null,
                properties,
                OceanBaseSinkDTO.setDbNameToUrlWithCdc(oceanBaseSink.getJdbcUrl(), oceanBaseSink.getDatabaseName()),
                oceanBaseSink.getUsername(),
                oceanBaseSink.getPassword(),
                oceanBaseSink.getTableName(),
                oceanBaseSink.getPrimaryKey());
    }
The Provider for creating OceanBase load nodes.
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/OceanBaseProvider.java