@Override
    public ExtractNode createExtractNode(StreamNode streamNodeInfo) {
        HudiSource source = (HudiSource) streamNodeInfo;
        List<FieldInfo> fieldInfos = parseStreamFieldInfos(source.getFieldList(), source.getSourceName());
        Map<String, String> properties = parseProperties(source.getProperties());

        return new HudiExtractNode(
                source.getSourceName(),
                source.getSourceName(),
                fieldInfos,
                null,
                source.getCatalogUri(),
                source.getWarehouse(),
                source.getDbName(),
                source.getTableName(),
                CatalogType.HIVE,
                source.getCheckIntervalInMinus(),
                source.isReadStreamingSkipCompaction(),
                source.getReadStartCommit(),
                properties,
                source.getExtList());
    }
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