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 b2e135c270 IGNITE-17782 `sql` with white space in repl fails (#1157)
add 22aa8bdb9e IGNITE-17083 Skeleton classes for RAFT snapshots in
partitions & new method in MvPartitionStorage. (#1160)
No new revisions were added by this update.
Summary of changes:
.../org/apache/ignite/hlc/HybridTimestamp.java | 2 +-
.../serialization/BaseMethodNameResolver.java | 2 +-
.../ignite/internal/schema/ByteBufferRow.java | 2 +-
.../internal/storage/MvPartitionStorage.java | 8 ++
.../org/apache/ignite/internal/storage/RowId.java | 26 +++-
.../storage/AbstractMvPartitionStorageTest.java | 54 ++++----
.../storage/impl/TestMvPartitionStorage.java | 9 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 9 ++
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 47 +++++--
.../internal/table/distributed/TableManager.java | 3 +
.../table/distributed/TableMessageGroup.java | 79 ++++++++---
.../raft/snapshot/PartitionSnapshotStorage.java | 103 ++++++++++++--
.../snapshot/PartitionSnapshotStorageFactory.java | 30 ++++-
.../raft/snapshot/PartitionSnapshotWriter.java | 2 +-
.../distributed/raft/snapshot/SnapshotUri.java | 97 ++++++++++++++
.../snapshot/incoming/IncomingSnapshotCopier.java | 120 +++++++++++++++++
.../IncomingSnapshotReader.java} | 62 ++++-----
.../snapshot/message/SnapshotMetaRequest.java} | 8 +-
.../snapshot/message/SnapshotMetaResponse.java} | 13 +-
.../snapshot/message/SnapshotMvDataRequest.java} | 8 +-
.../snapshot/message/SnapshotMvDataResponse.java | 72 ++++++++++
.../SnapshotRequestMessage.java} | 15 ++-
.../snapshot/message/SnapshotTxDataRequest.java} | 8 +-
.../snapshot/message/SnapshotTxDataResponse.java} | 34 +++--
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 61 +++++++++
.../OutgoingSnapshotReader.java} | 79 ++++++-----
.../outgoing/OutgoingSnapshotsManager.java | 148 +++++++++++++++++++++
.../StartupPartitionSnapshotReader.java} | 20 ++-
28 files changed, 924 insertions(+), 197 deletions(-)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/SnapshotUri.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/incoming/IncomingSnapshotCopier.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/{InitPartitionSnapshotReader.java
=> incoming/IncomingSnapshotReader.java} (59%)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{replication/request/ReadWriteSwapRowReplicaRequest.java
=> raft/snapshot/message/SnapshotMetaRequest.java} (77%)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{message/HasDataResponse.java
=> raft/snapshot/message/SnapshotMetaResponse.java} (73%)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{replication/request/ReadWriteSwapRowReplicaRequest.java
=> raft/snapshot/message/SnapshotMvDataRequest.java} (77%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message/SnapshotMvDataResponse.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/{PartitionAccess.java
=> message/SnapshotRequestMessage.java} (78%)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{replication/request/ReadWriteSwapRowReplicaRequest.java
=> raft/snapshot/message/SnapshotTxDataRequest.java} (77%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/QueryStartResponse.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message/SnapshotTxDataResponse.java}
(60%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/OutgoingSnapshot.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/{InitPartitionSnapshotReader.java
=> outgoing/OutgoingSnapshotReader.java} (50%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/OutgoingSnapshotsManager.java
rename
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/{InitPartitionSnapshotReader.java
=> startup/StartupPartitionSnapshotReader.java} (79%)
