This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-21914
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 01bbbd4798 minors.
add e78b369bb5 IGNITE-21920 Cover SQL E051-04 (Basic query specification,
GROUP BY can contain columns not in <select list>) feature by tests (#3572)
add 7a479e147c IGNITE-21480 Check local node before broadcasting (#3568)
add 0c7076c0b6 IGNITE-21594 Storage profiles (#3266)
add 77bbc39bff IGNITE-21995 Do not disable thread assertions in tests
(#3565)
add a4ceab5d43 IGNITE-21892 Await replica services creation in
ItPlacementDriverReplicaSideTest (#3574)
add 010111eaa2 IGNITE-22018 Fix flaky ItConnectionHeartbeatTest (#3582)
add a0bbb71e64 IGNITE-21721 Sql. Adjust cost estimation for index scan
(#3579)
add c47c746b69 IGNITE-19274 Sql. Jdbc client time zone propagation (#3558)
add 4ed64a8b46 IGNITE-21922: Cover SQL E141-01(Basic integrity
constraints, NOT NULL constraints) feature by tests (#3578)
add 1b8046c97d IGNITE-21762 Run cleanup on primary reelection for all
finished txns. (#3540)
add 90b4e2418d IGNITE-21917: Cover SQL T434 (GROUP BY DISTINCT) feature by
tests (#3580)
add 97ccd370e8 IGNITE-21916 Sql. Cover SQL T828 (JSON_QUERY) feature by
tests (#3577)
add 0ce74471de IGNITE-22025 .NET: Remove Console.WriteLine leftovers
(#3586)
add 5c6befafbc IGNITE-21840
PersistentPageMemoryStorageEngine#createMvTable should return MvTableStorage.
(#3477)
add 87cf63d118 IGNITE-21841 The FilePageStoreManager constructor should
not throw an exception. (#3476)
add f10ab88c85 IGNITE-20416 Retry when schema change is detected during
implicit transaction (#3584)
add 94b064ab89 IGNITE-21933 Fix TxStateStorage#leaseStartTime possible
inconsistency with partition storage (#3551)
add 34354d2a59 IGNITE-21987 Optimize RO scan in sorted indexes (#3566)
add 2dd41ef593 IGNITE-22027 Fix
ItPrimaryReplicaChoiceTest#testPrimaryChangeLongHandling (#3593)
add d1635529ef IGNITE-22030 Remove unused jackson-dataformat-msgpack
dependency (#3595)
add 35b117e951 Merge branch 'main' into ignite-21914
No new revisions were added by this update.
Summary of changes:
check-rules/spotbugs-excludes.xml | 1 +
examples/build.gradle | 1 +
examples/config/ignite-config.conf | 7 +
.../storage/ItPageMemoryStorageExampleTest.java | 21 --
.../storage/ItRocksdbStorageExampleTest.java | 11 -
.../PersistentPageMemoryStorageExample.java | 2 +-
.../example/storage/RocksDbStorageExample.java | 2 +-
.../example/storage/StorageEngineExample.java | 15 +-
.../storage/VolatilePageMemoryStorageExample.java | 2 +-
gradle/libs.versions.toml | 1 -
.../org/apache/ignite/catalog/IgniteCatalog.java | 6 +-
.../apache/ignite/catalog/annotations/Zone.java | 14 +-
.../ignite/catalog/definitions/ZoneDefinition.java | 64 ++---
.../internal/ConfigurationModuleArchTest.java | 92 -------
.../ignite/internal/catalog/ItCatalogDslTest.java | 16 +-
.../catalog/sql/CreateFromAnnotationsImpl.java | 7 +-
.../catalog/sql/CreateFromDefinitionImpl.java | 7 +-
.../internal/catalog/sql/CreateZoneImpl.java | 18 +-
.../ignite/internal/catalog/sql/WithOption.java | 4 +
.../catalog/sql/CreateFromAnnotationsTest.java | 37 +--
.../catalog/sql/CreateFromDefinitionTest.java | 13 +-
.../internal/catalog/sql/CreateZoneTest.java | 13 +-
.../catalog/sql/InvalidDefinitionTest.java | 3 -
.../catalog/CatalogParamsValidationUtils.java | 44 ++++
.../ignite/internal/catalog/CatalogService.java | 3 +
.../catalog/commands/AlterZoneCommand.java | 25 +-
.../catalog/commands/AlterZoneCommandBuilder.java | 7 +-
.../internal/catalog/commands/CatalogUtils.java | 29 +--
.../catalog/commands/CreateTableCommand.java | 28 +-
.../commands/CreateTableCommandBuilder.java | 5 +-
.../catalog/commands/CreateZoneCommand.java | 28 +-
.../catalog/commands/CreateZoneCommandBuilder.java | 7 +-
.../catalog/commands/RenameZoneCommand.java | 2 +-
...torageParams.java => StorageProfileParams.java} | 55 ++--
.../descriptors/CatalogDataStorageDescriptor.java | 88 -------
.../CatalogStorageProfileDescriptor.java | 73 ++++++
.../CatalogStorageProfilesDescriptor.java | 90 +++++++
.../descriptors/CatalogTableDescriptor.java | 25 +-
.../catalog/descriptors/CatalogZoneDescriptor.java | 28 +-
.../internal/catalog/storage/AlterColumnEntry.java | 3 +-
.../internal/catalog/storage/DropColumnsEntry.java | 3 +-
.../internal/catalog/storage/NewColumnsEntry.java | 3 +-
.../internal/catalog/storage/RenameTableEntry.java | 3 +-
...CatalogManagerDescriptorCausalityTokenTest.java | 19 +-
.../internal/catalog/CatalogManagerSelfTest.java | 42 +--
.../commands/AbstractCommandValidationTest.java | 21 +-
.../catalog/commands/CatalogUtilsTest.java | 3 +-
.../commands/CreateTableCommandValidationTest.java | 28 ++
.../commands/CreateZoneCommandValidationTest.java | 22 ++
.../CatalogDataStorageDescriptorTest.java | 37 ---
.../descriptors/CatalogTableDescriptorTest.java | 4 +-
.../descriptors/CatalogZoneDescriptorTest.java | 8 +-
.../storage/CatalogEntrySerializationTest.java | 29 ++-
.../ignite/internal/catalog/CatalogTestUtils.java | 12 +-
.../cli/commands/ItConnectionHeartbeatTest.java | 109 ++------
.../repl/executor/ItIgnitePicocliCommandsTest.java | 5 +-
modules/client-common/build.gradle | 1 -
.../internal/jdbc/proto/JdbcQueryEventHandler.java | 5 +-
modules/client-handler/build.gradle | 1 -
.../client/handler/JdbcQueryEventHandlerImpl.java | 23 +-
.../requests/jdbc/ClientJdbcConnectRequest.java | 5 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 5 +-
.../ignite/client/handler/FakeCatalogService.java | 6 +-
modules/client/build.gradle | 1 -
.../apache/ignite/client/fakes/FakeTxManager.java | 11 +
modules/cluster-management/build.gradle | 3 +
.../management/topology/ItLogicalTopologyTest.java | 15 +-
.../cluster/management/NodeAttributes.java | 5 +-
.../management/NodeAttributesCollector.java | 15 +-
.../ClusterManagementConfigurationModule.java | 2 +-
.../StorageProfileConfigurationSchema.java | 36 ---
.../management/raft/CmgRaftGroupListener.java | 2 +-
.../raft/commands/ClusterNodeMessage.java | 3 +-
.../management/topology/api/LogicalNode.java | 25 +-
.../management/BaseItClusterManagementTest.java | 8 +-
.../internal/cluster/management/MockNode.java | 4 +-
modules/compute/build.gradle | 1 +
.../internal/compute/ItWorkerShutdownTest.java | 3 +-
.../internal/compute/ComputeComponentImpl.java | 22 +-
.../compute/messaging/ComputeMessaging.java | 2 +
.../internal/compute/ComputeComponentImplTest.java | 288 ++++++--------------
.../ignite/configuration/ConfigurationModule.java | 5 +-
.../configuration/ConfigurationTreeGenerator.java | 6 +-
.../configuration/ConfigurationTestUtils.java | 0
.../internal/replicator/ReplicatorConstants.java} | 11 +-
.../ignite/internal/thread/ThreadOperation.java | 4 +-
.../apache/ignite/internal/wrapper/Wrappers.java | 22 +-
.../testframework/TestIgnitionManager.java | 9 +-
...st.java => ItDistributionZonesFiltersTest.java} | 70 +++--
...niteDistributionZoneManagerNodeRestartTest.java | 40 +--
.../distributionzones/DistributionZoneManager.java | 6 +-
.../distributionzones/DistributionZonesUtil.java | 61 ++++-
.../distributionzones/NodeWithAttributes.java | 46 +++-
.../CausalityDataNodesEngine.java | 6 +-
.../rebalance/DistributionZoneRebalanceEngine.java | 2 +-
.../BaseDistributionZoneManagerTest.java | 17 ++
...a => DistributionZoneAttributeFiltersTest.java} | 44 ++--
.../DistributionZoneManagerAlterFilterTest.java | 24 +-
...ibutionZoneManagerConfigurationChangesTest.java | 8 +-
.../DistributionZoneManagerFilterTest.java | 24 +-
...istributionZoneManagerScaleUpScaleDownTest.java | 145 ++++++-----
...utionZoneManagerStorageProfilesFilterTest.java} | 51 ++--
.../DistributionZoneStorageProfilesFilterTest.java | 71 +++++
.../DistributionZoneCausalityDataNodesTest.java | 31 ++-
.../DistributionZoneRebalanceEngineTest.java | 13 +
.../RebalanceUtilUpdateAssignmentsTest.java | 4 +-
.../DistributionZonesTestUtil.java | 124 +++++----
.../internal/index/ItBuildIndexOneNodeTest.java | 3 +-
.../ignite/internal/index/ItBuildIndexTest.java | 5 +-
...IndexNodeFinishedRwTransactionsCheckerTest.java | 16 +-
.../index/ItRwTransactionAndIndexesTest.java | 6 +-
.../ignite/internal/index/IndexManagerTest.java | 4 +-
.../apache/ignite/jdbc/ItJdbcBatchSelfTest.java | 7 +-
.../ignite/jdbc/ItJdbcClientTimeZoneTest.java | 228 ++++++++++++++++
.../ignite/internal/jdbc/ConnectionProperties.java | 15 ++
.../internal/jdbc/ConnectionPropertiesImpl.java | 67 ++++-
.../internal/jdbc/JdbcClientQueryEventHandler.java | 7 +-
.../ignite/internal/jdbc/JdbcConnection.java | 62 ++---
.../internal/jdbc/PreparedStatementParamsTest.java | 10 +-
modules/low-watermark/build.gradle | 2 +
.../internal/lowwatermark/LowWatermarkImpl.java | 4 +-
.../lowwatermark/LowWatermarkImplTest.java | 2 +-
modules/metastorage/build.gradle | 2 +
.../ItMetaStorageMultipleNodesAbstractTest.java | 6 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 6 +-
.../processor/messages/MessageImplGenerator.java | 1 -
modules/page-memory/build.gradle | 1 +
.../tree/ItBplusTreeReplaceRemoveRaceTest.java | 18 +-
...ItBplusTreeReuseListVolatilePageMemoryTest.java | 24 +-
.../ItBplusTreeVolatilePageMemoryTest.java | 24 +-
.../ItBplusTreePersistentPageMemoryTest.java | 22 +-
...BplusTreeReuseListPersistentPageMemoryTest.java | 20 +-
.../PageMemoryLocalConfigurationModule.java | 7 +-
...stentPageMemoryProfileConfigurationSchema.java} | 15 +-
...atilePageMemoryProfileConfigurationSchema.java} | 16 +-
.../pagememory/inmemory/VolatilePageMemory.java | 32 +--
.../pagememory/persistence/PartitionMeta.java | 47 +++-
.../persistence/PersistentPageMemory.java | 40 +--
.../pagememory/persistence/io/PartitionMetaIo.java | 27 ++
.../persistence/store/FilePageStoreFactory.java | 2 +-
.../persistence/store/FilePageStoreManager.java | 5 +-
.../pagememory/freelist/AbstractFreeListTest.java | 18 +-
.../inmemory/VolatilePageMemoryNoLoadSelfTest.java | 25 +-
.../persistence/PartitionMetaManagerTest.java | 7 +-
.../pagememory/persistence/PartitionMetaTest.java | 2 +-
.../PersistentPageMemoryNoLoadTest.java | 21 +-
.../persistence/checkpoint/CheckpointerTest.java | 2 +-
.../store/FilePageStoreManagerTest.java | 2 +-
.../ItPrimaryReplicaChoiceTest.java | 117 +++++----
...apache.ignite.configuration.ConfigurationModule | 1 -
.../Apache.Ignite.Tests/ProjectFilesTests.cs | 23 ++
.../Table/SchemaSynchronizationTest.cs | 5 -
.../Apache.Ignite/Internal/Table/DataStreamer.cs | 3 -
.../org/apache/ignite/raft/jraft/JRaftUtils.java | 6 +-
.../ItPlacementDriverReplicaSideTest.java | 25 +-
.../ignite/internal/replicator/ReplicaManager.java | 7 +-
modules/runner/build.gradle | 2 +
.../configuration/generator/DefaultsGenerator.java | 3 +-
.../benchmark/AbstractMultiNodeBenchmark.java | 4 +-
.../internal/benchmark/SqlIndexScanBenchmark.java | 240 +++++++++++++++++
.../ignite/internal/benchmark/TpchBenchmark.java | 16 +-
.../ItDistributedConfigurationPropertiesTest.java | 6 +-
.../ItNodeBootstrapConfigurationTest.java | 2 +-
.../configuration/ItNodeConfigurationFileTest.java | 2 +-
.../ItDistributedConfigurationStorageTest.java | 6 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 26 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 5 +-
.../runner/app/ItIgniteNodeRestartTest.java | 34 ++-
.../app/client/ItAbstractThinClientTest.java | 4 +-
.../ItSchemaSyncAndImplicitTransactionsTest.java | 290 +++++++++++++++++++++
.../schemasync/ItSchemaSyncAndReplicationTest.java | 3 +-
.../schemasync/ItSchemaSyncMultiNodeTest.java | 2 +-
.../schemasync/ItSchemaSyncSingleNodeTest.java | 8 +-
.../ignite/internal/table/ItDurableFinishTest.java | 12 +-
.../ignite/internal/table/ItInternalTableTest.java | 4 +-
.../internal/table/ItReadOnlyTransactionTest.java | 5 +-
.../ignite/internal/table/ItTableScanTest.java | 20 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 13 +-
.../ignite/internal/app/ThreadPoolsManager.java | 3 +-
.../storage/LocalFileConfigurationStorage.java | 47 +++-
.../storage/LocalFileConfigurationStorageTest.java | 4 +-
.../ignite/internal/BaseIgniteRestartTest.java | 4 +
.../internal/ClusterPerClassIntegrationTest.java | 29 ++-
.../internal/ClusterPerTestIntegrationTest.java | 11 +
.../ignite/internal/TestDefaultProfilesNames.java} | 14 +-
.../apache/ignite/internal/table/NodeUtils.java | 5 +-
modules/schema/build.gradle | 3 +-
.../configuration/GcConfigurationSchema.java | 1 -
.../LowWatermarkConfigurationSchema.java | 4 +-
.../ignite/internal/schema/SchemaManagerTest.java | 9 +-
.../CatalogToSchemaDescriptorConverterTest.java | 4 +-
modules/sql-engine/build.gradle | 1 +
.../internal/sql/engine/ItAggregatesTest.java | 3 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 84 +++++-
.../internal/sql/engine/ItIndexSpoolTest.java | 8 +-
.../sql/engine/ItPkOnlyTableCrossApiTest.java | 13 +-
.../internal/sql/engine/ItSecondaryIndexTest.java | 5 +-
.../ignite/internal/sql/engine/ItSetOpTest.java | 1 -
.../internal/sql/engine/ItSqlOperatorsTest.java | 21 +-
.../ignite/internal/sql/engine/ItZoneDdlTest.java | 5 +-
.../internal/sql/engine/ItZonesSystemViewTest.java | 6 +-
.../aggregate/group/test_group_by_distinct.test | 98 +++++++
.../group/test_group_by_not_in_select.test | 64 +++++
.../sql/contstraint/test_not_null_contraint.test | 235 +++++++++++++++++
.../sql/function/json/test_json.test | 25 ++
.../sql/function/json/test_json_exists.test | 51 ++++
.../sql/function/json/test_json_predicate.test | 83 ++++++
.../sql/function/json/test_json_query.test | 96 +++++++
.../sql/function/json/test_json_value.test | 56 ++++
.../integrationTest/sql/types/time/test_time.test | 4 +-
.../sql/types/time/time_parsing.test | 6 +-
.../sql/types/timestamp/test_timestamp.test | 4 +-
.../src/main/codegen/includes/parserImpls.ftl | 6 +-
.../internal/sql/engine/SqlQueryProcessor.java | 7 -
.../sql/engine/exec/DestinationFactory.java | 4 +-
.../engine/exec/RehashingPartitionExtractor.java | 4 +
.../exec/ddl/DdlToCatalogCommandConverter.java | 12 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 70 +++++
.../sql/engine/exec/exp/RexToLixTranslator.java | 6 +-
.../sql/engine/metadata/IgniteMdSelectivity.java | 38 ---
.../sql/engine/metadata/cost/IgniteCost.java | 9 +
.../sql/engine/prepare/PrepareServiceImpl.java | 13 +-
.../sql/engine/prepare/ddl/CreateTableCommand.java | 17 ++
.../sql/engine/prepare/ddl/CreateZoneCommand.java | 43 +--
.../prepare/ddl/DdlSqlToCommandConverter.java | 119 ++-------
.../sql/engine/prepare/ddl/TableOptionEnum.java} | 12 +-
.../sql/engine/prepare/ddl/ZoneOptionEnum.java | 4 +-
.../internal/sql/engine/rel/AbstractIndexScan.java | 9 +-
.../internal/sql/engine/rel/IgniteProject.java | 10 +-
.../engine/rule/HashAggregateConverterRule.java | 4 +-
.../sql/engine/sql/IgniteSqlCreateZone.java | 25 +-
.../internal/sql/engine/util/IgniteMethod.java | 7 +-
.../DdlCommandHandlerExceptionHandlingTest.java | 2 +
.../ddl/DistributionZoneDdlCommandHandlerTest.java | 2 +
.../engine/exec/exp/IgniteSqlFunctionsTest.java | 17 ++
.../exec/rel/TableScanNodeExecutionTest.java | 2 +-
.../sql/engine/framework/TestBuilders.java | 4 +-
.../sql/engine/planner/AbstractPlannerTest.java | 16 +-
.../sql/engine/planner/AggregatePlannerTest.java | 50 +++-
.../planner/IndexSearchBoundsPlannerTest.java | 2 +-
.../planner/MapReduceHashAggregatePlannerTest.java | 6 +-
.../ddl/AbstractDdlSqlToCommandConverterTest.java | 3 +-
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 65 +++--
.../DistributionZoneSqlToCommandConverterTest.java | 43 ++-
.../engine/schema/SqlSchemaManagerImplTest.java | 3 +
...apache.ignite.configuration.ConfigurationModule | 1 -
.../src/test/resources/tpch/plan/q1.plan | 4 +-
.../internal/sql/engine/util/tpch/TpchTables.java | 168 +++++++++++-
.../resources/tpch/ddl/lineitem_ddl.sql | 2 -
.../resources/tpch/ddl/partsupp_ddl.sql | 1 -
modules/storage-api/README.md | 2 +-
modules/storage-api/build.gradle | 3 -
.../internal/storage/DataStorageManager.java | 89 ++-----
.../ignite/internal/storage/DataStorageModule.java | 4 +-
.../internal/storage/DataStorageModules.java | 81 +-----
.../internal/storage/MvPartitionStorage.java | 14 +
.../storage/ThreadAssertingMvPartitionStorage.java | 20 +-
.../StorageConfigurationModule.java} | 23 +-
.../StorageConfigurationSchema.java} | 24 +-
.../StorageEngineConfigurationSchema.java} | 10 +-
.../StorageProfileConfigurationSchema.java} | 19 +-
.../storage/engine/StorageTableDescriptor.java | 14 +-
.../internal/storage/index/SortedIndexStorage.java | 23 +-
.../storage/index/ThreadAssertingIndexStorage.java | 8 +-
.../index/ThreadAssertingSortedIndexStorage.java | 7 +
.../internal/storage/DataStorageManagerTest.java | 162 ------------
.../internal/storage/DataStorageModulesTest.java | 100 +------
.../storage/index/TestSortedIndexStorageTest.java | 5 +
...apache.ignite.configuration.ConfigurationModule | 1 -
.../storage/AbstractMvPartitionStorageTest.java | 23 ++
.../storage/AbstractMvTableStorageTest.java | 4 +-
.../storage/engine/AbstractStorageEngineTest.java | 10 +-
.../storage/impl/TestMvPartitionStorage.java | 22 ++
.../TestPersistStorageConfigurationSchema.java | 34 ---
.../impl/TestStorageLocalConfigurationModule.java | 4 +-
...ma.java => TestProfileConfigurationSchema.java} | 11 +-
.../storage/index/AbstractIndexStorageTest.java | 4 +-
.../index/AbstractSortedIndexStorageTest.java | 187 +++++++++----
.../pagememory/PersistentPageMemoryDataRegion.java | 26 +-
.../PersistentPageMemoryDataStorageModule.java | 11 +-
.../PersistentPageMemoryStorageEngine.java | 68 ++---
.../pagememory/VolatilePageMemoryDataRegion.java | 6 +-
.../VolatilePageMemoryDataStorageModule.java | 11 +-
.../VolatilePageMemoryStorageEngine.java | 40 ++-
.../configuration/PageMemoryDataRegionName.java | 34 ---
.../PageMemoryDataRegionValidatorImpl.java | 93 -------
...emoryStorageEngineLocalConfigurationModule.java | 38 +--
...PageMemoryStorageEngineConfigurationSchema.java | 41 ---
...ntPageMemoryDataStorageConfigurationSchema.java | 38 ---
...PageMemoryStorageEngineConfigurationSchema.java | 33 +--
...StorageEngineExtensionConfigurationSchema.java} | 19 +-
...lePageMemoryDataStorageConfigurationSchema.java | 38 ---
...PageMemoryStorageEngineConfigurationSchema.java | 35 +--
...StorageEngineExtensionConfigurationSchema.java} | 19 +-
.../index/sorted/PageMemorySortedIndexStorage.java | 22 ++
.../mv/PersistentPageMemoryMvPartitionStorage.java | 20 ++
.../mv/VolatilePageMemoryMvPartitionStorage.java | 28 ++
.../PersistentPageMemoryDataRegionTest.java | 46 ++--
.../PersistentPageMemoryMvTableStorageTest.java | 10 +-
.../VolatilePageMemoryMvTableStorageTest.java | 11 +-
.../PageMemoryDataRegionValidatorImplTest.java | 178 -------------
...yStorageEngineLocalConfigurationModuleTest.java | 74 ++++++
.../PersistentPageMemoryStorageEngineTest.java | 7 +-
.../AbstractPageMemoryHashIndexStorageTest.java | 11 +-
.../AbstractPageMemorySortedIndexStorageTest.java | 9 +-
.../PersistentPageMemoryHashIndexStorageTest.java | 12 +-
...PersistentPageMemorySortedIndexStorageTest.java | 12 +-
.../VolatilePageMemoryHashIndexStorageTest.java | 14 +-
.../VolatilePageMemorySortedIndexStorageTest.java | 14 +-
.../storage/pagememory/mv/BlobStorageTest.java | 13 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 14 +-
...rsistentPageMemoryMvPartitionStorageGcTest.java | 14 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 13 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 11 +-
...VolatilePageMemoryMvPartitionStorageGcTest.java | 12 +-
.../VolatilePageMemoryMvPartitionStorageTest.java | 11 +-
.../storage/rocksdb/RocksDbDataRegion.java | 18 +-
.../storage/rocksdb/RocksDbDataStorageModule.java | 10 +-
.../storage/rocksdb/RocksDbMetaStorage.java | 5 +
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 52 +++-
.../storage/rocksdb/RocksDbStorageEngine.java | 37 ++-
.../RocksDbDataRegionValidatorImpl.java | 56 ----
...cksDbStorageEngineLocalConfigurationModule.java | 24 +-
.../RocksDbDataStorageConfigurationSchema.java | 38 ---
...java => RocksDbProfileConfigurationSchema.java} | 12 +-
.../RocksDbStorageEngineConfigurationSchema.java | 23 +-
...StorageEngineExtensionConfigurationSchema.java} | 20 +-
.../rocksdb/index/RocksDbSortedIndexStorage.java | 117 +++++++--
.../rocksdb/instance/SharedRocksDbInstance.java | 2 +
.../RocksDbMvPartitionStorageConcurrencyTest.java | 12 +-
.../rocksdb/RocksDbMvPartitionStorageGcTest.java | 12 +-
.../rocksdb/RocksDbMvPartitionStorageTest.java | 12 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 12 +-
.../storage/rocksdb/RocksDbStorageEngineTest.java | 44 +---
.../RocksDbDataRegionValidatorImplTest.java | 107 --------
.../rocksdb/engine/RocksDbStorageEngineTest.java | 5 +
.../rocksdb/index/RocksDbHashIndexStorageTest.java | 12 +-
.../index/RocksDbSortedIndexStorageTest.java | 12 +-
.../instance/SharedRocksDbInstanceTest.java | 12 +-
...apache.ignite.configuration.ConfigurationModule | 1 -
.../internal/systemview/SystemViewManagerTest.java | 2 +-
modules/table/build.gradle | 1 +
.../apache/ignite/distributed/ItLockTableTest.java | 2 +-
...xDistributedTestSingleNodeNoCleanupMessage.java | 2 +-
.../ItDisasterRecoveryReconfigurationTest.java | 5 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 19 +-
.../rebalance/ItRebalanceDistributedTest.java | 45 ++--
.../rebalance/ItRebalanceRecoveryTest.java | 4 +-
.../ignite/internal/rebalance/ItRebalanceTest.java | 4 +-
.../rebalance/ItRebalanceTriggersRecoveryTest.java | 10 +-
.../ignite/internal/table/ItColocationTest.java | 2 +-
.../internal/table/ItOperationRetryTest.java | 3 +-
.../table/ItTransactionPrimaryChangeTest.java | 3 +-
.../internal/table/ItTransactionRecoveryTest.java | 3 +-
...apache.ignite.configuration.ConfigurationModule | 1 -
.../ignite/internal/table/AbstractTableView.java | 29 ++-
.../internal/table/distributed/TableManager.java | 21 +-
.../table/distributed/command/FinishTxCommand.java | 6 +
.../distributed/raft/PartitionDataStorage.java | 14 +
.../table/distributed/raft/PartitionListener.java | 32 ++-
.../SnapshotAwarePartitionDataStorage.java | 10 +
.../replicator/IncompatibleSchemaException.java | 3 +-
.../replicator/PartitionReplicaListener.java | 73 +++++-
.../replicator/TransactionStateResolver.java | 7 +-
.../CatalogStorageIndexDescriptorSupplierTest.java | 4 +-
.../distributed/TableManagerRecoveryTest.java | 18 +-
.../table/distributed/TableManagerTest.java | 39 +--
.../PartitionRaftCommandsSerializationTest.java | 2 +
.../PersistentPageMemoryGcUpdateHandlerTest.java | 14 +-
.../distributed/gc/RocksDbGcUpdateHandlerTest.java | 11 +-
.../gc/VolatilePageMemoryGcUpdateHandlerTest.java | 12 +-
.../raft/PartitionCommandListenerTest.java | 1 +
.../incoming/IncomingSnapshotCopierTest.java | 4 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 7 +-
.../replication/PartitionReplicaListenerTest.java | 15 +-
.../schema/CatalogValidationSchemasSourceTest.java | 6 +-
.../PartitionCommandsMarshallerImplTest.java | 2 +
.../apache/ignite/distributed/ItTxTestCluster.java | 2 +-
.../distributed/TestPartitionDataStorage.java | 10 +
.../table/impl/DummyInternalTableImpl.java | 2 +-
.../org/apache/ignite/internal/tx/TxManager.java | 25 +-
.../java/org/apache/ignite/internal/tx/TxMeta.java | 17 +-
.../ignite/internal/tx/impl/OrphanDetector.java | 3 +-
.../internal/tx/impl/TxCleanupRequestSender.java | 11 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 60 ++++-
.../ignite/internal/tx/impl/TxMessageSender.java | 18 +-
.../tx/impl/VolatileTxStateMetaStorage.java | 10 +-
.../tx/message/TxCleanupRecoveryRequest.java} | 12 +-
.../ignite/internal/tx/message/TxMessageGroup.java | 5 +
.../state/ThreadAssertingTxStateStorage.java | 18 +-
.../internal/tx/storage/state/TxStateStorage.java | 16 --
.../state/rocksdb/TxStateRocksDbStorage.java | 69 -----
.../apache/ignite/internal/tx/TxManagerTest.java | 2 +-
...apache.ignite.configuration.ConfigurationModule | 1 -
.../storage/state/AbstractTxStateStorageTest.java | 79 ++----
.../tx/storage/state/test/TestTxStateStorage.java | 22 --
396 files changed, 5744 insertions(+), 3865 deletions(-)
delete mode 100644
modules/arch-test/src/test/java/org/apache/ignite/internal/ConfigurationModuleArchTest.java
rename
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/{DataStorageParams.java
=> StorageProfileParams.java} (50%)
delete mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/descriptors/CatalogDataStorageDescriptor.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/descriptors/CatalogStorageProfileDescriptor.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/descriptors/CatalogStorageProfilesDescriptor.java
delete mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/descriptors/CatalogDataStorageDescriptorTest.java
delete mode 100644
modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/configuration/StorageProfileConfigurationSchema.java
rename modules/configuration/src/{test =>
testFixtures}/java/org/apache/ignite/internal/configuration/ConfigurationTestUtils.java
(100%)
copy modules/{api/src/main/java/org/apache/ignite/catalog/ZoneEngine.java =>
core/src/main/java/org/apache/ignite/internal/replicator/ReplicatorConstants.java}
(72%)
rename
modules/distribution-zones/src/integrationTest/java/org/apache/ignite/internal/distributionzones/{ItDistributionZonesFilterTest.java
=> ItDistributionZonesFiltersTest.java} (86%)
rename
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/{DistributionZoneFiltersTest.java
=> DistributionZoneAttributeFiltersTest.java} (79%)
copy
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/{DistributionZoneManagerFilterTest.java
=> DistributionZoneManagerStorageProfilesFilterTest.java} (71%)
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/DistributionZoneStorageProfilesFilterTest.java
create mode 100644
modules/jdbc/src/integrationTest/java/org/apache/ignite/jdbc/ItJdbcClientTimeZoneTest.java
rename
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/{PersistentPageMemoryDataRegionConfigurationSchema.java
=> PersistentPageMemoryProfileConfigurationSchema.java} (77%)
rename
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/{VolatilePageMemoryDataRegionConfigurationSchema.java
=> VolatilePageMemoryProfileConfigurationSchema.java} (81%)
delete mode 100644
modules/placement-driver/src/integrationTest/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/SqlIndexScanBenchmark.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/schemasync/ItSchemaSyncAndImplicitTransactionsTest.java
copy modules/{api/src/main/java/org/apache/ignite/catalog/ZoneEngine.java =>
runner/src/testFixtures/java/org/apache/ignite/internal/TestDefaultProfilesNames.java}
(68%)
rename
modules/{low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark =>
schema/src/main/java/org/apache/ignite/internal/schema}/configuration/LowWatermarkConfigurationSchema.java
(91%)
create mode 100644
modules/sql-engine/src/integrationTest/sql/aggregate/group/test_group_by_distinct.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/aggregate/group/test_group_by_not_in_select.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/contstraint/test_not_null_contraint.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/function/json/test_json_exists.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/function/json/test_json_predicate.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/function/json/test_json_query.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/function/json/test_json_value.test
copy modules/{api/src/main/java/org/apache/ignite/catalog/ZoneEngine.java =>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/TableOptionEnum.java}
(76%)
delete mode 100644
modules/sql-engine/src/test/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
rename
modules/storage-api/src/{testFixtures/java/org/apache/ignite/internal/storage/impl/TestPersistStorageConfigurationModule.java
=>
main/java/org/apache/ignite/internal/storage/configurations/StorageConfigurationModule.java}
(59%)
rename
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/configuration/StorageProfilesConfigurationSchema.java
=>
storage-api/src/main/java/org/apache/ignite/internal/storage/configurations/StorageConfigurationSchema.java}
(62%)
copy modules/{api/src/main/java/org/apache/ignite/catalog/ZoneEngine.java =>
storage-api/src/main/java/org/apache/ignite/internal/storage/configurations/StorageEngineConfigurationSchema.java}
(79%)
rename
modules/{schema/src/main/java/org/apache/ignite/internal/schema/configuration/storage/DataStorageConfigurationSchema.java
=>
storage-api/src/main/java/org/apache/ignite/internal/storage/configurations/StorageProfileConfigurationSchema.java}
(74%)
delete mode 100644
modules/storage-api/src/test/java/org/apache/ignite/internal/storage/DataStorageManagerTest.java
delete mode 100644
modules/storage-api/src/test/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
delete mode 100644
modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/TestPersistStorageConfigurationSchema.java
rename
modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/schema/{TestDataStorageConfigurationSchema.java
=> TestProfileConfigurationSchema.java} (73%)
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/PageMemoryDataRegionName.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/PageMemoryDataRegionValidatorImpl.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/BasePageMemoryStorageEngineConfigurationSchema.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/PersistentPageMemoryDataStorageConfigurationSchema.java
copy
modules/{page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/BasePageMemoryDataRegionConfigurationSchema.java
=>
storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/PersistentPageMemoryStorageEngineExtensionConfigurationSchema.java}
(62%)
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/VolatilePageMemoryDataStorageConfigurationSchema.java
rename
modules/{page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/BasePageMemoryDataRegionConfigurationSchema.java
=>
storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/VolatilePageMemoryStorageEngineExtensionConfigurationSchema.java}
(62%)
delete mode 100644
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/configuration/PageMemoryDataRegionValidatorImplTest.java
create mode 100644
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/configuration/PageMemoryStorageEngineLocalConfigurationModuleTest.java
delete mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/RocksDbDataRegionValidatorImpl.java
delete mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/schema/RocksDbDataStorageConfigurationSchema.java
rename
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/schema/{RocksDbDataRegionConfigurationSchema.java
=> RocksDbProfileConfigurationSchema.java} (83%)
rename
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/{RocksDbDataRegionName.java
=> schema/RocksDbStorageEngineExtensionConfigurationSchema.java} (63%)
delete mode 100644
modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/configuration/RocksDbDataRegionValidatorImplTest.java
delete mode 100644
modules/storage-rocksdb/src/test/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
delete mode 100644
modules/table/src/integrationTest/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
rename modules/{api/src/main/java/org/apache/ignite/catalog/ZoneEngine.java =>
transactions/src/main/java/org/apache/ignite/internal/tx/message/TxCleanupRecoveryRequest.java}
(66%)
delete mode 100644
modules/transactions/src/test/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
