@Override
    public LoadNode createLoadNode(StreamNode nodeInfo, Map<String, StreamField> constantFieldMap) {
        TDSQLPostgreSQLSink tdsqlPostgreSQLSink = (TDSQLPostgreSQLSink) nodeInfo;
        Map<String, String> properties = parseProperties(tdsqlPostgreSQLSink.getProperties());
        List<SinkField> sinkFieldList = tdsqlPostgreSQLSink.getSinkFieldList();
        List<FieldInfo> fieldInfos = parseSinkFieldInfos(sinkFieldList, tdsqlPostgreSQLSink.getSinkName());
        List<FieldRelation> fieldRelations = parseSinkFields(sinkFieldList, constantFieldMap);

        return new TDSQLPostgresLoadNode(
                tdsqlPostgreSQLSink.getSinkName(),
                tdsqlPostgreSQLSink.getSinkName(),
                fieldInfos,
                fieldRelations,
                null,
                null,
                null,
                properties,
                tdsqlPostgreSQLSink.getJdbcUrl(),
                tdsqlPostgreSQLSink.getUsername(),
                tdsqlPostgreSQLSink.getPassword(),
                tdsqlPostgreSQLSink.getSchemaName() + "." + tdsqlPostgreSQLSink.getTableName(),
                tdsqlPostgreSQLSink.getPrimaryKey());
    }
The Provider for creating TDSQLPostgreSQL load nodes.
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/TDSQLPostgreSQLProvider.java