@Override
    public String getExtParams(StreamSourceEntity sourceEntity) {
        COSSourceDTO cosSourceDTO = COSSourceDTO.getFromJson(sourceEntity.getExtParams());
        if (Objects.nonNull(cosSourceDTO) && StringUtils.isNotBlank(sourceEntity.getDataNodeName())) {
            COSDataNodeInfo dataNodeInfo =
                    (COSDataNodeInfo) dataNodeService.getByKeyWithoutTenant(sourceEntity.getDataNodeName(),
                            DataNodeType.COS);
            CommonBeanUtils.copyProperties(dataNodeInfo, cosSourceDTO, true);
            return JsonUtils.toJsonString(cosSourceDTO);
        }
        return sourceEntity.getExtParams();
    }
COS source operator, such as get or set COS source info.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/cos/COSSourceOperator.java