[ignite-3] branch main updated (8ffe0420d7 -> 99f3cdf7a1)

[ib...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ibessonov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


    from 8ffe0420d7 IGNITE-17612 Fix TableScanNode data propagation - Fixes #1224.
     add 99f3cdf7a1 IGNITE-17893 Implement RAFT snapshot streaming sender for MV data (#1226)

No new revisions were added by this update.

Summary of changes:
 .../apache/ignite/internal/lock/AutoLockup.java}   |  17 +-
 .../ignite/internal/lock/ReusableLockLockup.java}  |  43 +-
 .../internal/lock/ReusableLockLockupTest.java}     |  48 ++-
 .../storage/ItRebalanceDistributedTest.java        |   4 +-
 .../runner/app/ItIgniteNodeRestartTest.java        |   4 +-
 .../org/apache/ignite/internal/app/IgniteImpl.java |   9 +-
 .../sql/engine/exec/MockedStructuresTest.java      |   8 +-
 modules/storage-api/build.gradle                   |   1 +
 modules/storage-api/pom.xml                        |   6 +
 .../apache/ignite/internal/storage/ReadResult.java |   4 +-
 .../org/apache/ignite/internal/storage/RowId.java  |   9 +
 .../ignite/distributed/ItTablePersistenceTest.java |   4 +-
 .../distributed/ItTxDistributedTestSingleNode.java |   6 +-
 .../distributed/TestPartitionDataStorage.java      |  99 +++++
 .../internal/table/distributed/TableManager.java   |  50 ++-
 .../distributed/command/UpdateAllCommand.java      |   2 +-
 .../distributed/raft/PartitionDataStorage.java     | 145 +++++++
 .../table/distributed/raft/PartitionListener.java  |  12 +-
 .../distributed/raft/snapshot/PartitionAccess.java |  31 ++
 .../raft/snapshot/PartitionAccessImpl.java         |  71 ++++
 .../snapshot/PartitionKey.java}                    |  56 ++-
 .../snapshot/message/SnapshotMvDataRequest.java    |   7 +
 .../snapshot/message/SnapshotMvDataResponse.java   |   3 +-
 .../raft/snapshot/outgoing/OutgoingSnapshot.java   | 316 ++++++++++++++-
 .../snapshot/outgoing/OutgoingSnapshotReader.java  |  10 +-
 .../OutgoingSnapshotRegistry.java}                 |  23 +-
 .../outgoing/OutgoingSnapshotsManager.java         | 139 ++++++-
 .../raft/snapshot/outgoing/PartitionSnapshots.java |  42 ++
 .../PartitionsSnapshots.java}                      |  15 +-
 .../SnapshotAwarePartitionDataStorage.java         | 144 +++++++
 .../table/distributed/TableManagerTest.java        |   4 +-
 .../raft/PartitionCommandListenerTest.java         |   3 +-
 .../raft/snapshot/PartitionAccessImplTest.java     |  86 ++++
 .../snapshot/outgoing/OutgoingSnapshotTest.java    | 447 +++++++++++++++++++++
 .../outgoing/OutgoingSnapshotsManagerTest.java     |  81 ++++
 .../SnapshotAwarePartitionDataStorageTest.java     | 277 +++++++++++++
 .../table/impl/DummyInternalTableImpl.java         |   3 +-
 37 files changed, 2065 insertions(+), 164 deletions(-)
 copy modules/{cli/src/main/java/org/apache/ignite/internal/cli/core/repl/config/ClientConnectorConfig.java => core/src/main/java/org/apache/ignite/internal/lock/AutoLockup.java} (62%)
 copy modules/{cli/src/main/java/org/apache/ignite/internal/cli/core/exception/CommandExecutionException.java => core/src/main/java/org/apache/ignite/internal/lock/ReusableLockLockup.java} (51%)
 copy modules/{raft/src/test/java/org/apache/ignite/raft/jraft/entity/BallotTest.java => core/src/test/java/org/apache/ignite/internal/lock/ReusableLockLockupTest.java} (54%)
 create mode 100644 modules/table/src/integrationTest/java/org/apache/ignite/distributed/TestPartitionDataStorage.java
 create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/PartitionDataStorage.java
 create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/PartitionAccessImpl.java
 copy modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{replicator/TablePartitionId.java => raft/snapshot/PartitionKey.java} (57%)
 copy modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/{message/SnapshotRequestMessage.java => outgoing/OutgoingSnapshotRegistry.java} (63%)
 create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/PartitionSnapshots.java
 copy modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/{PartitionAccess.java => outgoing/PartitionsSnapshots.java} (67%)
 create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/SnapshotAwarePartitionDataStorage.java
 create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/PartitionAccessImplTest.java
 create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/OutgoingSnapshotTest.java
 create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/OutgoingSnapshotsManagerTest.java
 create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/SnapshotAwarePartitionDataStorageTest.java