import java.sql.*;
public class ParallelQueryExample {
public static void main(String[] args) {
String jdbcUrl = "jdbc:kinetica://localhost:9191/mydatabase";
String username = "admin";
String password = "password";
try {
Connection connection = DriverManager.getConnection(jdbcUrl, username, password);
Statement statement = connection.createStatement();
statement.setQueryParallelism(4);
String query = "SELECT * FROM mytable";
ResultSet resultSet = statement.executeQuery(query);
while (resultSet.next()) {
}
resultSet.close();
statement.close();
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
jdbc:kinetica://localhost:9191/mydatabase?compression=zlib
jdbc:kinetica://localhost:9191/mydatabase?maxrowscached=10000
