IGNITE-27737 Update TX API usage in examples

examples/java/src/main/java/org/apache/ignite/example/compute/ComputeColocatedExample.java

@@ -108,7 +108,7 @@ public static void main(String[] args) {
             System.out.println("\nCreating account records...");
 
             for (int i = 0; i < ACCOUNTS_COUNT; i++) {
-                view.insert(null, account(i));
+                view.insert(account(i));
             }
 
             //--------------------------------------------------------------------------------------
@@ -162,7 +162,7 @@ public CompletableFuture<Void> executeAsync(JobExecutionContext context, Integer
 
             RecordView<Tuple> view = context.ignite().tables().table("accounts").recordView();
 
-            Tuple account = view.get(null, accountKey);
+            Tuple account = view.get(accountKey);
 
             System.out.println("Account info [accountNumber=" + account.intValue(0) +
                     ", name=" + account.stringValue(1) + "]");

examples/java/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java

@@ -116,8 +116,8 @@ private static void verifyPut(RecordView view) {
         System.out.println("=== Table data after PUT ===");
         for (int i = 0; i < ACCOUNTS_COUNT; i++) {
             Account keyRec = new Account(i);
-            if (view.contains(null, keyRec)) {
-                Account record = (Account) view.get(null, keyRec);
+            if (view.contains(keyRec)) {
+                Account record = (Account) view.get(keyRec);
                 System.out.printf("Found: id=%d, name=%s, balance=%d, active=%b%n",
                         record.getId(), record.getName(), record.getBalance(), record.isActive());
             } else {
@@ -131,7 +131,7 @@ private static void verifyRemove(RecordView<Account> view) {
         List<Account> keys = IntStream.range(0, ACCOUNTS_COUNT)
                 .mapToObj(Account::new)
                 .collect(Collectors.toList());
-        List<Account> records = view.getAll(null, keys);
+        List<Account> records = view.getAll(keys);
         for (int i = 0; i < records.size(); i++) {
             System.out.printf("id=%d exists? %b%n", i, records.get(i) != null);
         }

examples/java/src/main/java/org/apache/ignite/example/streaming/TwoTableReceiver.java

@@ -35,8 +35,8 @@ public CompletableFuture<List<Tuple>> receive(List<Tuple> page, DataStreamerRece
                     .set("street", sourceItem.stringValue("street"))
                     .set("city", sourceItem.stringValue("city"));
 
-            customersTable.upsert(null, customer);
-            addressesTable.upsert(null, address);
+            customersTable.upsert(customer);
+            addressesTable.upsert(address);
         }
 
         return CompletableFuture.completedFuture(results);

examples/java/src/main/java/org/apache/ignite/example/table/KeyValueViewExample.java

@@ -88,11 +88,11 @@ public static void main(String[] args) throws Exception {
                     .set("accountNumber", 123456);
 
             Tuple value = Tuple.create()
-                    .set("firstName", "Val")
-                    .set("lastName", "Kulichenko")
+                    .set("firstName", "Jane")
+                    .set("lastName", "Doe")
                     .set("balance", 100.00d);
 
-            kvView.put(null, key, value);
+            kvView.put(key, value);
 
             //--------------------------------------------------------------------------------------
             //
@@ -102,7 +102,7 @@ public static void main(String[] args) throws Exception {
 
             System.out.println("\nRetrieving a value using KeyValueView API...");
 
-            value = kvView.get(null, key);
+            value = kvView.get(key);
 
             System.out.println(
                     "\nRetrieved value:\n"

examples/java/src/main/java/org/apache/ignite/example/table/KeyValueViewPojoExample.java

@@ -88,8 +88,8 @@ public static void main(String[] args) throws Exception {
             AccountKey key = new AccountKey(123456);
 
             Account value = new Account(
-                    "Val",
-                    "Kulichenko",
+                    "Jane",
+                    "Doe",
                     100.00d
             );
 

examples/java/src/main/java/org/apache/ignite/example/table/MapperExample.java

@@ -69,7 +69,7 @@ public static void main(String[] args) throws Exception {
 
                 Person myPerson = new Person(2, "2", "John Doe", 40, "Apache");
 
-                view.upsert(null, myPerson);
+                view.upsert(myPerson);
             } finally {
 
                 System.out.println("Dropping the table...");

examples/java/src/main/java/org/apache/ignite/example/table/QueryExample.java

@@ -68,7 +68,7 @@ public static void performQueryWithoutTransaction(Table table) {
         System.out.println("[ Example 1 ] Performing query without transaction");
 
         try (Cursor<Entry<Tuple, Tuple>> cursor = table.keyValueView().query(
-                null, // Implicit transaction
+                (Transaction) null, // Implicit transaction
                 // Query criteria
                 and(
                         columnValue("name", equalTo("John Doe")),
@@ -118,7 +118,7 @@ public static void performQueryAsync(Table table) {
         System.out.println("[ Example 3 ] Performing asynchronous query");
 
         AsyncCursor<Entry<Tuple, Tuple>> result = table.keyValueView().queryAsync(
-                        null, // Implicit transaction
+                        (Transaction) null, // Implicit transaction
                         and(
                                 columnValue("name", equalTo("John Doe")),
                                 columnValue("age", greaterThan(20))

examples/java/src/main/java/org/apache/ignite/example/table/RecordViewExample.java

@@ -23,6 +23,7 @@
 import org.apache.ignite.client.IgniteClient;
 import org.apache.ignite.table.RecordView;
 import org.apache.ignite.table.Tuple;
+import org.apache.ignite.tx.Transaction;
 
 /**
  * This example demonstrates the usage of the {@link RecordView} API.
@@ -86,11 +87,11 @@ public static void main(String[] args) throws Exception {
 
             Tuple newAccountTuple = Tuple.create()
                     .set("accountNumber", 123456)
-                    .set("firstName", "Val")
-                    .set("lastName", "Kulichenko")
+                    .set("firstName", "Jane")
+                    .set("lastName", "Doe")
                     .set("balance", 100.00d);
 
-            accounts.insert(null, newAccountTuple);
+            accounts.insert(newAccountTuple);
 
             //--------------------------------------------------------------------------------------
             //
@@ -102,7 +103,7 @@ public static void main(String[] args) throws Exception {
 
             Tuple accountNumberTuple = Tuple.create().set("accountNumber", 123456);
 
-            Tuple accountTuple = accounts.get(null, accountNumberTuple);
+            Tuple accountTuple = accounts.get(accountNumberTuple);
 
             System.out.println(
                     "\nRetrieved record:\n"

examples/java/src/main/java/org/apache/ignite/example/table/RecordViewPojoExample.java

@@ -87,12 +87,12 @@ public static void main(String[] args) throws Exception {
 
             Account newAccount = new Account(
                     123456,
-                    "Val",
-                    "Kulichenko",
+                    "Jane",
+                    "Doe",
                     100.00d
             );
 
-            accounts.insert(null, newAccount);
+            accounts.insert(newAccount);
 
             //--------------------------------------------------------------------------------------
             //
@@ -102,7 +102,7 @@ public static void main(String[] args) throws Exception {
 
             System.out.println("\nRetrieving a record using RecordView API...");
 
-            Account account = accounts.get(null, new Account(123456));
+            Account account = accounts.get(new Account(123456));
 
             System.out.println(
                     "\nRetrieved record:\n"

examples/java/src/main/java/org/apache/ignite/example/table/TableExample.java

@@ -82,11 +82,11 @@ public static void main(String[] args) throws Exception {
                     .set("age", 32)
                     .set("company", "Apache");
 
-            personTableView.upsert(null, personTuple);
+            personTableView.upsert(personTuple);
 
             Tuple personIdTuple = Tuple.create()
                     .set("id", 1);
-            Tuple insertedPerson = personTableView.get(null, personIdTuple);
+            Tuple insertedPerson = personTableView.get(personIdTuple);
 
             System.out.println("Person name: " + insertedPerson.stringValue("name"));
         }

examples/java/src/main/java/org/apache/ignite/example/tx/TransactionsExample.java

@@ -60,7 +60,7 @@ public static void main(String[] args) throws Exception {
 
             /* Insert initial account */
             accounts.put(null, key, new Account("John", "Doe", 1000.0d));
-            System.out.println("Initial balance: " + accounts.get(null, key).balance);
+            System.out.println("Initial balance: " + accounts.get(key).balance);
 
             /* Using synchronous transactional API to update the balance */
             client.transactions().runInTransaction(tx -> {
@@ -69,7 +69,7 @@ public static void main(String[] args) throws Exception {
                 accounts.put(tx, key, acct);
             });
 
-            System.out.println("Balance after the sync transaction: " + accounts.get(null, key).balance);
+            System.out.println("Balance after the sync transaction: " + accounts.get(key).balance);
 
             /* Using asynchronous transactional API to update the balance */
             CompletableFuture<Void> future = client.transactions().runInTransactionAsync(tx ->
@@ -80,7 +80,7 @@ public static void main(String[] args) throws Exception {
                             })
             );
             future.join();
-            System.out.println("Balance after the async transaction: " + accounts.get(null, key).balance);
+            System.out.println("Balance after the async transaction: " + accounts.get(key).balance);
 
         } finally {