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

        return new KuduLoadNode(
                kuduSink.getSinkName(),
                kuduSink.getSinkName(),
                fieldInfos,
                fieldRelations,
                null,
                null,
                null,
                properties,
                kuduSink.getMasters(),
                kuduSink.getTableName(),
                kuduSink.getPartitionKey());
    }
The Provider for creating Kudu load nodes.
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/KuduProvider.java