tkalkirill commented on code in PR #976:
URL: https://github.com/apache/ignite-3/pull/976#discussion_r938572880
##########
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/PersistentPageMemoryTableStorage.java:
##########
@@ -164,8 +170,113 @@ public void destroy() throws StorageException {
/** {@inheritDoc} */
@Override
- public PageMemoryMvPartitionStorage createMvPartitionStorage(int
partitionId) {
- throw new UnsupportedOperationException("Not supported yet");
+ public PersistentPageMemoryMvPartitionStorage createMvPartitionStorage(int
partitionId) {
+ TableView tableView = tableCfg.value();
+
+ FilePageStore filePageStore = ensurePartitionFilePageStore(tableView,
partitionId);
+
+ CheckpointManager checkpointManager = dataRegion.checkpointManager();
+
+ CheckpointTimeoutLock checkpointTimeoutLock =
checkpointManager.checkpointTimeoutLock();
+
+ checkpointTimeoutLock.checkpointReadLock();
+
+ try {
+ PersistentPageMemory persistentPageMemory =
dataRegion.pageMemory();
+
+ int grpId = tableView.tableId();
+
+ CheckpointProgress lastCheckpointProgress =
checkpointManager.lastCheckpointProgress();
+
+ UUID checkpointId = lastCheckpointProgress == null ? null :
lastCheckpointProgress.id();
+
+ PartitionMeta meta =
dataRegion.partitionMetaManager().readOrCreateMeta(
+ checkpointId,
+ new GroupPartitionId(grpId, partitionId),
+ filePageStore
+ );
+
+ dataRegion.partitionMetaManager().addMeta(new
GroupPartitionId(grpId, partitionId), meta);
+
+ filePageStore.pages(meta.pageCount());
+
+ filePageStore.setPageAllocationListener(pageIdx -> {
+ assert checkpointTimeoutLock.checkpointLockIsHeldByThread();
+
+ CheckpointProgress last =
checkpointManager.lastCheckpointProgress();
+
+ meta.incrementPageCount(last == null ? null : last.id());
+ });
+
+ boolean initNewVersionChainTree = false;
+
+ if (meta.versionChainTreeRootPageId() == 0) {
+ meta.versionChainTreeRootPageId(checkpointId,
persistentPageMemory.allocatePage(grpId, partitionId, FLAG_AUX));
+
+ initNewVersionChainTree = true;
+ }
+
+ boolean initVersionChainFreeList = false;
+
+ if (meta.versionChainFreeListRootPageId() == 0) {
+ meta.versionChainFreeListRootPageId(checkpointId,
persistentPageMemory.allocatePage(grpId, partitionId, FLAG_AUX));
+
+ initVersionChainFreeList = true;
+ }
+
+ boolean initRowVersionFreeList = false;
+
+ if (meta.rowVersionFreeListRootPageId() == 0) {
+ meta.rowVersionFreeListRootPageId(checkpointId,
persistentPageMemory.allocatePage(grpId, partitionId, FLAG_AUX));
+
+ initRowVersionFreeList = true;
+ }
+
+ VersionChainFreeList versionChainFreeList =
createVersionChainFreeList(
+ tableView,
+ partitionId,
+ meta.versionChainFreeListRootPageId(),
+ initVersionChainFreeList
+ );
+
+ autoCloseables.add(versionChainFreeList::close);
+
+ RowVersionFreeList rowVersionFreeList = createRowVersionFreeList(
+ tableView,
+ partitionId,
+ versionChainFreeList,
+ meta.rowVersionFreeListRootPageId(),
+ initRowVersionFreeList
+ );
+
+ autoCloseables.add(rowVersionFreeList::close);
+
+ VersionChainTree versionChainTree = createVersionChainTree(
+ tableView,
+ partitionId,
+ versionChainFreeList,
+ meta.versionChainTreeRootPageId(),
+ initNewVersionChainTree
+ );
+
+ return new PersistentPageMemoryMvPartitionStorage(
+ partitionId,
+ tableView,
+ dataRegion.pageMemory(),
+ versionChainFreeList,
+ rowVersionFreeList,
+ versionChainTree,
+ checkpointTimeoutLock
+ );
+ } catch (IgniteInternalCheckedException e) {
+ throw new StorageException(
+ String.format("Error getting or creating partition
metadata [tableName=%s, partitionId=%s]", tableView.name(),
Review Comment:
fix it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
