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

        String clusterMode = redisSink.getClusterMode();
        String dataType = redisSink.getDataType();
        String schemaMapMode = redisSink.getSchemaMapMode();
        String host = redisSink.getHost();
        Integer port = redisSink.getPort();
        String clusterNodes = redisSink.getClusterNodes();
        String masterName = redisSink.getMasterName();
        String sentinelsInfo = redisSink.getSentinelsInfo();
        Integer database = redisSink.getDatabase();
        String password = redisSink.getPassword();
        Integer ttl = redisSink.getTtl();
        Integer timeout = redisSink.getTimeout();
        Integer soTimeout = redisSink.getSoTimeout();
        Integer maxTotal = redisSink.getMaxTotal();
        Integer maxIdle = redisSink.getMaxIdle();
        Integer minIdle = redisSink.getMinIdle();
        Integer maxRetries = redisSink.getMaxRetries();

        Format format = parsingDataFormat(
                redisSink.getFormatDataType(),
                false,
                redisSink.getFormatDataSeparator(),
                false);

        return new RedisLoadNode(
                redisSink.getSinkName(),
                redisSink.getSinkName(),
                fieldInfos,
                fieldRelations,
                null,
                null,
                null,
                properties,
                clusterMode,
                dataType,
                schemaMapMode,
                host,
                port,
                clusterNodes,
                masterName,
                sentinelsInfo,
                database,
                password,
                ttl,
                format,
                timeout,
                soTimeout,
                maxTotal,
                maxIdle,
                minIdle,
                maxRetries);
    }
Parse LookupOptions

@param options RedisLookupOptions
@return LookupOptions
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/RedisProvider.java