You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sd...@apache.org on 2022/08/17 09:38:47 UTC
[ignite-3] branch ignite-17196 updated (5bb0534c29 -> df9928bae9)
This is an automated email from the ASF dual-hosted git repository.
sdanilov pushed a change to branch ignite-17196
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 5bb0534c29 IGNITE-17196 In-memory partition rebalance
discard 0cb436fd01 IGNITE-17196 In-memory partition rebalance
discard 409a2d556b IGNITE-17196 In-memory partition rebalance
discard 77f0950455 IGNITE-17196 In-memory partition rebalance
discard 30bde88a35 IGNITE-17196 In-memory partition rebalance
discard c17b1f6540 .
add 4a62798559 IGNITE-17439 Small enhancements for BinaryTuple (#965)
add 2a6d30702c IGNITE-17085 Support persistent case for page-memory-based MV storage (#976)
add e3cda0f342 IGNITE-17458 Fix issues under disabled tests - Fixes #973.
add 93461c72a0 IGNITE-17125 Add dynamic completers (#953)
add 288a608a8b IGNITE-17133 User flow for CLI (#943)
add 7e7ab4689d IGNITE-17308 Rework SortedIndexMvStorage interface (#979)
add 45195ad481 IGNITE-17225 Page replacement for persistent data region is not fully ported (#981)
add 188e63f2f6 IGNITE-17468 Rename SortedIndexMvStorage to SortedIndexStorage (#983)
add b92858cb8c IGNITE-14843 Updated obsolete TODOs
add 3f2dfb53c6 Muted TODOs related to new transaction protocol
add 55b0c176a1 IGNITE-17492 Fixed a link to RECOVERY.md
add dc71e4172a IGNITE-17493 Updated TODO in CmgRaftService
add a5662cc269 IGNITE-14937 Introduce index management (#980)
add 8e25fce53b IGNITE-17348 Added quit/exit command to Ignite3 CLI sql REPL. Fixes #971
add 10e977eb67 IGNITE-17233 Clarify cluster URL parameter name. Fixes #974
add 513dff3af8 IGNITE-17310 Add index related methods to the MvTableStorage interface (#992)
add 6c0bad95e9 IGNITE-17500 Fix minor issues in RocksDB-based partition storages (#994)
add d8e694eaa1 IGNITE-17077 persistedIndex implementation for PDS (#989)
add e051b8e679 IGNITE-17476 Implement configurations event handling by index manager (#993)
add 8551ac43dd IGNITE-17347 Add port parameters to Ignite3 CLI node start command. Fixes #961
add 8f5a3d59ee IGNITE-17461 Fixed an issue when status command could incorrectly handle invalid URLs. Fixes #991
add ddb6564864 IGNITE-17110 Auto-connect on the REPL start. Fixes #984
add 747ba20c96 IGNITE-17394 Added api method for retrieving mapping of partitions leaders. Fixes #997
add 078e0c5a73 IGNITE-17286 Added missed busy locks to get rid of resources leaking during table creation. Fixes #977
add 4547eac1d3 IGNITE-17475 FreeList metadata is not stored on the checkpoint (#995)
add 90d73bb16d IGNITE-17076 Common RowId implementation introduced (#1003)
add 32b1bae2c0 IGNITE-17532 Removed explicit flush after partition deletion in RockDB based partition storage. (#1011)
add 68f1dec4cc IGNITE-17466 Remove TableStorage and PartitionStorage implementations (#1012)
add e05eb06da4 IGNITE-17530 Fixed an issue that led to the inability to start a new node with custom config file. Fixes #1007
add 2da1474f73 .
add 1f1c5f3809 IGNITE-17196 In-memory partition rebalance
add d132ac3b53 IGNITE-17196 In-memory partition rebalance
add 64828ab778 IGNITE-17196 In-memory partition rebalance
add 63ba511cd3 IGNITE-17196 In-memory partition rebalance
add df9928bae9 IGNITE-17196 In-memory partition rebalance
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (5bb0534c29)
\
N -- N -- N refs/heads/ignite-17196 (df9928bae9)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../schemas/table/ColumnConfigurationSchema.java | 4 +-
.../table/HashIndexConfigurationSchema.java | 2 +-
.../table/PartialIndexConfigurationSchema.java | 38 --
.../table/TableIndexConfigurationSchema.java | 13 +-
.../apache/ignite/lang/IndexNotFoundException.java | 8 +-
.../builder/PartialIndexDefinitionBuilder.java | 72 ---
modules/cli/pom.xml | 6 +
.../org/apache/ignite/cli/IntegrationTestBase.java | 2 +-
.../configuration/ItShowConfigurationCallTest.java | 16 +-
.../ItUpdateConfigurationCallTest.java | 2 +-
...liCommandTestNotInitializedIntegrationBase.java | 10 +-
.../ItClusterStatusReplCommandInitializedTest.java | 2 +-
...ClusterStatusReplCommandNotInitializedTest.java | 2 +-
.../ItTopologyCommandInitializedClusterTest.java | 4 +-
...ItTopologyCommandNotInitializedClusterTest.java | 4 +-
.../configuration/ItConfigCommandTest.java | 16 +-
.../commands/questions/ItConnectToClusterTest.java | 141 +++++
.../cli/deprecated/ItClusterCommandTest.java | 2 +-
.../src/main/java/org/apache/ignite/cli/Main.java | 4 +
.../profile/CliConfigCreateProfileCall.java | 2 +-
.../cli/call/cluster/status/ClusterStatusCall.java | 2 +
.../call/configuration/ClusterConfigShowCall.java | 10 +-
.../ignite/cli/call/configuration/JsonString.java} | 25 +-
.../cli/call/configuration/NodeConfigShowCall.java | 10 +-
.../ignite/cli/call/connect/ConnectCall.java | 8 +-
.../ignite/cli/call/connect/ConnectCallInput.java | 21 +-
.../cli/call/node/status/NodeStatusCall.java | 2 +-
.../ignite/cli/commands/OptionsConstants.java} | 47 +-
.../commands/cliconfig/CliConfigSubCommand.java | 4 +-
.../config/ClusterConfigShowReplSubCommand.java | 41 +-
.../config/ClusterConfigShowSubCommand.java | 8 +-
.../config/ClusterConfigUpdateReplSubCommand.java | 39 +-
.../config/ClusterConfigUpdateSubCommand.java | 8 +-
.../cluster/init/ClusterInitReplSubCommand.java | 12 +-
.../cluster/init/ClusterInitSubCommand.java | 10 +-
.../status/ClusterStatusReplSubCommand.java | 11 +-
.../cluster/status/ClusterStatusSubCommand.java | 8 +-
.../cli/commands/connect/ConnectCommand.java | 7 +-
...ecorator.java => DefaultDecoratorRegistry.java} | 29 +-
.../cli/commands/decorators/JsonDecorator.java | 10 +-
...{ConfigDecorator.java => ProfileDecorator.java} | 2 +-
.../cli/commands/decorators/TableDecorator.java | 4 +-
.../node/config/NodeConfigShowReplSubCommand.java | 43 +-
.../node/config/NodeConfigShowSubCommand.java | 8 +-
.../config/NodeConfigUpdateReplSubCommand.java | 39 +-
.../node/config/NodeConfigUpdateSubCommand.java | 8 +-
.../node/status/NodeStatusReplSubCommand.java | 13 +-
.../commands/node/status/NodeStatusSubCommand.java | 8 +-
.../questions/ConnectToClusterQuestion.java | 110 ++++
.../ignite/cli/commands/sql/SqlReplCommand.java | 8 +-
.../topology/LogicalTopologyReplSubCommand.java | 11 +-
.../topology/LogicalTopologySubCommand.java | 8 +-
.../topology/PhysicalTopologyReplSubCommand.java | 11 +-
.../topology/PhysicalTopologySubCommand.java | 8 +-
...Profile.java => CachedStateConfigProvider.java} | 24 +-
.../cli/config/{Profile.java => Config.java} | 38 +-
.../apache/ignite/cli/config/ConfigConstants.java | 3 +-
.../ignite/cli/config/ConfigManagerProvider.java | 5 +
.../java/org/apache/ignite/cli/config/Profile.java | 62 +-
.../org/apache/ignite/cli/config/StateConfig.java | 61 ++
.../ignite/cli/config/StateConfigProvider.java} | 18 +-
.../ignite/cli/config/StateFolderProvider.java | 5 +-
.../apache/ignite/cli/config/ini/IniConfig.java} | 51 +-
.../ignite/cli/config/ini/IniConfigManager.java | 21 +-
.../org/apache/ignite/cli/config/ini/IniFile.java | 33 +-
.../apache/ignite/cli/config/ini/IniParser.java | 8 +-
.../apache/ignite/cli/config/ini/IniProfile.java | 40 +-
.../apache/ignite/cli/config/ini/IniSection.java | 5 -
.../ignite/cli/core/call/DefaultCallOutput.java | 2 +-
.../decorator/DecoratorRegistry.java} | 28 +-
.../cli/core/exception/ExceptionHandlers.java | 11 +
.../ignite/cli/core/exception/ExceptionWriter.java | 5 +
.../handler/DefaultExceptionHandlers.java | 1 +
.../handler/FlowInterruptExceptionHandler.java} | 18 +-
.../ignite/cli/core/flow/DefaultFlowable.java | 142 +++++
.../org/apache/ignite/cli/core/flow/Flow.java} | 37 +-
.../flow/FlowInterruptException.java} | 7 +-
.../org/apache/ignite/cli/core/flow/Flowable.java | 122 ++++
.../ignite/cli/core/flow/builder/FlowBuilder.java | 58 ++
.../cli/core/flow/builder/FlowBuilderImpl.java | 126 ++++
.../apache/ignite/cli/core/flow/builder/Flows.java | 143 +++++
.../flow/question/AcceptedQuestionAnswer.java} | 21 +-
.../flow/question/InterruptQuestionAnswer.java} | 14 +-
.../flow/question/JlineQuestionWriterReader.java | 57 ++
.../cli/core/flow/question/QuestionAnswer.java} | 55 +-
.../cli/core/flow/question/QuestionAsker.java | 54 ++
.../core/flow/question/QuestionAskerFactory.java} | 21 +-
.../core/flow/question/QuestionWriterReader.java} | 24 +-
.../java/org/apache/ignite/cli/core/repl/Repl.java | 11 +-
.../apache/ignite/cli/core/repl/ReplBuilder.java | 10 +-
.../repl/completer/CompleterFilter.java} | 8 +-
.../cli/core/repl/completer/DynamicCompleter.java} | 22 +-
.../completer/DynamicCompleterActivationPoint.java | 44 ++
.../repl/completer/DynamicCompleterFactory.java | 92 +++
.../repl/completer/DynamicCompleterFilter.java | 67 ++
.../repl/completer/DynamicCompleterRegistry.java | 81 +++
.../core/repl/completer/HoconDynamicCompleter.java | 105 +++
.../core/repl/completer/LazyDynamicCompleter.java | 51 ++
.../cli/core/repl/completer/NodeUrlProvider.java | 64 ++
.../cli/core/repl/context/CommandLineContext.java} | 22 +-
.../repl/context/CommandLineContextProvider.java} | 39 +-
.../core/repl/executor/IgnitePicocliCommands.java | 229 +++++++
.../repl/executor/RegistryCommandExecutor.java | 21 +-
.../cli/core/repl/executor/ReplExecutor.java | 39 +-
.../core/repl/executor/ReplExecutorProvider.java | 2 +-
.../cli/deprecated/builtins/node/NodeManager.java | 40 +-
.../cli/deprecated/spec/NodeCommandSpec.java | 81 ++-
.../cli/commands/UrlOptionsNegativeTest.java | 62 +-
.../cliconfig/CliConfigGetSubCommandTest.java | 2 +-
.../cliconfig/CliConfigSetSubCommandTest.java | 10 +-
.../cli/commands/cliconfig/ConfigManagerTest.java | 4 +-
.../cliconfig/TestConfigManagerHelper.java | 32 +-
.../apache/ignite/cli/commands/flow/FlowTest.java | 112 ++++
.../apache/ignite/cli/commands/flow/IntCall.java} | 22 +-
.../ignite/cli/commands/flow/IntCallInput.java} | 15 +-
.../apache/ignite/cli/commands/flow/StrCall.java} | 22 +-
.../ignite/cli/commands/flow/StrCallInput.java} | 15 +-
.../ignite/cli/config/TestStateConfigHelper.java} | 29 +-
.../cli/config/TestStateConfigProvider.java} | 25 +-
.../repl/completer/DynamicCompleterFilterTest.java | 104 +++
.../completer/DynamicCompleterRegistryTest.java | 91 +++
.../repl/completer/HoconDynamicCompleterTest.java | 170 +++++
.../cli/deprecated/IgniteCliInterfaceTest.java | 167 ++++-
.../src/test/resources/cluster_url_non_default.ini | 5 +
modules/cli/src/test/resources/ignite-config.json | 8 +
.../cli/src/test/resources/integration_tests.ini | 2 +-
.../src/test/resources/last_connected_default.ini | 1 +
.../cluster/management/raft/CmgRaftService.java | 2 +-
.../org/apache/ignite/internal/causality/README.md | 2 +-
.../ignite/internal/causality/VersionedValue.java | 2 +-
.../apache/ignite/internal/util/IgniteUtils.java | 41 ++
.../java/org/apache/ignite/lang/ErrorGroups.java | 12 +
.../internal/testframework/IgniteTestUtils.java | 18 +-
.../testframework/VariableArgumentsProvider.java | 4 +-
.../internal/testframework/VariableSource.java | 4 +-
.../internal/testframework/VariableSourceTest.java | 4 +-
modules/index/pom.xml | 95 +++
.../ignite/internal/index/ColumnCollation.java | 71 +++
.../apache/ignite/internal/index/HashIndex.java | 76 +++
.../org/apache/ignite/internal/index/Index.java} | 36 +-
.../ignite/internal/index/IndexDescriptor.java | 57 ++
.../apache/ignite/internal/index/IndexManager.java | 448 +++++++++++++
.../apache/ignite/internal/index/SortedIndex.java | 60 ++
.../internal/index/SortedIndexDescriptor.java | 73 +++
.../ignite/internal/index/SortedIndexImpl.java | 82 +++
.../ignite/internal/index/event/IndexEvent.java} | 14 +-
.../internal/index/event/IndexEventParameters.java | 86 +++
.../ignite/internal/index/IndexManagerTest.java | 458 ++++++++++++++
.../ignite/internal/pagememory/Storable.java | 2 +-
.../PageMemoryCheckpointConfigurationSchema.java | 5 +
.../pagememory/datapage/PageMemoryTraversal.java | 2 +-
.../pagememory/freelist/AbstractFreeList.java | 3 +-
.../internal/pagememory/freelist/PagesList.java | 3 +-
.../pagememory/persistence/PartitionMeta.java | 120 ++--
.../persistence/PersistentPageMemory.java | 21 +-
.../checkpoint/AwaitTasksCompletionExecutor.java | 80 +++
.../persistence/checkpoint/CheckpointListener.java | 8 +-
.../persistence/checkpoint/CheckpointManager.java | 16 +-
.../checkpoint/CheckpointReadWriteLock.java | 9 +-
.../persistence/checkpoint/CheckpointWorkflow.java | 75 ++-
.../persistence/checkpoint/Checkpointer.java | 38 +-
.../pagememory/persistence/io/PartitionMetaIo.java | 67 +-
.../replacement/DelayedDirtyPageWrite.java | 27 +-
.../AbstractPageMemoryNoLoadSelfTest.java | 6 +-
.../internal/pagememory/freelist/TestDataRow.java | 2 +-
.../persistence/PartitionMetaManagerTest.java | 27 +-
.../pagememory/persistence/PartitionMetaTest.java | 102 +--
.../PersistentPageMemoryNoLoadTest.java | 131 +++-
.../AwaitTasksCompletionExecutorTest.java | 72 +++
.../checkpoint/CheckpointWorkflowTest.java | 131 +++-
.../persistence/checkpoint/CheckpointerTest.java | 30 +-
.../internal/raft/server/impl/JraftServerImpl.java | 3 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 4 +-
.../raft/jraft/rpc/impl/AbstractClientService.java | 6 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 4 +-
modules/runner/pom.xml | 5 +
.../internal/AbstractClusterIntegrationTest.java | 2 +-
.../ignite/internal/index/ItIndexManagerTest.java | 102 +++
.../internal/runner/app/IgniteCliRunnerTest.java | 2 +-
.../ignite/internal/sql/engine/ItJoinTest.java | 2 +-
.../ignite/internal/sql/engine/ItMetadataTest.java | 2 +-
.../internal/sql/engine/ItMixedQueriesTest.java | 2 +-
.../internal/sql/engine/ItOrToUnionRuleTest.java | 2 +-
.../internal/sql/engine/ItSecondaryIndexTest.java | 2 +-
.../internal/table/ItPublicApiColocationTest.java | 2 -
.../org/apache/ignite/app/IgniteCliRunner.java | 35 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 19 +
.../CoreDistributedConfigurationModule.java | 2 -
.../CoreDistributedConfigurationModuleTest.java | 6 -
.../ignite/internal/schema/BinaryTupleBuilder.java | 8 +-
.../ignite/internal/schema/BinaryTupleParser.java | 8 +-
.../ignite/internal/schema/BinaryTupleSchema.java | 53 +-
.../ignite/internal/schema/SchemaManager.java | 67 +-
.../SchemaConfigurationConverter.java | 41 +-
.../builder/PartialIndexDefinitionBuilderImpl.java | 121 ----
.../builder/SortedIndexDefinitionBuilderImpl.java | 4 +-
.../index/PartialIndexDefinitionImpl.java | 61 --
.../org/apache/ignite/schema/SchemaBuilders.java | 12 -
.../internal/schema/SchemaConfigurationTest.java | 9 -
.../builder/PartialIndexDefinitionBuilderTest.java | 46 --
.../SchemaConfigurationConverterTest.java | 27 -
.../configuration/TableValidatorImplTest.java | 4 +-
.../internal/sql/engine/SqlQueryProcessor.java | 2 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 248 ++++----
.../internal/sql/engine/session/Session.java | 2 +-
.../sql/engine/type/IgniteTypeFactory.java | 4 +-
.../sql/engine/exec/MockedStructuresTest.java | 2 -
.../engine/exec/schema/SqlSchemaManagerTest.java | 7 +-
modules/storage-api/pom.xml | 13 +
.../internal/storage/MvPartitionStorage.java | 21 +-
.../org/apache/ignite/internal/storage/RowId.java | 88 ++-
.../internal/storage/TxIdMismatchException.java | 38 ++
.../internal/storage/engine/MvTableStorage.java | 48 +-
.../internal/storage/engine/StorageEngine.java | 8 +-
.../internal/storage/engine/TableStorage.java | 23 -
.../ignite/internal/storage/index/IndexRow.java | 22 +-
.../storage/index/IndexRowDeserializer.java | 2 +-
...ndexRowFactory.java => IndexRowSerializer.java} | 11 +-
.../internal/storage/index/PrefixComparator.java | 138 ----
.../storage/index/SortedIndexDescriptor.java | 114 +---
.../storage/index/SortedIndexMvStorage.java | 118 ----
.../internal/storage/index/SortedIndexStorage.java | 58 +-
.../storage/AbstractMvPartitionStorageTest.java | 120 +++-
.../storage/AbstractMvTableStorageTest.java | 173 +++++
.../storage/AbstractSortedIndexMvStorageTest.java | 435 -------------
.../ConcurrentHashMapMvTableStorageTest.java | 50 ++
.../storage/ConcurrentHashMapStorageTest.java | 83 ---
.../{basic => }/TestMvPartitionStorageTest.java | 12 +-
.../storage/basic/TestSortedIndexMvStorage.java | 288 ---------
.../basic/TestSortedIndexMvStorageTest.java | 49 --
.../TestConcurrentHashMapMvPartitionStorage.java} | 93 +--
.../chm/TestConcurrentHashMapMvTableStorage.java | 134 ++++
.../chm/TestConcurrentHashMapPartitionStorage.java | 295 ---------
.../chm/TestConcurrentHashMapStorageEngine.java | 11 +-
.../chm/TestConcurrentHashMapTableStorage.java | 118 ----
.../internal/storage/chm/TestMvTableStorage.java | 88 ---
.../index/AbstractSortedIndexStorageTest.java | 704 +++++++++++++++++++++
.../storage/index/TestSortedIndexStorageTest.java} | 16 +-
.../storage/index/impl/BinaryTupleComparator.java | 150 +++++
.../index/impl/BinaryTupleRowDeserializer.java} | 36 +-
.../index/impl/BinaryTupleRowSerializer.java | 77 +++
.../internal/storage/index/impl/IndexRowImpl.java} | 28 +-
.../internal/storage/index/impl/TestIndexRow.java} | 113 ++--
.../storage/index/impl/TestSortedIndexStorage.java | 149 +++++
.../pagememory/AbstractPageMemoryTableStorage.java | 117 +---
.../storage/pagememory/FragmentedByteArray.java | 94 ---
.../pagememory/PageMemoryStorageIoModule.java | 43 --
.../pagememory/PersistentPageMemoryDataRegion.java | 37 +-
.../PersistentPageMemoryPartitionStorage.java | 166 -----
.../PersistentPageMemoryStorageEngine.java | 11 +-
.../PersistentPageMemoryTableStorage.java | 133 ++--
.../internal/storage/pagememory/TableDataRow.java | 111 ----
.../internal/storage/pagememory/TableFreeList.java | 100 ---
.../internal/storage/pagememory/TableTree.java | 329 ----------
.../pagememory/VolatilePageMemoryDataRegion.java | 91 +--
.../VolatilePageMemoryPartitionStorage.java | 488 --------------
.../VolatilePageMemoryStorageEngine.java | 8 +-
.../pagememory/VolatilePageMemoryTableStorage.java | 49 +-
.../storage/pagememory/io/TableDataIo.java | 174 -----
.../storage/pagememory/io/TableInnerIo.java | 113 ----
.../storage/pagememory/io/TableLeafIo.java | 112 ----
...a => AbstractPageMemoryMvPartitionStorage.java} | 310 +++------
.../pagememory/mv/PageMemoryMvStorageIoModule.java | 5 +-
.../storage/pagememory/mv/PartitionlessLinks.java | 119 +---
.../mv/PersistentPageMemoryMvPartitionStorage.java | 197 ++++++
.../storage/pagememory/mv/ReadRowVersion.java | 21 +-
.../storage/pagememory/mv/ReadRowVersionValue.java | 2 +
.../internal/storage/pagememory/mv/RowVersion.java | 35 +-
.../storage/pagememory/mv/RowVersionFreeList.java | 12 +-
.../pagememory/mv/ScanVersionChainByTimestamp.java | 37 +-
.../internal/storage/pagememory/mv/Timestamps.java | 24 +-
.../storage/pagememory/mv/TransactionIds.java | 57 --
.../storage/pagememory/mv/VersionChain.java | 97 +--
.../pagememory/mv/VersionChainDataPageReader.java | 87 ---
.../pagememory/mv/VersionChainFreeList.java | 158 -----
...icationsException.java => VersionChainKey.java} | 23 +-
.../storage/pagememory/mv/VersionChainTree.java | 21 +-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 82 +++
.../storage/pagememory/mv/io/RowVersionDataIo.java | 3 +-
.../pagememory/mv/io/VersionChainDataIo.java | 97 ---
.../pagememory/mv/io/VersionChainInnerIo.java | 41 +-
.../storage/pagememory/mv/io/VersionChainIo.java | 135 +++-
.../pagememory/mv/io/VersionChainLeafIo.java | 41 +-
...ache.ignite.internal.pagememory.io.PageIoModule | 1 -
.../AbstractPageMemoryMvPartitionStorageTest.java | 120 ++++
.../mv/PageMemoryMvPartitionStorageTest.java | 268 --------
.../pagememory/mv/PartitionlessLinksTest.java | 68 --
...ersistentPageMemoryMvPartitionStorageTest.java} | 85 +--
.../VolatilePageMemoryMvPartitionStorageTest.java} | 83 +--
.../storage/rocksdb/ColumnFamilyUtils.java | 37 +-
.../storage/rocksdb/RocksDbFlushListener.java | 8 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 152 ++---
.../storage/rocksdb/RocksDbPartitionStorage.java | 500 ---------------
.../storage/rocksdb/RocksDbStorageEngine.java | 9 +-
.../storage/rocksdb/RocksDbTableStorage.java | 207 +++---
.../ignite/internal/storage/rocksdb/UuidRowId.java | 115 ----
.../RocksDbStorageEngineConfigurationSchema.java | 3 +
.../storage/rocksdb/index/BinaryIndexRow.java | 69 --
.../rocksdb/index/BinaryIndexRowFactory.java | 92 ---
.../storage/rocksdb/index/BinaryRowComparator.java | 193 ------
.../storage/rocksdb/index/ComparatorUtils.java | 46 --
.../rocksdb/index/RocksDbSortedIndexStorage.java | 152 -----
.../rocksdb/RocksDbMvPartitionStorageTest.java | 9 +-
.../storage/rocksdb/RocksDbTableStorageTest.java | 36 +-
.../index/RocksDbSortedIndexStorageTest.java | 506 ---------------
.../ignite/distributed/ItTablePersistenceTest.java | 4 +-
.../distributed/ItTxDistributedTestSingleNode.java | 4 +-
.../internal/table/distributed/TableManager.java | 118 +++-
.../org/apache/ignite/internal/table/Example.java | 4 +-
.../internal/table/InteropOperationsTest.java | 4 +-
.../table/KeyValueBinaryViewOperationsTest.java | 4 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 4 +-
.../internal/table/KeyValueViewOperationsTest.java | 4 +-
.../table/RecordBinaryViewOperationsTest.java | 4 +-
.../internal/table/RecordViewOperationsTest.java | 4 +-
.../internal/table/SchemaValidationTest.java | 4 +-
.../apache/ignite/internal/table/TxLocalTest.java | 6 +-
.../table/distributed/TableManagerTest.java | 2 -
.../raft/PartitionCommandListenerTest.java | 4 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 14 +-
parent/pom.xml | 12 +
pom.xml | 1 +
322 files changed, 9505 insertions(+), 8894 deletions(-)
delete mode 100644 modules/api/src/main/java/org/apache/ignite/configuration/schemas/table/PartialIndexConfigurationSchema.java
delete mode 100644 modules/api/src/main/java/org/apache/ignite/schema/definition/builder/PartialIndexDefinitionBuilder.java
create mode 100644 modules/cli/src/integrationTest/java/org/apache/ignite/cli/commands/questions/ItConnectToClusterTest.java
rename modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/VersionChainLink.java => cli/src/main/java/org/apache/ignite/cli/call/configuration/JsonString.java} (67%)
copy modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/TableSearchRow.java => cli/src/main/java/org/apache/ignite/cli/commands/OptionsConstants.java} (52%)
copy modules/cli/src/main/java/org/apache/ignite/cli/commands/decorators/{TableDecorator.java => DefaultDecoratorRegistry.java} (51%)
rename modules/cli/src/main/java/org/apache/ignite/cli/commands/decorators/{ConfigDecorator.java => ProfileDecorator.java} (94%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/commands/questions/ConnectToClusterQuestion.java
copy modules/cli/src/main/java/org/apache/ignite/cli/config/{Profile.java => CachedStateConfigProvider.java} (65%)
copy modules/cli/src/main/java/org/apache/ignite/cli/config/{Profile.java => Config.java} (59%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/config/StateConfig.java
copy modules/{api/src/main/java/org/apache/ignite/schema/definition/index/PartialIndexDefinition.java => cli/src/main/java/org/apache/ignite/cli/config/StateConfigProvider.java} (71%)
rename modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/TableDataRowAdapter.java => cli/src/main/java/org/apache/ignite/cli/config/ini/IniConfig.java} (50%)
copy modules/cli/src/main/java/org/apache/ignite/cli/{config/Profile.java => core/decorator/DecoratorRegistry.java} (54%)
copy modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/ReadRowVersionValue.java => cli/src/main/java/org/apache/ignite/cli/core/exception/handler/FlowInterruptExceptionHandler.java} (59%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/flow/DefaultFlowable.java
copy modules/{api/src/main/java/org/apache/ignite/lang/IndexNotFoundException.java => cli/src/main/java/org/apache/ignite/cli/core/flow/Flow.java} (50%)
copy modules/cli/src/main/java/org/apache/ignite/cli/{config/ConfigManagerProvider.java => core/flow/FlowInterruptException.java} (82%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/flow/Flowable.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/flow/builder/FlowBuilder.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/flow/builder/FlowBuilderImpl.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/flow/builder/Flows.java
copy modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/ReadRowVersionValue.java => cli/src/main/java/org/apache/ignite/cli/core/flow/question/AcceptedQuestionAnswer.java} (62%)
copy modules/cli/src/main/java/org/apache/ignite/cli/{config/ConfigManagerProvider.java => core/flow/question/InterruptQuestionAnswer.java} (71%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/flow/question/JlineQuestionWriterReader.java
rename modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/TableSearchRow.java => cli/src/main/java/org/apache/ignite/cli/core/flow/question/QuestionAnswer.java} (51%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/flow/question/QuestionAsker.java
copy modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/ReadRowVersionValue.java => cli/src/main/java/org/apache/ignite/cli/core/flow/question/QuestionAskerFactory.java} (63%)
copy modules/{api/src/main/java/org/apache/ignite/schema/definition/index/PartialIndexDefinition.java => cli/src/main/java/org/apache/ignite/cli/core/flow/question/QuestionWriterReader.java} (71%)
copy modules/cli/src/main/java/org/apache/ignite/cli/{config/ConfigManagerProvider.java => core/repl/completer/CompleterFilter.java} (81%)
copy modules/{api/src/main/java/org/apache/ignite/schema/definition/index/PartialIndexDefinition.java => cli/src/main/java/org/apache/ignite/cli/core/repl/completer/DynamicCompleter.java} (70%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/repl/completer/DynamicCompleterActivationPoint.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/repl/completer/DynamicCompleterFactory.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/repl/completer/DynamicCompleterFilter.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/repl/completer/DynamicCompleterRegistry.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/repl/completer/HoconDynamicCompleter.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/repl/completer/LazyDynamicCompleter.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/repl/completer/NodeUrlProvider.java
rename modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/io/RowIo.java => cli/src/main/java/org/apache/ignite/cli/core/repl/context/CommandLineContext.java} (66%)
rename modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/io/TableMetaIo.java => cli/src/main/java/org/apache/ignite/cli/core/repl/context/CommandLineContextProvider.java} (52%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/repl/executor/IgnitePicocliCommands.java
create mode 100644 modules/cli/src/test/java/org/apache/ignite/cli/commands/flow/FlowTest.java
copy modules/{api/src/main/java/org/apache/ignite/schema/definition/index/PartialIndexDefinition.java => cli/src/test/java/org/apache/ignite/cli/commands/flow/IntCall.java} (68%)
copy modules/cli/src/{main/java/org/apache/ignite/cli/config/ConfigManagerProvider.java => test/java/org/apache/ignite/cli/commands/flow/IntCallInput.java} (78%)
rename modules/{api/src/main/java/org/apache/ignite/schema/definition/index/PartialIndexDefinition.java => cli/src/test/java/org/apache/ignite/cli/commands/flow/StrCall.java} (66%)
copy modules/cli/src/{main/java/org/apache/ignite/cli/config/ConfigManagerProvider.java => test/java/org/apache/ignite/cli/commands/flow/StrCallInput.java} (77%)
copy modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/LinkRowId.java => cli/src/test/java/org/apache/ignite/cli/config/TestStateConfigHelper.java} (55%)
copy modules/cli/src/{main/java/org/apache/ignite/cli/config/Profile.java => test/java/org/apache/ignite/cli/config/TestStateConfigProvider.java} (68%)
create mode 100644 modules/cli/src/test/java/org/apache/ignite/cli/core/repl/completer/DynamicCompleterFilterTest.java
create mode 100644 modules/cli/src/test/java/org/apache/ignite/cli/core/repl/completer/DynamicCompleterRegistryTest.java
create mode 100644 modules/cli/src/test/java/org/apache/ignite/cli/core/repl/completer/HoconDynamicCompleterTest.java
create mode 100644 modules/cli/src/test/resources/cluster_url_non_default.ini
create mode 100644 modules/cli/src/test/resources/ignite-config.json
create mode 100644 modules/cli/src/test/resources/last_connected_default.ini
create mode 100644 modules/index/pom.xml
create mode 100644 modules/index/src/main/java/org/apache/ignite/internal/index/ColumnCollation.java
create mode 100644 modules/index/src/main/java/org/apache/ignite/internal/index/HashIndex.java
rename modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/LinkRowId.java => index/src/main/java/org/apache/ignite/internal/index/Index.java} (54%)
create mode 100644 modules/index/src/main/java/org/apache/ignite/internal/index/IndexDescriptor.java
create mode 100644 modules/index/src/main/java/org/apache/ignite/internal/index/IndexManager.java
create mode 100644 modules/index/src/main/java/org/apache/ignite/internal/index/SortedIndex.java
create mode 100644 modules/index/src/main/java/org/apache/ignite/internal/index/SortedIndexDescriptor.java
create mode 100644 modules/index/src/main/java/org/apache/ignite/internal/index/SortedIndexImpl.java
copy modules/{cli/src/main/java/org/apache/ignite/cli/config/ConfigManagerProvider.java => index/src/main/java/org/apache/ignite/internal/index/event/IndexEvent.java} (72%)
create mode 100644 modules/index/src/main/java/org/apache/ignite/internal/index/event/IndexEventParameters.java
create mode 100644 modules/index/src/test/java/org/apache/ignite/internal/index/IndexManagerTest.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/AwaitTasksCompletionExecutor.java
create mode 100644 modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/AwaitTasksCompletionExecutorTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/index/ItIndexManagerTest.java
delete mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/definition/builder/PartialIndexDefinitionBuilderImpl.java
delete mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/definition/index/PartialIndexDefinitionImpl.java
delete mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/builder/PartialIndexDefinitionBuilderTest.java
rename modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/{IndexRowFactory.java => IndexRowSerializer.java} (77%)
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/PrefixComparator.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/SortedIndexMvStorage.java
create mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/AbstractMvTableStorageTest.java
delete mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/AbstractSortedIndexMvStorageTest.java
create mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/ConcurrentHashMapMvTableStorageTest.java
delete mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/ConcurrentHashMapStorageTest.java
rename modules/storage-api/src/test/java/org/apache/ignite/internal/storage/{basic => }/TestMvPartitionStorageTest.java (74%)
delete mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/basic/TestSortedIndexMvStorage.java
delete mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/basic/TestSortedIndexMvStorageTest.java
rename modules/storage-api/src/test/java/org/apache/ignite/internal/storage/{basic/TestMvPartitionStorage.java => chm/TestConcurrentHashMapMvPartitionStorage.java} (77%)
create mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/chm/TestConcurrentHashMapMvTableStorage.java
delete mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/chm/TestConcurrentHashMapPartitionStorage.java
delete mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/chm/TestConcurrentHashMapTableStorage.java
delete mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/chm/TestMvTableStorage.java
create mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/index/AbstractSortedIndexStorageTest.java
rename modules/storage-api/src/{main/java/org/apache/ignite/internal/storage/index/IndexRowPrefix.java => test/java/org/apache/ignite/internal/storage/index/TestSortedIndexStorageTest.java} (63%)
create mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/index/impl/BinaryTupleComparator.java
rename modules/{storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/BinaryIndexRowDeserializer.java => storage-api/src/test/java/org/apache/ignite/internal/storage/index/impl/BinaryTupleRowDeserializer.java} (56%)
create mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/index/impl/BinaryTupleRowSerializer.java
rename modules/{storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/ByteArraySearchRow.java => storage-api/src/test/java/org/apache/ignite/internal/storage/index/impl/IndexRowImpl.java} (56%)
rename modules/{storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/index/IndexRowWrapper.java => storage-api/src/test/java/org/apache/ignite/internal/storage/index/impl/TestIndexRow.java} (59%)
create mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/index/impl/TestSortedIndexStorage.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/FragmentedByteArray.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/PageMemoryStorageIoModule.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/PersistentPageMemoryPartitionStorage.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/TableDataRow.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/TableFreeList.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/TableTree.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/VolatilePageMemoryPartitionStorage.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/io/TableDataIo.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/io/TableInnerIo.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/io/TableLeafIo.java
rename modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/{PageMemoryMvPartitionStorage.java => AbstractPageMemoryMvPartitionStorage.java} (56%)
create mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/PersistentPageMemoryMvPartitionStorage.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/TransactionIds.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/VersionChainDataPageReader.java
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/VersionChainFreeList.java
rename modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/{RowIdIsInvalidForModificationsException.java => VersionChainKey.java} (70%)
create mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/VolatilePageMemoryMvPartitionStorage.java
delete 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/test/java/org/apache/ignite/internal/storage/pagememory/mv/AbstractPageMemoryMvPartitionStorageTest.java
delete mode 100644 modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/mv/PageMemoryMvPartitionStorageTest.java
delete mode 100644 modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/mv/PartitionlessLinksTest.java
rename modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/{PersistentPageMemoryPartitionStorageTest.java => mv/PersistentPageMemoryMvPartitionStorageTest.java} (62%)
rename modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/{VolatilePageMemoryPartitionStorageTest.java => mv/VolatilePageMemoryMvPartitionStorageTest.java} (59%)
delete mode 100644 modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/RocksDbPartitionStorage.java
delete mode 100644 modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/UuidRowId.java
delete mode 100644 modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/BinaryIndexRow.java
delete mode 100644 modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/BinaryIndexRowFactory.java
delete mode 100644 modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/BinaryRowComparator.java
delete mode 100644 modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/ComparatorUtils.java
delete mode 100644 modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/RocksDbSortedIndexStorage.java
delete mode 100644 modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/index/RocksDbSortedIndexStorageTest.java