You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2023/05/30 12:44:31 UTC
[ignite-3] branch ignite-19460 updated (d29dd53181 -> 58eef45d8c)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-19460
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit d29dd53181 Add add/crop column events.
omit 69553ff61d Add create/drop columns commands.
omit 34715ef541 Add create/drop index events.
omit ea6047fdf1 Add create index command. Add drop index command.
omit cbbfac684d Styles
add de16422ec6 IGNITE-19509 Get rid of reading configuration when calling methods MvTableStorage#getOrCreate*Index (#2082)
add 332195b96a IGNITE-18619 Need to properly wait for indexes to be created before rebalancing (#2084)
add 1e14abe820 IGNITE-19384 Update deployment units after deploy (#2044)
add be4f6a8877 IGNITE-19525 Muted DeploymentManagementControllerTest.testDeploySuccessful test (#2088)
add 220b6a442e IGNITE-19183 Fixed LogicalNode.toString method (#2086)
add bab4e35a89 IGNITE-19464 Move out logic of applying cluster configuration from ClusterManagementGroupManager (#2066)
add 7a338a04f7 IGNITE-19443 Skipping empty data nodes propagation to pending assignments after filtering (#2089)
add 144ffc4f92 IGNITE-19278 Multiple partition scan requests may return more rows than requested (#2079)
add 86ee7fdee5 IGNITE-19454 Validate backwards schema compatibility (#2075)
add be922061ae IGNITE-19527 .NET: Add NUnit.Analyzers (#2092)
add 22f6d0d1d3 IGNITE-19381 TimestampAware messages sometimes lacks timestamps (#2083)
add 00e6812c2a IGNITE-19428 PlacementDriver API implemented. (#2078)
add 018148ffab IGNITE-18518 Proper filtering of index scans, according to MV storage data. (#2037)
add 1431f13855 IGNITE-19177 Add assignments checks when building indexes (#2030)
add 2ce91dc565 IGNITE-19396 Move work with indexes from StorageUpdateHandler to a separate class (#2091)
add b9259f516f IGNITE-19472 Make fsync flag configurable in RAFT (#2096)
add f6a8dd1b70 IGNITE-19523 Unmuted TxAbstractTest.testRollbackUpgradedLock (#2087)
add 0c68cbe3f0 IGNITE-17883 Removed not implemented 'invoke' functionality (#2090)
add 4c483b0eb1 IGNITE-19293 Validate cluster configuration on init (#2065)
add 69073325b9 IGNITE-19533 Renamed UNKNOWN_ERR error code to INTERNAL_ERR. Removed UNEXPECTED_ERR error code. (#2097)
add 7523612b38 IGNITE-19532 Happens-before for safe time propagation (#2098)
add 317aca963e IGNITE-19531 Switch table IDs from UUIDs to integers (#2093)
add c6ee1d2bd0 IGNITE-19572 Non-REPL node commands show node name option (#2111)
add 21aaecee15 IGNITE-19578 PlacementDriver disabled. (#2113)
add cd7a275484 IGNITE-19547 Switch index IDs from UUID to int (#2112)
add d20a66ab0e IGNITE-18443 Sql. Provide extend commands and handlers for distributed zones operation (#2103)
add bcbe8280aa IGNITE-19576 Fix ItClusterManagerTest.testClusterConfigurationIsRemovedFromClusterStateAfterUpdating (#2110)
add 2f0f20cf41 IGNITE-19398 ItIgniteNodeRestartTest optimized. (#2114)
add 907fb85767 Styles
add 46b9e1ca2c Add create/drop index commands.
add 58eef45d8c Add create/drop index events.
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 (d29dd53181)
\
N -- N -- N refs/heads/ignite-19460 (58eef45d8c)
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:
docs/_docs/handling-exceptions.adoc | 6 +-
.../org/apache/ignite/lang/IgniteException.java | 14 +-
.../org/apache/ignite/table/InvocationContext.java | 70 ---
.../org/apache/ignite/table/InvokeProcessor.java | 47 --
.../ignite/table/InvokeProcessorException.java | 38 --
.../java/org/apache/ignite/table/KeyValueView.java | 65 ---
.../java/org/apache/ignite/table/RecordView.java | 48 ---
.../internal/catalog/CatalogServiceImpl.java | 153 +------
.../commands/AlterTableDropColumnParams.java | 4 -
.../internal/catalog/commands/CatalogUtils.java | 38 +-
.../internal/catalog/commands/ColumnParams.java | 88 +---
.../catalog/commands/CreateIndexParams.java | 38 +-
.../internal/catalog/commands/DropIndexParams.java | 1 +
.../catalog/descriptors/HashIndexDescriptor.java | 15 +-
.../catalog/descriptors/IndexDescriptor.java | 20 +-
.../catalog/descriptors/SortedIndexDescriptor.java | 21 +-
.../catalog/descriptors/TableDescriptor.java | 44 +-
.../catalog/events/AddColumnEventParameters.java | 56 ---
.../internal/catalog/events/CatalogEvent.java | 8 +-
.../catalog/events/CreateIndexEventParameters.java | 4 +-
.../catalog/events/DropColumnEventParameters.java | 55 ---
.../internal/catalog/storage/DropColumnsEntry.java | 58 ---
.../internal/catalog/storage/DropIndexEntry.java | 6 +-
.../internal/catalog/storage/NewColumnsEntry.java | 59 ---
.../internal/catalog/storage/NewIndexEntry.java | 4 +-
.../internal/catalog/storage/UpdateLogImpl.java | 2 +-
.../internal/catalog/CatalogServiceSelfTest.java | 393 +++--------------
.../cli/call/unit/ItDeployUndeployCallsTest.java | 6 +-
.../internal/rest/ItGeneratedRestClientTest.java | 2 +-
.../internal/cli/call/unit/ListUnitCall.java | 2 +-
.../internal/cli/call/unit/UnitStatusCall.java | 2 +-
.../internal/cli/call/unit/UnitStatusRecord.java | 18 +-
.../ignite/internal/cli/commands/Options.java | 2 +-
.../internal/cli/commands/node/NodeUrlMixin.java | 3 +-
.../cli/commands/node/NodeUrlProfileMixin.java | 15 +-
.../core/repl/registry/impl/UnitsRegistryImpl.java | 2 +-
.../internal/cli/decorators/UnitListDecorator.java | 6 +-
.../cli/decorators/UnitStatusDecorator.java | 4 +-
.../ignite/client/handler/ItClientHandlerTest.java | 6 +-
.../apache/ignite/client/handler/TestServer.java | 12 +-
.../handler/ClientInboundMessageHandler.java | 4 +-
.../handler/requests/table/ClientTableCommon.java | 3 +-
.../requests/table/ClientTableGetRequest.java | 2 +-
.../ClientTablePartitionAssignmentGetRequest.java | 3 +-
.../requests/table/ClientTablesGetRequest.java | 2 +-
.../internal/client/compute/ClientCompute.java | 4 +-
.../client/table/ClientKeyValueBinaryView.java | 46 --
.../internal/client/table/ClientKeyValueView.java | 54 +--
.../client/table/ClientRecordBinaryView.java | 39 --
.../client/table/ClientRecordSerializer.java | 22 +-
.../internal/client/table/ClientRecordView.java | 39 --
.../ignite/internal/client/table/ClientTable.java | 16 +-
.../ignite/internal/client/table/ClientTables.java | 4 +-
.../client/table/ClientTupleSerializer.java | 12 +-
.../internal/client/tx/ClientTransaction.java | 4 +-
.../ignite/client/PartitionAwarenessTest.java | 8 +-
.../java/org/apache/ignite/client/TestServer.java | 12 +-
.../ignite/client/fakes/FakeIgniteTables.java | 19 +-
.../ignite/client/fakes/FakeInternalTable.java | 46 +-
modules/cluster-management/build.gradle | 3 +
.../cluster/management/ItClusterManagerTest.java | 90 +++-
.../management/ClusterManagementGroupManager.java | 106 +++--
.../UpdateDistributedConfigurationAction.java | 66 +++
.../management/topology/api/LogicalNode.java | 13 +-
.../internal/cluster/management/MockNode.java | 9 +-
modules/code-deployment/build.gradle | 5 +
.../deployunit/DeployMessagingService.java | 34 +-
.../deployunit/DeployMetastoreService.java | 133 ------
.../ignite/internal/deployunit/DeployTracker.java | 6 +-
.../ignite/internal/deployunit/DeploymentInfo.java | 116 -----
.../internal/deployunit/DeploymentManagerImpl.java | 143 +++---
.../internal/deployunit/IgniteDeployment.java | 8 +-
.../ignite/internal/deployunit/UnitMeta.java | 169 --------
.../ignite/internal/deployunit/UnitStatus.java | 129 ++----
.../{UnitStatus.java => UnitStatuses.java} | 63 ++-
.../ignite/internal/deployunit/key/UnitKey.java | 77 ----
...umulator.java => ClusterStatusAccumulator.java} | 25 +-
.../deployunit/metastore/DeploymentUnitStore.java | 138 ++++++
.../metastore/DeploymentUnitStoreImpl.java | 200 +++++++++
.../deployunit/metastore/KeyAccumulator.java} | 24 +-
.../deployunit/metastore/UnitsAccumulator.java | 29 +-
.../metastore/UnitsByNodeAccumulator.java | 62 +++
.../internal/deployunit/metastore/key/UnitKey.java | 142 ++++++
.../{ => metastore}/key/UnitMetaSerializer.java | 31 +-
.../ignite/deployment/UnitMetaSerializerTest.java | 10 +-
.../metastore/DeploymentUnitStoreImplTest.java | 168 ++++++++
.../presentation/HoconPresentationTest.java | 15 +-
.../configuration/ConfigurationChanger.java | 44 +-
.../configuration/ConfigurationManager.java | 40 +-
.../configuration/ConfigurationRegistry.java | 68 +--
.../validation/ConfigurationValidator.java | 62 +++
...onUtil.java => ConfigurationValidatorImpl.java} | 115 ++++-
.../validation/ValidationContextImpl.java | 17 +-
.../configuration/ConfigurationChangerTest.java | 13 +-
.../configuration/ConfigurationRegistryTest.java | 86 ++--
.../asm/ConfigurationTreeGeneratorTest.java | 6 +-
.../configuration/direct/DirectPropertiesTest.java | 8 +-
.../configuration/hocon/HoconConverterTest.java | 18 +-
.../ConfigurationAnyListenerTest.java | 17 +-
.../notifications/ConfigurationListenerTest.java | 16 +-
.../internal/configuration/sample/UsageTest.java | 13 +-
.../configuration/tree/InternalIdTest.java | 6 +-
.../configuration/tree/NamedListNodeTest.java | 6 +-
...st.java => ConfigurationValidatorImplTest.java} | 38 +-
.../configuration/TestConfigurationChanger.java | 10 +-
.../validation/TestConfigurationValidator.java | 50 +++
.../ignite/internal/hlc/HybridTimestamp.java | 7 +-
.../internal/replicator/TablePartitionId.java | 15 +-
.../ignite/internal/util/CollectionUtils.java | 14 +
.../util/PendingComparableValuesTracker.java | 5 +
.../PendingIndependentComparableValuesTracker.java | 6 +
.../java/org/apache/ignite/lang/ErrorGroups.java | 71 ++-
.../lang/IgniteInternalCheckedException.java | 12 +-
.../ignite/lang/IgniteInternalException.java | 10 +-
.../ignite/internal/util/CollectionUtilsTest.java | 10 +
.../org/apache/ignite/lang/ErrorGroupTest.java | 8 +-
.../asserts/CompletableFutureAssert.java | 10 +-
.../rebalance/DistributionZoneRebalanceEngine.java | 20 +-
.../rebalance/TablePartitionId.java | 14 +-
.../BaseDistributionZoneManagerTest.java | 17 +-
...ibutionZoneManagerConfigurationChangesTest.java | 15 +-
.../DistributionZoneManagerTest.java | 15 +-
.../DistributionZoneRebalanceEngineTest.java | 37 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 19 +-
.../ignite/internal/index/BuildIndexTaskId.java | 10 +-
.../apache/ignite/internal/index/HashIndex.java | 11 +-
.../org/apache/ignite/internal/index/Index.java | 4 +-
.../apache/ignite/internal/index/IndexBuilder.java | 378 ----------------
.../apache/ignite/internal/index/IndexManager.java | 93 ++--
.../ignite/internal/index/SortedIndexImpl.java | 11 +-
.../internal/index/event/IndexEventParameters.java | 13 +-
.../ignite/internal/index/IndexManagerTest.java | 28 +-
.../internal/metastorage/MetaStorageManager.java | 13 +
.../metastorage/server/time/ClusterTime.java | 0
...=> ItMetaStorageMultipleNodesAbstractTest.java} | 81 ++--
.../ItMetaStorageMultipleNodesRocksDbTest.java} | 18 +-
...MetaStorageMultipleNodesSimpleStorageTest.java} | 17 +-
...MetaStorageSafeTimePropagationAbstractTest.java | 100 +++++
...MetaStorageSafeTimePropagationRocksDbTest.java} | 11 +-
...orageSafeTimePropagationSimpleStorageTest.java} | 14 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 13 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 16 +-
.../server/OnRevisionAppliedCallback.java | 4 +-
.../metastorage/server/WatchProcessor.java | 16 +-
.../server/persistence/RocksDbKeyValueStorage.java | 109 ++++-
.../persistence/StorageColumnFamilyType.java | 5 +-
.../server/raft/MetaStorageWriteHandler.java | 8 +-
.../server/BasicOperationsKeyValueStorageTest.java | 8 +-
.../RocksDbCompactionKeyValueStorageTest.java | 2 +-
.../server/RocksDbKeyValueStorageTest.java | 4 +-
...impleInMemoryCompactionKeyValueStorageTest.java | 2 +-
.../server/SimpleInMemoryKeyValueStorageTest.java | 2 +-
.../metastorage/server/WatchProcessorTest.java | 27 +-
.../server/AbstractKeyValueStorageTest.java | 2 +-
.../server/SimpleInMemoryKeyValueStorage.java | 18 +-
.../serialization/BaseMethodNameResolver.java | 2 +
.../network/serialization/MessageReader.java | 9 +
.../network/serialization/MessageWriter.java | 10 +
.../network/direct/DirectMessageReader.java | 11 +
.../network/direct/DirectMessageWriter.java | 9 +
.../direct/stream/DirectByteBufferStream.java | 15 +
.../stream/DirectByteBufferStreamImplV1.java | 32 ++
.../network/processor/AllTypesMessage.java | 2 +
.../ignite/utils/ClusterServiceTestUtils.java | 8 +-
.../internal/placementdriver/LeaseMeta.java} | 27 +-
.../internal/placementdriver/PlacementDriver.java | 51 +++
modules/placement-driver/build.gradle | 5 +
.../MultiActorPlacementDriverTest.java | 13 +-
.../PlacementDriverManagerTest.java | 13 +-
.../placementdriver/AssignmentsTracker.java | 3 +-
.../internal/placementdriver/LeaseUpdater.java | 6 +-
.../placementdriver/PlacementDriverManager.java | 1 +
.../internal/placementdriver/leases/Lease.java | 51 +--
.../placementdriver/leases/LeaseTracker.java | 95 +++-
.../placementdriver/PlacementDriverTest.java | 337 +++++++++++++++
.../leases/LeaseSerializationTest.java | 22 +-
.../cpp/ignite/client/detail/table/table_impl.cpp | 2 +-
.../cpp/ignite/client/detail/table/table_impl.h | 6 +-
.../cpp/ignite/client/detail/table/tables_impl.cpp | 6 +-
.../dotnet/Apache.Ignite.Tests/.editorconfig | 5 +
.../Apache.Ignite.Tests/Apache.Ignite.Tests.csproj | 1 +
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 8 +-
.../Linq/LinqTests.Aggregate.cs | 2 +
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 4 +-
.../dotnet/Apache.Ignite/Internal/Table/Tables.cs | 10 +-
.../configuration/RaftConfigurationSchema.java | 6 +
.../java/org/apache/ignite/internal/raft/Loza.java | 7 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 6 +-
.../raft/client/TopologyAwareRaftGroupService.java | 2 +-
.../apache/ignite/internal/replicator/Replica.java | 11 +-
.../ignite/internal/replicator/ReplicaManager.java | 15 +-
.../replicator/listener/ReplicaListener.java | 18 +
.../replicator/message/TimestampAware.java | 8 +-
modules/rest-api/openapi/openapi.yaml | 28 +-
.../rest/api/deployment/DeploymentCodeApi.java | 2 +-
.../rest/api/deployment/DeploymentInfo.java | 60 ---
.../internal/rest/api/deployment/UnitStatus.java | 12 +-
.../handler/IgniteExceptionHandlerTest.java | 12 +-
.../cluster/ItClusterManagementControllerTest.java | 47 ++
.../DeploymentManagementControllerTest.java | 16 +-
.../apache/ignite/internal/rest/RestComponent.java | 4 +-
.../authentication/NodeOnlyEndpointsFilter.java | 2 +-
.../rest/cluster/ClusterManagementController.java | 58 ++-
.../ConfigurationValidatorFactory.java | 50 +++
.../deployment/DeploymentManagementController.java | 12 +-
.../internal/rest/configuration/TestFactory.java | 9 +-
.../ItDistributedConfigurationPropertiesTest.java | 27 +-
.../configuration/ItNodeConfigurationFileTest.java | 97 +++++
.../ItDistributedConfigurationStorageTest.java | 15 +-
.../storage/ItRebalanceDistributedTest.java | 47 +-
.../internal/deployment/ItDeploymentUnitTest.java | 55 +--
.../zones/ItDistributionZonesFilterTest.java | 151 +++++--
.../ignite/internal/index/ItIndexManagerTest.java | 3 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 3 +-
.../rest/ItNotInitializedClusterRestTest.java | 36 ++
.../app/ItIgniteInMemoryNodeRestartTest.java | 10 +-
.../runner/app/ItIgniteNodeRestartTest.java | 161 ++++---
.../runner/app/ItSchemaChangeTableViewTest.java | 3 -
.../internal/runner/app/ItTablesApiTest.java | 3 +-
.../runner/app/client/ItThinClientComputeTest.java | 6 +-
.../sql/engine/ClusterPerClassIntegrationTest.java | 35 +-
.../internal/sql/engine/ItBuildIndexTest.java | 22 +-
.../internal/sql/engine/ItSecondaryIndexTest.java | 4 +-
.../internal/sql/internal/InternalSchemaTest.java | 3 -
.../ignite/internal/table/ItTableScanTest.java | 159 +++++--
.../org/apache/ignite/internal/app/IgniteImpl.java | 79 ++--
.../internal/component/RestAddressReporter.java | 4 +-
.../DistributedConfigurationUpdater.java | 47 +-
.../DistributedConfigurationUpdaterTest.java | 115 +++++
.../DistributedConfigurationCatchUpTest.java | 7 +-
.../storage/LocalFileConfigurationStorageTest.java | 5 +-
.../ignite/internal/schema/BinaryRowConverter.java | 2 +-
.../ignite/internal/schema/NativeTypeSpec.java | 2 +-
.../ignite/internal/schema/SchemaManager.java | 52 ++-
.../ExtendedTableConfigurationSchema.java | 6 -
.../configuration/TableConfigurationSchema.java | 12 +-
.../configuration/index/IndexValidatorImpl.java | 16 +-
.../index/TableIndexConfigurationSchema.java | 12 +-
.../schema/event/SchemaEventParameters.java | 7 +-
.../index/IndexValidatorImplTest.java | 19 +-
.../testutils/SchemaConfigurationConverter.java | 7 +-
.../ignite/internal/sql/api/SessionImpl.java | 4 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 8 +-
.../internal/sql/engine/exec/ExecutionContext.java | 6 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 10 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 12 +
.../engine/exec/ddl/DdlCommandHandlerWrapper.java | 20 -
.../exec/ddl/DdlToCatalogCommandConverter.java | 36 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 4 +-
.../internal/sql/engine/exec/rel/Outbox.java | 6 +-
.../internal/sql/engine/exec/rel/RootNode.java | 4 +-
.../internal/sql/engine/externalize/RelJson.java | 5 +-
.../engine/prepare/ddl/AlterZoneSetCommand.java | 11 +
.../prepare/ddl/DdlSqlToCommandConverter.java | 29 +-
.../internal/sql/engine/rel/IgniteTableModify.java | 2 +-
.../engine/rel/ProjectableFilterableTableScan.java | 2 +-
.../internal/sql/engine/schema/IgniteSchema.java | 11 +-
.../internal/sql/engine/schema/IgniteTable.java | 3 +-
.../sql/engine/schema/IgniteTableImpl.java | 15 +-
.../sql/engine/schema/SqlSchemaManager.java | 3 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 43 +-
.../sql/engine/trait/DistributionFunction.java | 9 +-
.../sql/engine/trait/IgniteDistributions.java | 5 +-
.../internal/sql/engine/trait/TraitUtils.java | 2 +-
.../sql/engine/util/HashFunctionFactory.java | 4 +-
.../sql/engine/util/HashFunctionFactoryImpl.java | 3 +-
.../internal/sql/engine/StopCalciteModuleTest.java | 5 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 7 +-
.../sql/engine/exec/MockedStructuresTest.java | 2 +-
.../DdlCommandHandlerExceptionHandlingTest.java | 19 +-
.../ddl/DistributionZoneDdlCommandHandlerTest.java | 9 +
.../exec/rel/TableScanNodeExecutionTest.java | 5 +-
.../engine/exec/schema/SqlSchemaManagerTest.java | 13 +-
.../sql/engine/framework/NoOpTransaction.java | 2 +-
.../engine/framework/PredefinedSchemaManager.java | 5 +-
.../internal/sql/engine/framework/TestTable.java | 5 +-
.../planner/AbstractAggregatePlannerTest.java | 4 +-
.../sql/engine/planner/AbstractPlannerTest.java | 36 +-
.../sql/engine/planner/DmlPlannerTest.java | 5 +-
.../sql/engine/planner/HashIndexPlannerTest.java | 5 +-
.../engine/planner/HashIndexSpoolPlannerTest.java | 13 +-
.../engine/planner/JoinColocationPlannerTest.java | 13 +-
.../sql/engine/planner/JoinCommutePlannerTest.java | 5 +-
.../internal/sql/engine/planner/PlannerTest.java | 21 +-
.../sql/engine/planner/SetOpPlannerTest.java | 13 +-
.../planner/SortedIndexSpoolPlannerTest.java | 14 +-
.../sql/engine/planner/TableSpoolPlannerTest.java | 6 +-
.../sql/engine/planner/UnionPlannerTest.java | 8 +-
.../DistributionZoneSqlToCommandConverterTest.java | 85 +++-
.../sql/DistributionZoneSqlDdlParserTest.java | 57 ---
.../internal/storage/MvPartitionStorage.java | 4 +-
.../apache/ignite/internal/storage/ReadResult.java | 8 +-
.../internal/storage/engine/MvTableStorage.java | 46 +-
.../storage/index/HashIndexDescriptor.java | 30 +-
.../internal/storage/index/IndexDescriptor.java | 28 +-
.../storage/index/SortedIndexDescriptor.java | 29 +-
.../storage/index/BinaryTupleComparatorTest.java | 10 +-
.../storage/AbstractMvPartitionStorageTest.java | 2 +-
.../storage/AbstractMvTableStorageTest.java | 124 +++---
.../storage/BaseMvPartitionStorageTest.java | 2 +-
.../storage/impl/TestMvPartitionStorage.java | 17 +-
.../internal/storage/impl/TestMvTableStorage.java | 18 +-
.../index/AbstractHashIndexStorageTest.java | 15 +-
.../index/AbstractSortedIndexStorageTest.java | 15 +-
.../pagememory/AbstractPageMemoryTableStorage.java | 12 +-
.../PersistentPageMemoryTableStorage.java | 24 +-
.../pagememory/VolatilePageMemoryTableStorage.java | 10 +-
.../index/AbstractPageMemoryIndexStorage.java | 2 +-
.../storage/pagememory/index/meta/IndexMeta.java | 2 +-
.../pagememory/index/meta/IndexMetaKey.java | 8 +-
.../pagememory/index/meta/io/IndexMetaIo.java | 34 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 59 ++-
.../pagememory/mv/AddWriteInvokeClosure.java | 8 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 14 +-
.../storage/pagememory/mv/VersionChain.java | 8 +-
.../storage/pagememory/mv/io/VersionChainIo.java | 21 +-
.../VolatilePageMemoryMvTableStorageTest.java | 8 +-
.../storage/rocksdb/ColumnFamilyUtils.java | 9 +-
.../storage/rocksdb/PartitionDataHelper.java | 2 +-
.../storage/rocksdb/RocksDbMetaStorage.java | 7 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 19 +-
.../storage/rocksdb/RocksDbStorageEngine.java | 2 +-
.../storage/rocksdb/RocksDbStorageUtils.java | 7 +-
.../storage/rocksdb/RocksDbTableStorage.java | 36 +-
.../rocksdb/index/AbstractRocksDbIndexStorage.java | 5 +-
.../rocksdb/index/RocksDbHashIndexStorage.java | 6 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 6 +-
.../ignite/distributed/ItTablePersistenceTest.java | 19 +-
.../distributed/ItTxDistributedTestSingleNode.java | 50 ++-
.../ignite/distributed/ReplicaUnavailableTest.java | 12 +-
.../ignite/internal/table/ItColocationTest.java | 4 +-
.../internal/table/IgniteTablesInternal.java | 6 +-
.../ignite/internal/table/InternalTable.java | 35 +-
.../internal/table/KeyValueBinaryViewImpl.java | 46 --
.../ignite/internal/table/KeyValueViewImpl.java | 46 --
.../internal/table/RecordBinaryViewImpl.java | 43 --
.../ignite/internal/table/RecordViewImpl.java | 39 --
.../apache/ignite/internal/table/TableImpl.java | 58 +--
.../table/distributed/HashIndexLocker.java | 7 +-
.../internal/table/distributed/IndexLocker.java | 2 +-
...sSupplier.java => PartitionUpdateHandlers.java} | 34 +-
.../table/distributed/SortedIndexLocker.java | 67 +--
.../table/distributed/StorageUpdateHandler.java | 217 ++--------
.../distributed/TableIndexStoragesSupplier.java | 5 +-
.../internal/table/distributed/TableManager.java | 223 ++++++----
.../distributed/TableSchemaAwareIndexStorage.java | 9 +-
.../distributed/command/BuildIndexCommand.java | 2 +-
.../command/TablePartitionIdMessage.java | 3 +-
.../table/distributed/gc/GcStorageHandler.java | 9 +-
.../table/distributed/gc/GcUpdateHandler.java | 120 ++++++
.../ignite/internal/table/distributed/gc/MvGc.java | 13 +-
.../table/distributed/index/IndexBuildTask.java | 225 ++++++++++
.../table/distributed/index/IndexBuildTaskId.java} | 43 +-
.../table/distributed/index/IndexBuilder.java | 185 ++++++++
.../distributed/index/IndexUpdateHandler.java | 153 +++++++
.../table/distributed/message/HasDataRequest.java | 3 +-
.../distributed/raft/PartitionDataStorage.java | 4 +-
.../table/distributed/raft/PartitionListener.java | 38 +-
.../distributed/raft/snapshot/PartitionAccess.java | 4 +-
.../raft/snapshot/PartitionAccessImpl.java | 37 +-
.../distributed/raft/snapshot/PartitionKey.java | 11 +-
.../snapshot/message/SnapshotMvDataResponse.java | 2 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 2 +-
.../SnapshotAwarePartitionDataStorage.java | 2 +-
.../request/ScanRetrieveBatchReplicaRequest.java | 6 +-
...tionResult.java => CompatValidationResult.java} | 49 +--
.../replicator/IncompatibleSchemaException.java} | 28 +-
.../replicator/PartitionReplicaListener.java | 477 ++++++++++++++++-----
.../replicator/SchemaCompatValidator.java | 87 +++-
.../distributed/replicator/action/RequestType.java | 38 +-
.../distributed/schema/NonHistoricSchemas.java | 17 +-
.../internal/table/distributed/schema/Schemas.java | 24 +-
.../distributed/storage/InternalTableImpl.java | 74 ++--
.../internal/table/event/TableEventParameters.java | 7 +-
.../ignite/internal/utils/RebalanceUtil.java | 7 +-
.../RepeatedFinishReadWriteTransactionTest.java | 12 +-
.../AbstractMvStorageUpdateHandlerTest.java | 43 +-
.../internal/table/distributed/IndexBaseTest.java | 34 +-
.../internal/table/distributed/IndexGcTest.java | 22 +-
.../distributed/StorageUpdateHandlerTest.java | 128 +-----
.../table/distributed/TableManagerTest.java | 2 +-
.../PartitionRaftCommandsSerializationTest.java | 10 +-
.../table/distributed/gc/GcUpdateHandlerTest.java | 87 ++++
.../internal/table/distributed/gc/MvGcTest.java | 111 ++---
.../distributed/index/IndexUpdateHandlerTest.java | 88 ++++
.../raft/PartitionCommandListenerTest.java | 68 +--
.../raft/snapshot/PartitionAccessImplTest.java | 53 ++-
.../incoming/IncomingSnapshotCopierTest.java | 26 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 2 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 4 +-
.../outgoing/OutgoingSnapshotReaderTest.java | 3 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 6 +-
.../outgoing/OutgoingSnapshotsManagerTest.java | 2 +-
.../SnapshotAwarePartitionDataStorageTest.java | 8 +-
.../PartitionReplicaListenerIndexLockingTest.java | 54 ++-
.../replication/PartitionReplicaListenerTest.java | 313 ++++++++++++--
.../distributed/schema/FullTableSchemaTest.java | 2 +-
.../distributed/storage/InternalTableImplTest.java | 3 +-
.../distributed/TestPartitionDataStorage.java | 2 +-
.../ignite/internal/table/TxAbstractTest.java | 3 +-
.../table/impl/DummyInternalTableImpl.java | 49 +--
.../ignite/internal/table/impl/DummySchemas.java | 15 +-
.../org/apache/ignite/internal/tx/LockKey.java | 7 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 2 +
.../apache/ignite/internal/tx/TxManagerTest.java | 2 +-
.../storage/state/AbstractTxStateStorageTest.java | 2 +-
406 files changed, 7323 insertions(+), 5850 deletions(-)
delete mode 100644 modules/api/src/main/java/org/apache/ignite/table/InvocationContext.java
delete mode 100644 modules/api/src/main/java/org/apache/ignite/table/InvokeProcessor.java
delete mode 100644 modules/api/src/main/java/org/apache/ignite/table/InvokeProcessorException.java
delete mode 100644 modules/catalog/src/main/java/org/apache/ignite/internal/catalog/events/AddColumnEventParameters.java
delete mode 100644 modules/catalog/src/main/java/org/apache/ignite/internal/catalog/events/DropColumnEventParameters.java
delete mode 100644 modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/DropColumnsEntry.java
delete mode 100644 modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/NewColumnsEntry.java
create mode 100644 modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/UpdateDistributedConfigurationAction.java
delete mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/DeployMetastoreService.java
delete mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/DeploymentInfo.java
delete mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/UnitMeta.java
copy modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/{UnitStatus.java => UnitStatuses.java} (63%)
delete mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/key/UnitKey.java
rename modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/metastore/{UnitStatusAccumulator.java => ClusterStatusAccumulator.java} (68%)
create mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/metastore/DeploymentUnitStore.java
create mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/metastore/DeploymentUnitStoreImpl.java
copy modules/{metastorage/src/test/java/org/apache/ignite/internal/metastorage/server/SimpleInMemoryKeyValueStorageTest.java => code-deployment/src/main/java/org/apache/ignite/internal/deployunit/metastore/KeyAccumulator.java} (56%)
create mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/metastore/UnitsByNodeAccumulator.java
create mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/metastore/key/UnitKey.java
rename modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/{ => metastore}/key/UnitMetaSerializer.java (74%)
create mode 100644 modules/code-deployment/src/test/java/org/apache/ignite/deployment/metastore/DeploymentUnitStoreImplTest.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/validation/ConfigurationValidator.java
rename modules/configuration/src/main/java/org/apache/ignite/internal/configuration/validation/{ValidationUtil.java => ConfigurationValidatorImpl.java} (64%)
rename modules/configuration/src/test/java/org/apache/ignite/internal/configuration/validation/{ValidationUtilTest.java => ConfigurationValidatorImplTest.java} (89%)
create mode 100644 modules/configuration/src/testFixtures/java/org/apache/ignite/internal/configuration/validation/TestConfigurationValidator.java
delete mode 100644 modules/index/src/main/java/org/apache/ignite/internal/index/IndexBuilder.java
copy modules/{metastorage => metastorage-api}/src/main/java/org/apache/ignite/internal/metastorage/server/time/ClusterTime.java (100%)
rename modules/metastorage/src/integrationTest/java/org/apache/ignite/internal/metastorage/impl/{ItMetaStorageMultipleNodesTest.java => ItMetaStorageMultipleNodesAbstractTest.java} (88%)
copy modules/metastorage/src/{test/java/org/apache/ignite/internal/metastorage/server/RocksDbCompactionKeyValueStorageTest.java => integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItMetaStorageMultipleNodesRocksDbTest.java} (60%)
copy modules/metastorage/src/{test/java/org/apache/ignite/internal/metastorage/server/SimpleInMemoryKeyValueStorageTest.java => integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItMetaStorageMultipleNodesSimpleStorageTest.java} (58%)
create mode 100644 modules/metastorage/src/integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItMetaStorageSafeTimePropagationAbstractTest.java
copy modules/metastorage/src/{test/java/org/apache/ignite/internal/metastorage/server/RocksDbCompactionKeyValueStorageTest.java => integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItMetaStorageSafeTimePropagationRocksDbTest.java} (72%)
copy modules/metastorage/src/{test/java/org/apache/ignite/internal/metastorage/server/SimpleInMemoryKeyValueStorageTest.java => integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItMetaStorageSafeTimePropagationSimpleStorageTest.java} (64%)
rename modules/metastorage/src/{test => testFixtures}/java/org/apache/ignite/internal/metastorage/server/AbstractKeyValueStorageTest.java (96%)
rename modules/{metastorage/src/main/java/org/apache/ignite/internal/metastorage/server/time/ClusterTime.java => placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/LeaseMeta.java} (59%)
create mode 100644 modules/placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/PlacementDriver.java
create mode 100644 modules/placement-driver/src/test/java/org/apache/ignite/internal/placementdriver/PlacementDriverTest.java
delete mode 100644 modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/deployment/DeploymentInfo.java
create mode 100644 modules/rest/src/main/java/org/apache/ignite/internal/rest/configuration/ConfigurationValidatorFactory.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/configuration/ItNodeConfigurationFileTest.java
rename modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management => runner/src/main/java/org/apache/ignite/internal/configuration}/DistributedConfigurationUpdater.java (52%)
create mode 100644 modules/runner/src/test/java/org/apache/ignite/internal/configuration/DistributedConfigurationUpdaterTest.java
copy modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{TableIndexStoragesSupplier.java => PartitionUpdateHandlers.java} (54%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/gc/GcUpdateHandler.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/index/IndexBuildTask.java
copy modules/{index/src/main/java/org/apache/ignite/internal/index/BuildIndexTaskId.java => table/src/main/java/org/apache/ignite/internal/table/distributed/index/IndexBuildTaskId.java} (66%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/index/IndexBuilder.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/index/IndexUpdateHandler.java
rename modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/{ForwardValidationResult.java => CompatValidationResult.java} (65%)
copy modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/meta/IndexMetaKey.java => table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/IncompatibleSchemaException.java} (60%)
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/gc/GcUpdateHandlerTest.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/index/IndexUpdateHandlerTest.java