public static void setup() throws SQLException {
        Hive hive = new Hive();
        hive.execute("DROP TABLE IF EXISTS trx");
        hive.execute("CREATE TABLE trx(product_key STRING, customer_key STRING, price FLOAT, trx_date TIMESTAMP)");
    }