ashishm07 commented on code in PR #7122:
URL: https://github.com/apache/ignite-3/pull/7122#discussion_r2599233761
##########
examples/java/src/main/java/org/apache/ignite/example/compute/ComputeBroadcastExample.java:
##########
@@ -83,8 +137,40 @@ public static void main(String[] args) {
//
//--------------------------------------------------------------------------------------
+ try (
+ Connection conn =
getConnection("jdbc:ignite:thin://127.0.0.1:10800/");
+ Statement stmt = conn.createStatement()
+ ) {
+ stmt.execute("CREATE SCHEMA IF NOT EXISTS CUSTOM_SCHEMA");
+ stmt.execute("CREATE TABLE IF NOT EXISTS
CUSTOM_SCHEMA.MY_QUALIFIED_TABLE (" +
+ "ID INT PRIMARY KEY, MESSAGE VARCHAR(255))");
+
+ stmt.execute("CREATE SCHEMA IF NOT EXISTS PUBLIC");
+ stmt.execute("CREATE TABLE IF NOT EXISTS PUBLIC.MY_TABLE (" +
+ "ID INT PRIMARY KEY, MESSAGE VARCHAR(255))");
+
+ stmt.execute("CREATE TABLE IF NOT EXISTS PERSON (" +
+ "ID INT PRIMARY KEY, FIRST_NAME VARCHAR(100)," +
+ "LAST_NAME VARCHAR(100), AGE INT)");
+
+ stmt.execute("INSERT INTO PERSON VALUES " +
+ "(1, 'John', 'Doe', 36)," +
+ "(2, 'Jane', 'Smith', 35)," +
+ "(3, 'Robert', 'Johnson', 25)");
+
+ }
+
System.out.println("\nConfiguring compute job...");
+ // 1) Check if deployment unit already exists
Review Comment:
Removing all comments as previously advised
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
