public ExtractNode createExtractNode(StreamSource sourceInfo) {
        if (sourceInfo == null) {
            return null;
        }
        String sourceType = sourceInfo.getSourceType();
        return extractNodeProviderFactory.getExtractNodeProvider(sourceType).createExtractNode(sourceInfo);
    }
Create extract node from the given source.
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/NodeFactory.java