public Connection getHiveConnection() throws SQLException, ClassNotFoundException {
        Class.forName(HIVE_DRIVER);

        String connStr = hiveJdbcUrl + "/" + hiveDatabase;
        Connection connection = DriverManager.getConnection(connStr, hiveUsername, hivePassword);

        LOG.info("Connect to hive {} successfully", connStr);
        return connection;
    }
getHiveConnection

@return                        Connection
@throws SQLException
@throws ClassNotFoundException
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/hive/HiveSinkContext.java