@Override
    public LoadNode createLoadNode(StreamNode nodeInfo, Map<String, StreamField> constantFieldMap) {
        HBaseSink hbaseSink = (HBaseSink) nodeInfo;
        Map<String, String> properties = parseProperties(hbaseSink.getProperties());
        List<FieldInfo> fieldInfos = parseSinkFieldInfos(hbaseSink.getSinkFieldList(), hbaseSink.getSinkName());
        List<FieldRelation> fieldRelations = parseSinkFields(hbaseSink.getSinkFieldList(), constantFieldMap);
        return new HbaseLoadNode(
                hbaseSink.getSinkName(),
                hbaseSink.getSinkName(),
                fieldInfos,
                fieldRelations,
                Lists.newArrayList(),
                null,
                null,
                properties,
                hbaseSink.getTableName(),
                hbaseSink.getNamespace(),
                hbaseSink.getZkQuorum(),
                hbaseSink.getRowKey(),
                hbaseSink.getBufferFlushMaxSize(),
                hbaseSink.getZkNodeParent(),
                hbaseSink.getBufferFlushMaxRows(),
                hbaseSink.getBufferFlushInterval());
    }
The Provider for creating HBase load nodes.
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/HBaseProvider.java