HiveClientJdbc.java

package test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class HiveClientJdbc {
    private static final String HIVE_DRIVER = “org.apache.hadoop.hive.jdbc.HiveDriver”;
    private static final String CONNECTION_URL = “jdbc:hive://localhost:10000/default”;
    public static void main(String[] args) throws SQLException, ClassNotFoundException {
        Class.forName(HIVE_DRIVER);
        Connection con = DriverManager.getConnection(CONNECTION_URL, “”, “”);
        Statement stmt = con.createStatement();
        ResultSet rslt = stmt.executeQuery(“select count(*) from retail_demo.email_addresses_dim_hive”);
        if (rslt.next()) {
            System.out.println(rslt.getInt(1));
        }
        con.close();
    }
}