private HiveTableMetaStoreFactory msFactory() {
        // Get dbName from with properties first.
        String dbName = jobConf.get(HiveValidator.CONNECTOR_HIVE_DATABASE);
        if (dbName == null) {
            dbName = identifier.getDatabaseName();
        }
        return new HiveTableMetaStoreFactory(jobConf, hiveVersion, dbName, identifier.getObjectName());
    }
Table sink to write to Hive tables.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveTableSink.java