From 0d30c2916a4d855154cd468afc194987612a624e Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Fri, 17 Apr 2026 06:43:31 +0200 Subject: [PATCH 01/14] bulkUpsert method implementation for InMemoryTable Currently, the bulkUpsert method is not supported by InMemoryTable in any form. This makes testing code that uses this method difficult. This PR adds a trivial implementation by re-calling the save method. --- .../tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java b/repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java index 0d19a40b..5326e7df 100644 --- a/repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java +++ b/repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java @@ -97,6 +97,11 @@ public void update(Entity.Id id, Changeset changeset) { transaction.getTransactionLocal().firstLevelCache(tableDescriptor).remove(id); } + @Override + public void bulkUpsert(List input, BulkParams params) { + input.forEach(this::save); + } + @Override public List find( @Nullable String indexName, From c7d1130febe208d0a21189314778739644935f01 Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Fri, 17 Apr 2026 06:47:07 +0200 Subject: [PATCH 02/14] Test bulkUpdate InMemoryRepositoryTest.java --- .../test/inmemory/InMemoryRepositoryTest.java | 35 +++++++++++++++++-- 1 file changed, 33 insertions(+), 2 deletions(-) diff --git a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java index cadfaa05..c1eed10a 100644 --- a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java +++ b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java @@ -1,11 +1,42 @@ package tech.ydb.yoj.repository.test.inmemory; +import org.junit.Test; import tech.ydb.yoj.repository.db.Repository; +import tech.ydb.yoj.repository.db.bulk.BulkParams; import tech.ydb.yoj.repository.test.RepositoryTest; +import tech.ydb.yoj.repository.test.sample.model.Project; + +import java.util.List; + +import static org.assertj.core.api.Assertions.assertThat; + +public class InMemoryRepositoryTest extends RepositoryTest { -public class InMemoryRepositoryTest extends RepositoryTest { @Override - protected Repository createTestRepository() { + protected Repository createDb() { return new TestInMemoryRepository(); } + + @Test + public void bulkUpsert() { + Project.Id existingId = new Project.Id("existing"); + Project.Id newId = new Project.Id("new"); + + db.tx(() -> db.projects().save(new Project(existingId, "before"))); + + db.tx(() -> db.projects().bulkUpsert( + List.of( + new Project(existingId, "after"), + new Project(newId, "created") + ), + BulkParams.DEFAULT + )); + + List projects = db.tx(() -> db.projects().findAll()); + + assertThat(projects).containsExactlyInAnyOrder( + new Project(existingId, "after"), + new Project(newId, "created") + ); + } } From fa40049c57fc71b78e17306b482c61bea740c166 Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Fri, 17 Apr 2026 06:51:29 +0200 Subject: [PATCH 03/14] Update InMemoryRepositoryTest.java --- .../yoj/repository/test/inmemory/InMemoryRepositoryTest.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java index c1eed10a..490aead8 100644 --- a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java +++ b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java @@ -10,10 +10,9 @@ import static org.assertj.core.api.Assertions.assertThat; -public class InMemoryRepositoryTest extends RepositoryTest { - +public class InMemoryRepositoryTest extends RepositoryTest { @Override - protected Repository createDb() { + protected Repository createTestRepository() { return new TestInMemoryRepository(); } From 071d7898f11d723f2b0fec2095bccd0575789604 Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Fri, 17 Apr 2026 06:56:08 +0200 Subject: [PATCH 04/14] Update InMemoryTable.java --- .../tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java | 1 + 1 file changed, 1 insertion(+) diff --git a/repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java b/repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java index 5326e7df..16c7ab20 100644 --- a/repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java +++ b/repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java @@ -18,6 +18,7 @@ import tech.ydb.yoj.repository.db.TableQueryBuilder; import tech.ydb.yoj.repository.db.TableQueryImpl; import tech.ydb.yoj.repository.db.ViewSchema; +import tech.ydb.yoj.repository.db.bulk.BulkParams; import tech.ydb.yoj.repository.db.cache.FirstLevelCache; import tech.ydb.yoj.repository.db.exception.IllegalTransactionIsolationLevelException; import tech.ydb.yoj.repository.db.list.InMemoryQueries; From e46f552086867b2e901d139c3a7b28950d0b7715 Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Tue, 21 Apr 2026 06:18:18 +0200 Subject: [PATCH 05/14] fix CR: move bulkInsert test from YdbRepositoryIntegrationTest and InMemoryRepositoryTest into RepositoryTest --- .../test/inmemory/InMemoryRepositoryTest.java | 30 ------------------- .../yoj/repository/test/RepositoryTest.java | 20 +++++++++++++ .../ydb/YdbRepositoryIntegrationTest.java | 20 ------------- 3 files changed, 20 insertions(+), 50 deletions(-) diff --git a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java index 490aead8..cadfaa05 100644 --- a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java +++ b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/InMemoryRepositoryTest.java @@ -1,41 +1,11 @@ package tech.ydb.yoj.repository.test.inmemory; -import org.junit.Test; import tech.ydb.yoj.repository.db.Repository; -import tech.ydb.yoj.repository.db.bulk.BulkParams; import tech.ydb.yoj.repository.test.RepositoryTest; -import tech.ydb.yoj.repository.test.sample.model.Project; - -import java.util.List; - -import static org.assertj.core.api.Assertions.assertThat; public class InMemoryRepositoryTest extends RepositoryTest { @Override protected Repository createTestRepository() { return new TestInMemoryRepository(); } - - @Test - public void bulkUpsert() { - Project.Id existingId = new Project.Id("existing"); - Project.Id newId = new Project.Id("new"); - - db.tx(() -> db.projects().save(new Project(existingId, "before"))); - - db.tx(() -> db.projects().bulkUpsert( - List.of( - new Project(existingId, "after"), - new Project(newId, "created") - ), - BulkParams.DEFAULT - )); - - List projects = db.tx(() -> db.projects().findAll()); - - assertThat(projects).containsExactlyInAnyOrder( - new Project(existingId, "after"), - new Project(newId, "created") - ); - } } diff --git a/repository-test/src/main/java/tech/ydb/yoj/repository/test/RepositoryTest.java b/repository-test/src/main/java/tech/ydb/yoj/repository/test/RepositoryTest.java index 362f079e..b43c1a62 100644 --- a/repository-test/src/main/java/tech/ydb/yoj/repository/test/RepositoryTest.java +++ b/repository-test/src/main/java/tech/ydb/yoj/repository/test/RepositoryTest.java @@ -3360,6 +3360,26 @@ public void nullOrderingDesc() { assertThat(results.subList(2, 4)).containsExactlyInAnyOrder(e2, e4); } + @Test + public void bulkInserts() { + var id1 = new Bubble.Id("a", "b"); + var id2 = new Bubble.Id("c", "d"); + + db.tx(() -> { + db.bubbles().bulkUpsert( + List.of(new Bubble(id1, "oldA", "oldB", "oldC"), new Bubble(id2, "oldA", "oldB", "oldC")), + BulkParams.DEFAULT + ); + }); + + db.readOnly().run(() -> { + var first = this.db.bubbles().find(id1); + assertThat(first).isNotNull(); + assertThat(first.getFieldA()).isEqualTo("oldA"); + assertThat(this.db.bubbles().find(id2)).isNotNull(); + }); + } + @Test public void loggingMdcContextEvenOnException() { Logger log = LoggerFactory.getLogger("RepositoryTest"); diff --git a/repository-ydb-v2/src/test/java/tech/ydb/yoj/repository/ydb/YdbRepositoryIntegrationTest.java b/repository-ydb-v2/src/test/java/tech/ydb/yoj/repository/ydb/YdbRepositoryIntegrationTest.java index 5b1963b1..cbe3caf1 100644 --- a/repository-ydb-v2/src/test/java/tech/ydb/yoj/repository/ydb/YdbRepositoryIntegrationTest.java +++ b/repository-ydb-v2/src/test/java/tech/ydb/yoj/repository/ydb/YdbRepositoryIntegrationTest.java @@ -804,26 +804,6 @@ public void complexInPredicate() { }); } - @Test - public void bulkInserts() { - var id1 = new Bubble.Id("a", "b"); - var id2 = new Bubble.Id("c", "d"); - - db.tx(() -> { - db.bubbles().bulkUpsert( - List.of(new Bubble(id1, "oldA", "oldB", "oldC"), new Bubble(id2, "oldA", "oldB", "oldC")), - BulkParams.DEFAULT - ); - }); - - db.readOnly().run(() -> { - var first = this.db.bubbles().find(id1); - assertThat(first).isNotNull(); - assertThat(first.getFieldA()).isEqualTo("oldA"); - assertThat(this.db.bubbles().find(id2)).isNotNull(); - }); - } - @Test public void testTransactionTakesTimeoutFromGrpcContext() { int[] timeoutsMin = IntStream.range(3, 12).toArray(); From 23f4bca43bcfe87035f585e0b9861d0d0a743a4b Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Tue, 21 Apr 2026 06:20:31 +0200 Subject: [PATCH 06/14] fix build --- .../main/java/tech/ydb/yoj/repository/test/RepositoryTest.java | 1 + .../ydb/yoj/repository/ydb/YdbRepositoryIntegrationTest.java | 1 - 2 files changed, 1 insertion(+), 1 deletion(-) diff --git a/repository-test/src/main/java/tech/ydb/yoj/repository/test/RepositoryTest.java b/repository-test/src/main/java/tech/ydb/yoj/repository/test/RepositoryTest.java index b43c1a62..70d6dd8c 100644 --- a/repository-test/src/main/java/tech/ydb/yoj/repository/test/RepositoryTest.java +++ b/repository-test/src/main/java/tech/ydb/yoj/repository/test/RepositoryTest.java @@ -35,6 +35,7 @@ import tech.ydb.yoj.repository.db.Tx; import tech.ydb.yoj.repository.db.TxManager; import tech.ydb.yoj.repository.db.TxOptions; +import tech.ydb.yoj.repository.db.bulk.BulkParams; import tech.ydb.yoj.repository.db.common.CommonConverters; import tech.ydb.yoj.repository.db.common.CommonConverters.EnumDeserializer; import tech.ydb.yoj.repository.db.exception.ConversionException; diff --git a/repository-ydb-v2/src/test/java/tech/ydb/yoj/repository/ydb/YdbRepositoryIntegrationTest.java b/repository-ydb-v2/src/test/java/tech/ydb/yoj/repository/ydb/YdbRepositoryIntegrationTest.java index cbe3caf1..aa375fd6 100644 --- a/repository-ydb-v2/src/test/java/tech/ydb/yoj/repository/ydb/YdbRepositoryIntegrationTest.java +++ b/repository-ydb-v2/src/test/java/tech/ydb/yoj/repository/ydb/YdbRepositoryIntegrationTest.java @@ -59,7 +59,6 @@ import tech.ydb.yoj.repository.db.StdTxManager; import tech.ydb.yoj.repository.db.TableDescriptor; import tech.ydb.yoj.repository.db.Tx; -import tech.ydb.yoj.repository.db.bulk.BulkParams; import tech.ydb.yoj.repository.db.common.CommonConverters; import tech.ydb.yoj.repository.db.exception.ConversionException; import tech.ydb.yoj.repository.db.exception.RetryableException; From 1d747fcf6f4d1e5b0f64b700c08aece9df11044e Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Tue, 21 Apr 2026 06:25:23 +0200 Subject: [PATCH 07/14] remove UnsupportedOperaton default --- .../src/main/java/tech/ydb/yoj/repository/db/Table.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java b/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java index 212f23f3..9f18b1c7 100644 --- a/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java +++ b/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java @@ -266,10 +266,8 @@ default ViewListResult list(Class viewType, List return ViewListResult.forPage(request, viewType, nextPage); } - default void bulkUpsert(List input, BulkParams params) { - throw new UnsupportedOperationException(); - } - + void bulkUpsert(List input, BulkParams params); + @InternalApi default List postLoad(List list) { return list.stream().map(this::postLoad).collect(Collectors.toList()); From a92d6dbb863d940c312478c1a992bb3f3320a8c1 Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Tue, 21 Apr 2026 06:28:50 +0200 Subject: [PATCH 08/14] fix build --- .../ydb/yoj/repository/test/sample/TestEntityOperations.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java b/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java index 534409a2..de74430c 100644 --- a/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java +++ b/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java @@ -152,6 +152,11 @@ public List findViewWithEmbeddedAIn(Collection possibleA public void updateEmbedded(TypeFreak.Id id, TypeFreak.Embedded newEmbedded) { modifyIfPresent(id, t -> t.withEmbedded(newEmbedded)); } + + @Override + public void bulkUpsert(List input, BulkParams params) { + throw new UnsupportedOperationException(); + } } interface BubbleTable extends Table { From 5bb18088a0baea3854395ef7ca24c26ccb841cbf Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Tue, 21 Apr 2026 06:30:14 +0200 Subject: [PATCH 09/14] fix build --- .../ydb/yoj/repository/test/sample/TestEntityOperations.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java b/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java index de74430c..70620da6 100644 --- a/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java +++ b/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java @@ -154,7 +154,7 @@ public void updateEmbedded(TypeFreak.Id id, TypeFreak.Embedded newEmbedded) { } @Override - public void bulkUpsert(List input, BulkParams params) { + public void bulkUpsert(List input, BulkParams params) { throw new UnsupportedOperationException(); } } From b7754ce7a74b3521cb67d316d9794338299f6394 Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Tue, 21 Apr 2026 06:34:41 +0200 Subject: [PATCH 10/14] fix build --- .../test/inmemory/TestInMemoryRepository.java | 15 +++++++++++++++ .../test/sample/TestEntityOperations.java | 5 ----- .../java/tech/ydb/yoj/repository/db/Table.java | 4 +++- 3 files changed, 18 insertions(+), 6 deletions(-) diff --git a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java index 7b356790..6effa010 100644 --- a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java +++ b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java @@ -153,6 +153,11 @@ private static class Supabubble2InMemoryTable extends AbstractDelegatingTable target) { super(target); } + + @Override + public void bulkUpsert(List input, BulkParams params) { + input.forEach(this::save); + } } private static class BubbleTableImpl extends AbstractDelegatingTable implements BubbleTable { @@ -164,6 +169,11 @@ public BubbleTableImpl(Table target) { public void updateSomeFields(Set ids, String fieldA, String fieldB) { throw new UnsupportedOperationException("not for in-memory"); } + + @Override + public void bulkUpsert(List input, BulkParams params) { + input.forEach(this::save); + } } private static class IndexedTableImpl extends AbstractDelegatingTable implements IndexedTable { @@ -175,5 +185,10 @@ protected IndexedTableImpl(Table target) { public void updateSomeFields(Set ids, String value, String value2) { throw new UnsupportedOperationException("not for in-memory"); } + + @Override + public void bulkUpsert(List input, BulkParams params) { + input.forEach(this::save); + } } } diff --git a/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java b/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java index 70620da6..534409a2 100644 --- a/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java +++ b/repository-test/src/main/java/tech/ydb/yoj/repository/test/sample/TestEntityOperations.java @@ -152,11 +152,6 @@ public List findViewWithEmbeddedAIn(Collection possibleA public void updateEmbedded(TypeFreak.Id id, TypeFreak.Embedded newEmbedded) { modifyIfPresent(id, t -> t.withEmbedded(newEmbedded)); } - - @Override - public void bulkUpsert(List input, BulkParams params) { - throw new UnsupportedOperationException(); - } } interface BubbleTable extends Table { diff --git a/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java b/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java index 9f18b1c7..57c3287d 100644 --- a/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java +++ b/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java @@ -266,7 +266,9 @@ default ViewListResult list(Class viewType, List return ViewListResult.forPage(request, viewType, nextPage); } - void bulkUpsert(List input, BulkParams params); + default void bulkUpsert(List input, BulkParams params) { + throw new UnsupportedOperationException(); + } @InternalApi default List postLoad(List list) { From a8c085f26adaa9fe14b9d962d3f47f8ab7a14c11 Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Tue, 21 Apr 2026 06:39:22 +0200 Subject: [PATCH 11/14] fix build --- .../repository/test/inmemory/TestInMemoryRepository.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java index 6effa010..4c5445b5 100644 --- a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java +++ b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java @@ -4,6 +4,7 @@ import tech.ydb.yoj.repository.db.RepositoryTransaction; import tech.ydb.yoj.repository.db.Table; import tech.ydb.yoj.repository.db.TxOptions; +import tech.ydb.yoj.repository.db.bulk.BulkParams; import tech.ydb.yoj.repository.db.common.CommonConverters; import tech.ydb.yoj.repository.db.json.JacksonJsonConverter; import tech.ydb.yoj.repository.test.sample.TestEntityOperations; @@ -155,7 +156,7 @@ public Supabubble2InMemoryTable(Table target) { } @Override - public void bulkUpsert(List input, BulkParams params) { + public void bulkUpsert(List input, BulkParams params) { input.forEach(this::save); } } @@ -171,7 +172,7 @@ public void updateSomeFields(Set ids, String fieldA, String fieldB) { } @Override - public void bulkUpsert(List input, BulkParams params) { + public void bulkUpsert(List input, BulkParams params) { input.forEach(this::save); } } @@ -187,7 +188,7 @@ public void updateSomeFields(Set ids, String value, String val } @Override - public void bulkUpsert(List input, BulkParams params) { + public void bulkUpsert(List input, BulkParams params) { input.forEach(this::save); } } From b5874958e576e1687cb24fad30963304e7c30954 Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Tue, 21 Apr 2026 06:41:24 +0200 Subject: [PATCH 12/14] fix build --- .../ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java | 1 + 1 file changed, 1 insertion(+) diff --git a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java index 4c5445b5..550326b7 100644 --- a/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java +++ b/repository-inmemory/src/test/java/tech/ydb/yoj/repository/test/inmemory/TestInMemoryRepository.java @@ -32,6 +32,7 @@ import tech.ydb.yoj.repository.test.sample.model.VersionedAliasedEntity; import tech.ydb.yoj.repository.test.sample.model.VersionedEntity; +import java.util.List; import java.util.Set; public class TestInMemoryRepository extends InMemoryRepository { From 4c5cb0a24e397c77eb6f606b1ef3f1fc6543e7c8 Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Tue, 21 Apr 2026 06:45:46 +0200 Subject: [PATCH 13/14] remove useless change --- repository/src/main/java/tech/ydb/yoj/repository/db/Table.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java b/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java index 57c3287d..7edf89d9 100644 --- a/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java +++ b/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java @@ -269,7 +269,7 @@ default ViewListResult list(Class viewType, List default void bulkUpsert(List input, BulkParams params) { throw new UnsupportedOperationException(); } - + @InternalApi default List postLoad(List list) { return list.stream().map(this::postLoad).collect(Collectors.toList()); From 7278899c27161c9822050a284e038a99ade76692 Mon Sep 17 00:00:00 2001 From: Anton Tolstov Date: Tue, 21 Apr 2026 06:46:17 +0200 Subject: [PATCH 14/14] remove useless change --- repository/src/main/java/tech/ydb/yoj/repository/db/Table.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java b/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java index 7edf89d9..212f23f3 100644 --- a/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java +++ b/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java @@ -269,7 +269,7 @@ default ViewListResult list(Class viewType, List default void bulkUpsert(List input, BulkParams params) { throw new UnsupportedOperationException(); } - + @InternalApi default List postLoad(List list) { return list.stream().map(this::postLoad).collect(Collectors.toList());