This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-16962
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from d566c1bd9 Styles.
add 678a8ce9b IGNITE-16700 Muted testBalance
add 6fdb7c4bc IGNITE-16984 [Native Persistence 3.0] Porting a checkpoint
and related code, part 4 (#822)
add 1d76a6ee4 IGNITE-16933 PageMemory-based MV storage implementation
(#814)
add 36d8e99c0 IGNITE-16965 SQL API: Implement synchronous SQL API (#830)
add da2738b57 IGNITE-17068 Sql: Fix AsyncResultSet.fetchNextPage semantics
(#841)
add ee862dbe4 Merge branch 'main' into ignite-16962
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/ignite/sql/ResultSet.java | 15 +-
.../main/java/org/apache/ignite/sql/Session.java | 4 +
.../main/java/org/apache/ignite/sql/Statement.java | 10 +
.../apache/ignite/sql/async/AsyncResultSet.java | 23 +
.../ignite/internal/util/worker/IgniteWorker.java | 16 +-
.../testframework/BaseIgniteAbstractTest.java | 7 +-
.../persistence/ItBplusTreePageMemoryImplTest.java | 6 +-
.../ItBplusTreeReuseListPageMemoryImplTest.java | 6 +-
.../tree/ItBplusTreeReplaceRemoveRaceTest.java | 2 -
.../pagememory/tree/ItBplusTreeSelfTest.java | 11 +-
.../internal/pagememory/PageMemoryDataRegion.java | 5 +-
.../PageMemoryCheckpointConfigurationSchema.java | 5 +-
.../pagememory/datapage/DataPageReader.java | 97 ++++
.../datapage/NonFragmentableDataPageReader.java | 134 +++++
.../pagememory/datapage/PageMemoryTraversal.java | 50 ++
.../datapage/ReadPageMemoryRowValue.java | 137 ++++++
.../internal/pagememory/freelist/FreeList.java | 6 +-
.../pagememory/impl/PageMemoryNoStoreImpl.java | 11 +-
.../internal/pagememory/io/AbstractDataPageIo.java | 92 +++-
.../internal/pagememory/io/DataPagePayload.java | 9 +
.../pagememory/persistence/PageMemoryEx.java | 118 -----
.../pagememory/persistence/PageMemoryImpl.java | 133 +++--
.../persistence/checkpoint/CheckpointManager.java | 208 ++++++++
.../checkpoint/CheckpointReadWriteLock.java | 9 +-
.../persistence/checkpoint/CheckpointWorkflow.java | 11 +-
.../persistence/checkpoint/Checkpointer.java | 39 +-
.../ReentrantReadWriteLockWithTracking.java | 2 +-
...ointTestUtils.java => PageMemoryTestUtils.java} | 25 +-
.../pagememory/freelist/AbstractFreeListTest.java | 2 -
.../pagememory/impl/PageMemoryNoLoadSelfTest.java | 24 +-
.../persistence/PageMemoryImplNoLoadTest.java | 225 +++++++--
.../checkpoint/CheckpointManagerTest.java | 109 +++++
.../checkpoint/CheckpointTestUtils.java | 35 +-
.../checkpoint/CheckpointWorkflowTest.java | 23 +-
.../persistence/checkpoint/CheckpointerTest.java | 29 --
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 75 +--
.../internal/sql/api/ItSqlSynchronousApiTest.java | 240 +++++++++
.../ignite/internal/schema/ByteBufferRow.java | 10 +-
.../internal/sql/api/AsyncResultSetImpl.java | 55 +--
.../ignite/internal/sql/api/ResultSetImpl.java | 146 ++++++
.../ignite/internal/sql/api/SessionImpl.java | 22 +-
.../internal/sql/engine/IgniteSqlApiTest.java | 60 ++-
.../internal/storage/MvPartitionStorage.java | 13 +-
...ype.java => NoUncommittedVersionException.java} | 14 +-
.../storage/AbstractMvPartitionStorageTest.java | 542 ++++++++++++++++-----
.../internal/storage/BaseMvStoragesTest.java | 1 -
.../storage/basic/TestMvPartitionStorage.java | 8 +-
.../storage/basic/TestMvPartitionStorageTest.java | 16 +-
.../pagememory/AbstractPageMemoryDataRegion.java | 6 +-
.../pagememory/PageMemoryStorageEngine.java | 3 +-
.../storage/pagememory/PageMemoryTableStorage.java | 17 +-
.../internal/storage/pagememory/TableTree.java | 4 +-
.../pagememory/VolatilePageMemoryDataRegion.java | 119 ++++-
.../pagememory/VolatilePageMemoryTableStorage.java | 2 +-
.../internal/storage/pagememory/mv/LinkRowId.java} | 36 +-
.../mv/PageMemoryMvPartitionStorage.java | 521 ++++++++++++++++++++
.../PageMemoryMvStorageIoModule.java} | 24 +-
.../storage/pagememory/mv/PartitionlessLinks.java | 134 +++++
.../pagememory/mv/ReadLatestRowVersion.java | 95 ++++
.../pagememory/mv/ReadRowVersionValue.java} | 17 +-
.../RowIdIsInvalidForModificationsException.java} | 11 +-
.../internal/storage/pagememory/mv/RowVersion.java | 180 +++++++
.../RowVersionFreeList.java} | 80 ++-
.../pagememory/mv/ScanVersionChainByTimestamp.java | 120 +++++
.../internal/storage/pagememory/mv/Timestamps.java | 70 +++
.../storage/pagememory/mv/TransactionIds.java | 57 +++
.../storage/pagememory/mv/VersionChain.java | 107 ++++
.../pagememory/mv/VersionChainDataPageReader.java | 84 ++++
.../VersionChainFreeList.java} | 91 +++-
.../storage/pagememory/mv/VersionChainLink.java} | 24 +-
.../storage/pagememory/mv/VersionChainTree.java | 114 +++++
.../storage/pagememory/mv/io/RowVersionDataIo.java | 106 ++++
.../pagememory/mv/io/VersionChainDataIo.java | 95 ++++
.../pagememory/mv/io/VersionChainInnerIo.java | 86 ++++
.../{io/RowIo.java => mv/io/VersionChainIo.java} | 14 +-
.../io/VersionChainLeafIo.java} | 56 +--
.../io/VersionChainMetaIo.java} | 16 +-
...ache.ignite.internal.pagememory.io.PageIoModule | 1 +
.../PageMemoryMvPartitionStorageTest.java} | 104 ++--
.../pagememory/mv/PartitionlessLinksTest.java | 68 +++
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 4 +
.../rocksdb/RocksDbMvPartitionStorageTest.java | 9 +-
.../ignite/internal/table/TxAbstractTest.java | 2 +-
.../org/apache/ignite/internal/tx/Timestamp.java | 12 +-
84 files changed, 4459 insertions(+), 870 deletions(-)
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/datapage/DataPageReader.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/datapage/NonFragmentableDataPageReader.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/datapage/PageMemoryTraversal.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/datapage/ReadPageMemoryRowValue.java
delete mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PageMemoryEx.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/CheckpointManager.java
copy
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/{persistence/checkpoint/CheckpointTestUtils.java
=> PageMemoryTestUtils.java} (59%)
create mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/CheckpointManagerTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/api/ItSqlSynchronousApiTest.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/ResultSetImpl.java
copy
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/{OperationType.java
=> NoUncommittedVersionException.java} (76%)
copy
modules/{client/src/main/java/org/apache/ignite/internal/client/PayloadReader.java
=>
storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/LinkRowId.java}
(57%)
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/PageMemoryMvPartitionStorage.java
copy
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/{PageMemoryStorageIoModule.java
=> mv/PageMemoryMvStorageIoModule.java} (57%)
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/PartitionlessLinks.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/ReadLatestRowVersion.java
copy
modules/{cli/src/integrationTest/java/org/apache/ignite/cli/NoOpHandler.java =>
storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/ReadRowVersionValue.java}
(66%)
copy
modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/ReflectionException.java
=>
storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/RowIdIsInvalidForModificationsException.java}
(73%)
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/RowVersion.java
copy
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/{TableFreeList.java
=> mv/RowVersionFreeList.java} (53%)
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/ScanVersionChainByTimestamp.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/Timestamps.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/TransactionIds.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/VersionChain.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/VersionChainDataPageReader.java
copy
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/{TableFreeList.java
=> mv/VersionChainFreeList.java} (51%)
copy
modules/{configuration/src/main/java/org/apache/ignite/internal/configuration/storage/StorageException.java
=>
storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/VersionChainLink.java}
(67%)
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/VersionChainTree.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/io/RowVersionDataIo.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/io/VersionChainDataIo.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/io/VersionChainInnerIo.java
copy
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/{io/RowIo.java
=> mv/io/VersionChainIo.java} (77%)
copy
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/{io/TableLeafIo.java
=> mv/io/VersionChainLeafIo.java} (50%)
copy
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/{io/TableMetaIo.java
=> mv/io/VersionChainMetaIo.java} (68%)
copy
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/{PageMemoryPartitionStorageTest.java
=> mv/PageMemoryMvPartitionStorageTest.java} (61%)
create mode 100644
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/mv/PartitionlessLinksTest.java
