...
Init Connection
Code Block | ||
---|---|---|
| ||
// Set JDBC Impala Driver Class.forName(JDBC_DRIVER_NAME); // Connect to Impala - Choose a user that has the rights to write into /user/hive/warehouse/ con = DriverManager.getConnection(connectionUrl,"hdfs",""); // Init Statement Statement stmt = con.createStatement(); |
How to create an Impala table with Java?
Code Block | ||
---|---|---|
| ||
String sqlStatementInvalidate = "INVALIDATE METADATA";
String sqlStatementDrop = "DROP TABLE IF EXISTS helloworld";
String sqlStatementCreate = "CREATE TABLE helloworld (message String) STORED AS PARQUET";
// Invalidate metadata to update changes
stmt.execute(sqlStatementInvalidate);
// Execute DROP TABLE Query
stmt.execute(sqlStatementDrop);
// Execute CREATE Query
stmt.execute(sqlStatementCreate); |
How to insert data into an Impala table with Java?
Code Block | ||
---|---|---|
| ||
String sqlStatementInsert = "INSERT INTO helloworld VALUES (\"helloworld\")"; // Execute INSERT Query stmt.execute(sqlStatementInsert); |
How to select data from an Impala table with Java?
Code Block | ||
---|---|---|
| ||
String sqlStatementSelect = "SELECT * from helloworld"; // Execute SELECT Query ResultSet rs = stmt.executeQuery(sqlStatementSelect); // Process results while(rs.next()) { logger.info(rs.getString(1)); } |