This is an automated email from the ASF dual-hosted git repository.
sk0x50 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 445fa517303 IGNITE-27737 Update TX API usage in examples (#7547)
445fa517303 is described below
commit 445fa5173037aa149570eb656330862eaabbbfdd
Author: jinxxxoid <[email protected]>
AuthorDate: Fri Apr 3 16:32:17 2026 +0400
IGNITE-27737 Update TX API usage in examples (#7547)
---
.../org/apache/ignite/example/table/ItTableExamplesTest.java | 8 ++++----
.../ignite/example/compute/ComputeColocatedExample.java | 8 ++++----
.../example/streaming/SingleTableDataStreamerExample.java | 11 ++++++-----
.../org/apache/ignite/example/streaming/TwoTableReceiver.java | 4 ++--
.../org/apache/ignite/example/table/KeyValueViewExample.java | 8 ++++----
.../apache/ignite/example/table/KeyValueViewPojoExample.java | 4 ++--
.../java/org/apache/ignite/example/table/MapperExample.java | 2 +-
.../java/org/apache/ignite/example/table/QueryExample.java | 5 ++---
.../org/apache/ignite/example/table/RecordViewExample.java | 9 +++++----
.../apache/ignite/example/table/RecordViewPojoExample.java | 8 ++++----
.../java/org/apache/ignite/example/table/TableExample.java | 8 ++++----
.../org/apache/ignite/example/tx/TransactionsExample.java | 6 +++---
12 files changed, 41 insertions(+), 40 deletions(-)
diff --git
a/examples/java/src/integrationTest/java/org/apache/ignite/example/table/ItTableExamplesTest.java
b/examples/java/src/integrationTest/java/org/apache/ignite/example/table/ItTableExamplesTest.java
index e0959ea1d24..6b572cf152d 100644
---
a/examples/java/src/integrationTest/java/org/apache/ignite/example/table/ItTableExamplesTest.java
+++
b/examples/java/src/integrationTest/java/org/apache/ignite/example/table/ItTableExamplesTest.java
@@ -36,7 +36,7 @@ public class ItTableExamplesTest extends AbstractExamplesTest
{
assertConsoleOutputContains(RecordViewExample::main, EMPTY_ARGS,
"\nRetrieved record:\n"
+ " Account Number: 123456\n"
- + " Owner: Val Kulichenko\n"
+ + " Owner: Jane Doe\n"
+ " Balance: $100.0\n");
}
@@ -50,7 +50,7 @@ public class ItTableExamplesTest extends AbstractExamplesTest
{
assertConsoleOutputContains(RecordViewPojoExample::main, EMPTY_ARGS,
"\nRetrieved record:\n"
+ " Account Number: 123456\n"
- + " Owner: Val Kulichenko\n"
+ + " Owner: Jane Doe\n"
+ " Balance: $100.0\n");
}
@@ -64,7 +64,7 @@ public class ItTableExamplesTest extends AbstractExamplesTest
{
assertConsoleOutputContains(KeyValueViewExample::main, EMPTY_ARGS,
"\nRetrieved value:\n"
+ " Account Number: 123456\n"
- + " Owner: Val Kulichenko\n"
+ + " Owner: Jane Doe\n"
+ " Balance: $100.0\n");
}
@@ -78,7 +78,7 @@ public class ItTableExamplesTest extends AbstractExamplesTest
{
assertConsoleOutputContains(KeyValueViewPojoExample::main, EMPTY_ARGS,
"\nRetrieved value:\n"
+ " Account Number: 123456\n"
- + " Owner: Val Kulichenko\n"
+ + " Owner: Jane Doe\n"
+ " Balance: $100.0\n");
}
}
diff --git
a/examples/java/src/main/java/org/apache/ignite/example/compute/ComputeColocatedExample.java
b/examples/java/src/main/java/org/apache/ignite/example/compute/ComputeColocatedExample.java
index 67f5eb6d1c8..b597ab1fa21 100644
---
a/examples/java/src/main/java/org/apache/ignite/example/compute/ComputeColocatedExample.java
+++
b/examples/java/src/main/java/org/apache/ignite/example/compute/ComputeColocatedExample.java
@@ -99,9 +99,9 @@ public class ComputeColocatedExample {
System.out.println("Creating account records...");
- for (int i = 0; i < ACCOUNTS_COUNT; i++) {
- view.insert(null, account(i));
- }
+ for (int i = 0; i < ACCOUNTS_COUNT; i++) {
+ view.insert(account(i));
+ }
//--------------------------------------------------------------------------------------
//
@@ -157,7 +157,7 @@ public class ComputeColocatedExample {
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) + "]");
diff --git
a/examples/java/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
b/examples/java/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
index 819386016f8..228f306027d 100644
---
a/examples/java/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
+++
b/examples/java/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
@@ -1,4 +1,3 @@
-package org.apache.ignite.example.streaming;
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
@@ -16,6 +15,8 @@ package org.apache.ignite.example.streaming;
* limitations under the License.
*/
+package org.apache.ignite.example.streaming;
+
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.SubmissionPublisher;
@@ -116,12 +117,12 @@ public class SingleTableDataStreamerExample {
streamerFut.join();
}
- private static void verifyPut(RecordView view) {
+ private static void verifyPut(RecordView<Account> 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 = 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 {
@@ -135,7 +136,7 @@ public class SingleTableDataStreamerExample {
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);
}
diff --git
a/examples/java/src/main/java/org/apache/ignite/example/streaming/TwoTableReceiver.java
b/examples/java/src/main/java/org/apache/ignite/example/streaming/TwoTableReceiver.java
index a8b4b8ffda4..a308819f43c 100644
---
a/examples/java/src/main/java/org/apache/ignite/example/streaming/TwoTableReceiver.java
+++
b/examples/java/src/main/java/org/apache/ignite/example/streaming/TwoTableReceiver.java
@@ -35,8 +35,8 @@ public class TwoTableReceiver implements
DataStreamerReceiver<Tuple, Void, Tuple
.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);
diff --git
a/examples/java/src/main/java/org/apache/ignite/example/table/KeyValueViewExample.java
b/examples/java/src/main/java/org/apache/ignite/example/table/KeyValueViewExample.java
index b7900220171..a7be0c91103 100644
---
a/examples/java/src/main/java/org/apache/ignite/example/table/KeyValueViewExample.java
+++
b/examples/java/src/main/java/org/apache/ignite/example/table/KeyValueViewExample.java
@@ -80,11 +80,11 @@ public class KeyValueViewExample {
.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);
//--------------------------------------------------------------------------------------
//
@@ -94,7 +94,7 @@ public class KeyValueViewExample {
System.out.println("Retrieving a value using KeyValueView API...");
- value = kvView.get(null, key);
+ value = kvView.get(key);
System.out.println(
"\nRetrieved value:\n"
diff --git
a/examples/java/src/main/java/org/apache/ignite/example/table/KeyValueViewPojoExample.java
b/examples/java/src/main/java/org/apache/ignite/example/table/KeyValueViewPojoExample.java
index 0b9af03b9de..d0964c185e5 100644
---
a/examples/java/src/main/java/org/apache/ignite/example/table/KeyValueViewPojoExample.java
+++
b/examples/java/src/main/java/org/apache/ignite/example/table/KeyValueViewPojoExample.java
@@ -80,8 +80,8 @@ public class KeyValueViewPojoExample {
AccountKey key = new AccountKey(123456);
Account value = new Account(
- "Val",
- "Kulichenko",
+ "Jane",
+ "Doe",
100.00d
);
diff --git
a/examples/java/src/main/java/org/apache/ignite/example/table/MapperExample.java
b/examples/java/src/main/java/org/apache/ignite/example/table/MapperExample.java
index 34566cb31db..f3ea3560345 100644
---
a/examples/java/src/main/java/org/apache/ignite/example/table/MapperExample.java
+++
b/examples/java/src/main/java/org/apache/ignite/example/table/MapperExample.java
@@ -90,7 +90,7 @@ public class MapperExample {
Person myPerson = new Person(2, "2", "John Doe", 40, "Apache");
- view.upsert(null, myPerson);
+ view.upsert(myPerson);
System.out.println("Dropping the table...");
diff --git
a/examples/java/src/main/java/org/apache/ignite/example/table/QueryExample.java
b/examples/java/src/main/java/org/apache/ignite/example/table/QueryExample.java
index cc33c675c90..8e18dc6afcc 100644
---
a/examples/java/src/main/java/org/apache/ignite/example/table/QueryExample.java
+++
b/examples/java/src/main/java/org/apache/ignite/example/table/QueryExample.java
@@ -70,7 +70,7 @@ public class QueryExample {
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")),
@@ -122,8 +122,7 @@ public class QueryExample {
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
+ AsyncCursor<Entry<Tuple, Tuple>> result =
table.keyValueView().queryAsync(null, // Implicit transaction
and(
columnValue("name", equalTo("John Doe")),
columnValue("age", greaterThan(20))
diff --git
a/examples/java/src/main/java/org/apache/ignite/example/table/RecordViewExample.java
b/examples/java/src/main/java/org/apache/ignite/example/table/RecordViewExample.java
index fd98f50ec98..7b1f28f541c 100644
---
a/examples/java/src/main/java/org/apache/ignite/example/table/RecordViewExample.java
+++
b/examples/java/src/main/java/org/apache/ignite/example/table/RecordViewExample.java
@@ -20,6 +20,7 @@ package org.apache.ignite.example.table;
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.
@@ -78,11 +79,11 @@ public class RecordViewExample {
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);
//--------------------------------------------------------------------------------------
//
@@ -94,7 +95,7 @@ public class RecordViewExample {
Tuple accountNumberTuple = Tuple.create().set("accountNumber",
123456);
- Tuple accountTuple = accounts.get(null, accountNumberTuple);
+ Tuple accountTuple = accounts.get(accountNumberTuple);
System.out.println(
"\nRetrieved record:\n"
diff --git
a/examples/java/src/main/java/org/apache/ignite/example/table/RecordViewPojoExample.java
b/examples/java/src/main/java/org/apache/ignite/example/table/RecordViewPojoExample.java
index b14578d6f7f..bcea89b7449 100644
---
a/examples/java/src/main/java/org/apache/ignite/example/table/RecordViewPojoExample.java
+++
b/examples/java/src/main/java/org/apache/ignite/example/table/RecordViewPojoExample.java
@@ -79,12 +79,12 @@ public class RecordViewPojoExample {
Account newAccount = new Account(
123456,
- "Val",
- "Kulichenko",
+ "Jane",
+ "Doe",
100.00d
);
- accounts.insert(null, newAccount);
+ accounts.insert(newAccount);
//--------------------------------------------------------------------------------------
//
@@ -94,7 +94,7 @@ public class RecordViewPojoExample {
System.out.println("Retrieving 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"
diff --git
a/examples/java/src/main/java/org/apache/ignite/example/table/TableExample.java
b/examples/java/src/main/java/org/apache/ignite/example/table/TableExample.java
index d9b2488b7b4..f514f36530a 100644
---
a/examples/java/src/main/java/org/apache/ignite/example/table/TableExample.java
+++
b/examples/java/src/main/java/org/apache/ignite/example/table/TableExample.java
@@ -83,11 +83,11 @@ public class TableExample {
.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 personIdTuple = Tuple.create()
+ .set("id", 1);
+ Tuple insertedPerson = personTableView.get(personIdTuple);
System.out.println("Person name: " +
insertedPerson.stringValue("name"));
} finally {
diff --git
a/examples/java/src/main/java/org/apache/ignite/example/tx/TransactionsExample.java
b/examples/java/src/main/java/org/apache/ignite/example/tx/TransactionsExample.java
index 3f6f16d6b33..dd05dcbb321 100644
---
a/examples/java/src/main/java/org/apache/ignite/example/tx/TransactionsExample.java
+++
b/examples/java/src/main/java/org/apache/ignite/example/tx/TransactionsExample.java
@@ -75,7 +75,7 @@ public class TransactionsExample {
// 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 -> {
@@ -84,7 +84,7 @@ public class TransactionsExample {
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 ->
@@ -95,7 +95,7 @@ public class TransactionsExample {
})
);
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);
//--------------------------------------------------------------------------------------
//
