This is an automated email from the ASF dual-hosted git repository. ptupitsyn pushed a commit to branch ignite-22133-bak in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 03dc2a03099844b1c2c006e96f12b0e18e05385d Merge: b2df1ab58ad d3bbbc8bd92 Author: Pavel Tupitsyn <[email protected]> AuthorDate: Fri Jul 11 11:48:19 2025 +0300 Merge branch 'main' into ignite-22133 .github/workflows/python_dbapi_wheels.yml | 6 +- README.md | 2 +- build.gradle | 6 + buildscripts/jmh.gradle | 7 + check-rules/spotbugs-excludes.xml | 1 + docs/_data/toc.yaml | 7 + .../sql-reference/explain-operators-list.adoc | 505 ++++++ docs/_docs/sql-reference/explain-statement.adoc | 311 ++++ gradle/libs.versions.toml | 27 +- .../tests/e2e/ErrorHandlingTest.java | 73 + .../tests/e2e/IgniteClientCredentialsTest.java | 120 ++ ...dler.java => DataStreamerExceptionHandler.java} | 22 +- ...va => DefaultMigrateCacheExceptionHandler.java} | 26 +- .../IgniteClientConnectionExceptionHandler.java | 22 +- ...cordAndTableSchemaMismatchExceptionHandler.java | 59 + .../cli/persistence/calls/MigrateCacheCall.java | 38 +- .../calls/RetriableMigrateCacheCall.java | 29 +- .../cli/persistence/commands/MigrateCacheCmd.java | 16 +- .../params/IgniteClientAuthenticatorParams.java | 52 + .../calls/RetriableMigrateCacheCallTest.java | 8 +- .../tests/bases/MigrationTestBase.java | 135 +- .../tests/containers/Ignite3ClusterContainer.java | 42 +- .../tests/containers/MigrationToolsContainer.java | 95 ++ .../internal/binarytuple/BinaryTupleParser.java | 97 +- .../compaction/ItCatalogCompactionTest.java | 21 + .../catalog/ItCatalogApiThreadingTest.java | 12 +- .../internal/catalog/CatalogManagerImpl.java | 2 +- .../internal/catalog/storage/UpdateLogImpl.java | 4 +- .../ignite/internal/cli/CliIntegrationTest.java | 17 + .../partitions/states/ItPartitionStatesTest.java | 55 +- .../cli/commands/sql/ItSqlCommandTest.java | 19 + .../call/SingleCallExecutionPipelineBuilder.java | 15 +- .../handler/DefaultExceptionHandlers.java | 15 + .../ignite/internal/cli/sql/table/Table.java | 2 +- .../handler/ClientInboundMessageHandler.java | 12 +- .../ignite/internal/client/TcpIgniteClient.java | 1 + .../internal/client/sql/ClientAsyncResultSet.java | 13 +- .../ignite/internal/client/sql/ClientSql.java | 84 +- .../client/sql/PartitionMappingProvider.java | 151 ++ .../ignite/internal/client/table/ClientSchema.java | 2 +- .../ignite/internal/client/table/ClientTable.java | 9 +- .../apache/ignite/client/ClientMetricsTest.java | 17 +- .../org/apache/ignite/client/ClientSqlTest.java | 9 +- .../ignite/client/PartitionAwarenessTest.java | 55 +- .../ignite/client/TestClientHandlerModule.java | 2 +- .../apache/ignite/client/fakes/FakeCompute.java | 5 +- .../org/apache/ignite/client/fakes/FakeCursor.java | 4 + .../org/apache/ignite/client/fakes/FakeIgnite.java | 5 +- .../client/fakes/FakeIgniteQueryProcessor.java | 16 + .../metrics/ClusterTopologyMetricsSource.java | 2 +- .../metrics/LocalTopologyMetricsSource.java | 2 +- .../internal/deployunit/DeploymentManagerImpl.java | 10 +- modules/compatibility-tests/build.gradle | 28 +- .../internal/client/ClientCompatibilityTests.java | 32 +- ...urrentClientWithOldServerCompatibilityTest.java | 13 + ...ldClientWithCurrentServerCompatibilityTest.java | 273 ++++ .../ignite/internal/OpenApiCompatibilityTest.java | 57 + .../src/test/resources/versions/3_0_0/openapi.yaml | 1652 ++++++++++++++++++++ .../ignite/internal/CompatibilityTestBase.java | 25 +- .../org/apache/ignite/internal/IgniteCluster.java | 16 +- .../apache/ignite/internal/OldClientLoader.java | 75 + .../org/apache/ignite/internal/OpenApiMatcher.java | 454 ++++++ .../apache/ignite/internal/OpenApiMatcherTest.java | 253 +++ .../internal/compute/ComputeComponentImpl.java | 2 +- .../ignite/internal/compute/ComputeUtils.java | 2 +- .../internal/compute/JobExecutionContextImpl.java | 7 +- .../compute/executor/ComputeExecutorImpl.java | 15 + .../platform/dotnet/DotNetComputeExecutor.java | 32 + .../internal/compute/loader/JobClassLoader.java | 106 +- .../compute/loader/JobClassLoaderFactory.java | 78 +- ...JobClassLoader.java => JobClassLoaderImpl.java} | 47 +- ...obClassLoaderFactory.java => JobClasspath.java} | 39 +- .../compute/streamer/StreamerReceiverJob.java | 2 +- .../internal/compute/ComputeComponentImplTest.java | 3 +- .../compute/JobExecutionContextImplTest.java | 4 +- .../compute/executor/ComputeExecutorTest.java | 3 +- .../compute/loader/JobClassLoaderFactoryTest.java | 35 +- .../compute/loader/JobClassLoaderTest.java | 21 +- .../compute/loader/JobContextManagerTest.java | 4 +- .../internal/lang/IgniteSystemProperties.java | 6 +- .../ignite/internal/streamer/StreamerBuffer.java | 31 +- .../internal/streamer/StreamerSubscriber.java | 15 +- .../apache/ignite/internal/util/GridUnsafe.java | 2 +- .../ignite/internal/util/HashCalculator.java | 103 +- .../apache/ignite/internal/util/IgniteUtils.java | 74 +- .../testframework/BaseIgniteAbstractTest.java | 1 - .../testframework/WorkDirectoryExtension.java | 2 +- .../ItRebalanceByPendingAssignmentsQueueTest.java | 12 +- .../rebalance/ItRebalanceDistributedTest.java | 40 +- .../rebalance/PartitionMover.java | 24 +- .../RebalanceMinimumRequiredTimeProviderImpl.java | 11 +- .../RebalanceRaftGroupEventsListener.java | 11 +- .../ZoneRebalanceRaftGroupEventsListener.java | 11 +- ...balanceMinimumRequiredTimeProviderImplTest.java | 24 + .../network/file/TestMessagingService.java | 6 + ...IndexNodeFinishedRwTransactionsCheckerTest.java | 98 +- .../apache/ignite/jdbc/ItJdbcQueryMetricsTest.java | 2 +- .../metastorage/impl/MetaStorageManagerImpl.java | 14 +- .../server/AbstractKeyValueStorage.java | 5 + .../metastorage/server/KeyValueStorage.java | 3 + .../server/NotificationEnqueuedListener.java | 43 + .../metastorage/server/WatchProcessor.java | 69 +- .../metastorage/server/WatchProcessorTest.java | 94 +- .../exporters/otlp/OtlpPushMetricExporter.java | 19 +- modules/metrics/build.gradle | 1 + .../metrics/exporters/TestDoubleStartExporter.java | 22 +- .../metrics/exporters/TestPullMetricExporter.java | 15 +- .../metrics/exporters/TestPushMetricExporter.java | 9 +- .../metrics/exporters/TestSimpleExporter.java | 17 +- .../internal/metrics/AbstractMetricSource.java | 32 +- .../ignite/internal/metrics/MetricManager.java | 5 +- .../ignite/internal/metrics/MetricManagerImpl.java | 167 +- .../ignite/internal/metrics/MetricProvider.java | 24 +- .../ignite/internal/metrics/MetricRegistry.java | 38 +- .../apache/ignite/internal/metrics/MetricSet.java | 47 +- .../ignite/internal/metrics/MetricSetBuilder.java | 22 +- .../{MetricProvider.java => MetricSnapshot.java} | 34 +- .../ignite/internal/metrics/MetricSource.java | 21 + .../metrics/exporters/BasicMetricExporter.java | 47 +- .../internal/metrics/exporters/MetricExporter.java | 11 +- .../metrics/exporters/PushMetricExporter.java | 43 +- .../metrics/exporters/jmx/JmxExporter.java | 52 +- .../metrics/exporters/jmx/MetricSetMbean.java | 34 +- .../metrics/exporters/log/LogPushExporter.java | 9 +- .../sources/StripedThreadPoolMetricSource.java | 31 +- .../metrics/sources/ThreadPoolMetricSource.java | 27 +- .../internal/metrics/MetricEntitiesTest.java | 50 +- .../metrics/exporters/PushExporterTest.java | 9 +- .../internal/metrics/exporters/TestExporter.java | 30 +- .../metrics/exporters/jmx/JmxExporterTest.java | 35 +- .../sources/ThreadPoolMetricSourceTest.java | 2 +- .../ignite/internal/metrics/NoOpMetricManager.java | 7 +- .../ignite/internal/metrics/TestMetricManager.java | 11 +- .../ignite/internal/network/MessagingService.java | 56 +- .../JumpToExecutorByConsistentIdAfterSend.java | 6 + .../JumpToExecutorByConsistentIdAfterSendTest.java | 13 +- .../internal/network/DefaultMessagingService.java | 59 +- .../scalecube/ScaleCubeClusterServiceFactory.java | 1 - .../ScaleCubeDirectMarshallerTransport.java | 17 +- .../network/DefaultMessagingServiceTest.java | 101 ++ .../ScaleCubeDirectMarshallerTransportTest.java | 73 + .../PersistentPageMemoryMetricSource.java | 7 +- .../replacement/ClockPageReplacementFlags.java | 46 +- .../persistence/store/FilePageStoreManager.java | 29 +- .../PendingAssignmentsCalculator.java | 2 +- .../partition/replicator/fixtures/Node.java | 8 +- .../PartitionReplicaLifecycleManager.java | 5 +- .../handlers/TxCleanupRecoveryRequestHandler.java | 63 +- .../raft/snapshot/PartitionSnapshotStorage.java | 62 +- .../snapshot/outgoing/OutgoingSnapshotReader.java | 16 +- .../schema/ExecutorInclinedSchemaSyncService.java | 2 + .../PartitionReplicaLifecycleManagerTest.java | 1 + .../TxCleanupRecoveryRequestHandlerTest.java | 76 + .../outgoing/OutgoingSnapshotReaderTest.java | 3 +- modules/placement-driver/build.gradle | 2 + .../ItPrimaryReplicaChoiceTest.java | 28 +- .../placementdriver/leases/LeaseTracker.java | 271 ++-- .../internal/placementdriver/LeaseTrackerTest.java | 208 ++- modules/platforms/cpp/CMakeLists.txt | 3 +- .../cpp/ignite/client/detail/cluster_connection.h | 2 +- modules/platforms/cpp/ignite/common/CMakeLists.txt | 1 + .../cpp/ignite/common/detail/string_utils.cpp | 62 + .../cpp/ignite/common/detail/string_utils.h | 48 + modules/platforms/cpp/ignite/odbc/CMakeLists.txt | 1 - .../cpp/ignite/odbc/config/config_tools.cpp | 47 +- .../cpp/ignite/odbc/config/config_tools.h | 46 +- .../cpp/ignite/odbc/config/configuration.h | 4 +- .../platforms/cpp/ignite/odbc/meta/column_meta.cpp | 343 ---- modules/platforms/cpp/ignite/odbc/odbc.cpp | 50 +- .../cpp/ignite/odbc/query/column_metadata_query.h | 8 +- modules/platforms/cpp/ignite/odbc/query/cursor.h | 7 +- .../platforms/cpp/ignite/odbc/query/data_query.cpp | 10 +- .../platforms/cpp/ignite/odbc/query/data_query.h | 27 +- .../cpp/ignite/odbc/query/foreign_keys_query.h | 6 +- .../cpp/ignite/odbc/query/primary_keys_query.h | 8 +- modules/platforms/cpp/ignite/odbc/query/query.h | 9 +- .../platforms/cpp/ignite/odbc/query/result_page.h | 3 - .../cpp/ignite/odbc/query/special_columns_query.h | 8 +- .../cpp/ignite/odbc/query/table_metadata_query.cpp | 3 +- .../cpp/ignite/odbc/query/table_metadata_query.h | 8 +- .../cpp/ignite/odbc/query/type_info_query.h | 8 +- .../platforms/cpp/ignite/odbc/sql_connection.cpp | 18 +- modules/platforms/cpp/ignite/odbc/sql_connection.h | 2 - .../platforms/cpp/ignite/odbc/sql_statement.cpp | 244 ++- modules/platforms/cpp/ignite/odbc/sql_statement.h | 5 +- .../platforms/cpp/ignite/protocol/CMakeLists.txt | 1 + modules/platforms/cpp/ignite/protocol/messages.h | 4 +- .../cpp/ignite/protocol/protocol_context.h | 3 + .../cpp/ignite/protocol/sql/column_meta.cpp | 94 ++ .../{odbc/meta => protocol/sql}/column_meta.h | 34 +- modules/platforms/cpp/ignite/protocol/utils.cpp | 2 + modules/platforms/cpp/ignite/protocol/utils.h | 4 +- .../Compute/ComputeJobExecutorBenchmarks.cs | 6 +- .../Compute/PlatformJobBenchmarks.cs | 24 +- .../Apache.Ignite.Tests/Compute/ComputeTests.cs | 10 + .../Compute/Executor/JobLoadContextCacheTests.cs | 131 ++ .../dotnet/Apache.Ignite.Tests/MetricsTests.cs | 40 +- .../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 4 +- .../TestHelpers/ManagementApi.cs | 4 +- .../dotnet/Apache.Ignite/Apache.Ignite.csproj | 3 - .../Apache.Ignite/ApiCompatibilitySuppressions.xml | 115 ++ .../Apache.Ignite/Internal/ClientFailoverSocket.cs | 32 +- .../Apache.Ignite/Internal/ClientSocket.Server.cs | 7 +- .../Compute/Executor/ComputeJobExecutor.cs | 54 +- .../Compute/Executor/DeploymentUnitPaths.cs | 3 +- .../Internal/Compute/Executor/JobLoadContext.cs | 49 +- .../Compute/Executor/JobLoadContextCache.cs | 241 +++ .../Apache.Ignite/Internal/Table/DataStreamer.cs | 4 +- modules/platforms/dotnet/Directory.Build.props | 6 + modules/platforms/python/CMakeLists.txt | 2 +- modules/platforms/python/README.md | 1 - modules/platforms/python/cpp_module/CMakeLists.txt | 5 +- .../odbc/query => python/cpp_module}/cursor.h | 23 +- modules/platforms/python/cpp_module/module.cpp | 167 +- .../platforms/python/cpp_module/node_connection.h | 657 ++++++++ .../platforms/python/cpp_module/py_connection.cpp | 196 +-- .../platforms/python/cpp_module/py_connection.h | 49 +- modules/platforms/python/cpp_module/py_cursor.cpp | 383 +---- modules/platforms/python/cpp_module/py_cursor.h | 18 +- .../odbc/query => python/cpp_module}/result_page.h | 18 +- .../python/cpp_module/ssl_config.h} | 47 +- modules/platforms/python/cpp_module/statement.cpp | 350 +++++ modules/platforms/python/cpp_module/statement.h | 255 +++ modules/platforms/python/cpp_module/utils.cpp | 330 ++-- modules/platforms/python/cpp_module/utils.h | 20 +- .../platforms/python/pyignite_dbapi/__init__.py | 28 +- modules/platforms/python/setup.py | 1 - modules/platforms/python/tests/test_connect.py | 2 +- modules/platforms/python/tests/test_fetch_table.py | 2 +- modules/platforms/python/tests/test_ssl.py | 6 +- modules/raft/build.gradle | 2 +- .../raftsnapshot/ItParallelRaftSnapshotsTest.java | 138 ++ .../ignite/raft/server/ItConnectionErrorTest.java | 43 +- .../ignite/internal/raft/RaftGroupServiceImpl.java | 85 +- .../raft/storage/impl/RocksDbSharedLogStorage.java | 28 +- .../replicator/ZonePartitionReplicaImpl.java | 5 +- .../api/recovery/GlobalPartitionStateResponse.java | 4 - .../api/recovery/LocalPartitionStateResponse.java | 4 - .../rest/metrics/NodeMetricController.java | 2 +- .../rest/recovery/DisasterRecoveryController.java | 88 +- modules/runner/build.gradle | 1 + .../internal/benchmark/SqlSelectAllBenchmark.java | 150 ++ .../runner/app/ItIgniteNodeRestartTest.java | 7 +- .../runner/app/PlatformTestNodeRunner.java | 3 - .../ItSchemaSyncMetastorageDependencyTest.java | 110 ++ .../ignite/internal/table/ItReplicasTest.java | 241 ++- .../org/apache/ignite/internal/app/IgniteImpl.java | 29 +- .../ignite/internal/app/IgniteServerImpl.java | 37 + .../ignite/internal/app/LifecycleManager.java | 7 +- .../ignite/internal/app/ThreadPoolsManager.java | 6 +- .../storage/LocalFileConfigurationStorage.java | 28 +- .../internal/schema/SchemaSafeTimeTrackerImpl.java | 116 ++ .../ignite/internal/app/LifecycleManagerTest.java | 3 +- .../ConfigurationCompatibilityTest.java | 20 +- .../compatibility/framework/ConfigAnnotation.java | 66 + .../compatibility/framework/ConfigNode.java | 141 +- .../framework/ConfigNodeSerializer.java | 4 +- .../framework/ConfigurationTreeComparator.java | 114 +- .../ConfigurationTreeComparatorSelfTest.java | 208 +++ .../framework/ConfigurationTreeScanner.java | 53 +- .../storage/LocalFileConfigurationStorageTest.java | 17 + .../schema/SchemaSafeTimeTrackerImplTest.java} | 33 +- .../compatibility/configuration/snapshot.bin | Bin 3317 -> 3487 bytes .../ignite/internal/AssignmentsTestUtils.java | 108 ++ .../internal/ClusterPerClassIntegrationTest.java | 3 + .../internal/ClusterPerTestIntegrationTest.java | 12 + .../ignite/internal/PublicApiThreadingTests.java | 19 +- .../metastorage/server/WatchListenerInhibitor.java | 5 +- .../internal/schema/SchemaSyncInhibitor.java | 121 ++ .../internal/schema/SchemaSafeTimeTracker.java | 47 + .../ignite/internal/schema/SchemaSyncService.java | 6 + modules/sql-engine/build.gradle | 6 - .../ignite/internal/sql/api/ItSqlApiBaseTest.java | 51 + .../internal/sql/api/ItSqlClientMetricsTest.java | 2 +- .../ignite/internal/sql/engine/ItIntervalTest.java | 364 ++++- .../internal/sql/engine/ItLimitOffsetTest.java | 58 +- .../sql/engine/ItSqlQueryExecutionMetricsTest.java | 2 +- .../datatypes/ItCastTemporalPrecisionTest.java | 43 +- .../sql/group1/explain/sort_and_limit.test | 42 +- .../sql/group1/types/interval/test_interval.test | 79 + .../timestamp/test_incorrect_timestamp_ltz.test | 5 +- .../sql/engine/exec/LogicalRelImplementor.java | 13 +- .../exec/ProjectedTableRowConverterImpl.java | 20 +- .../sql/engine/exec/QueryTaskExecutorImpl.java | 2 +- .../internal/sql/engine/exec/RowHandler.java | 5 + .../internal/sql/engine/exec/ScannableTable.java | 9 +- .../sql/engine/exec/ScannableTableImpl.java | 13 +- .../sql/engine/exec/TableRowConverterFactory.java | 7 +- .../engine/exec/TableRowConverterFactoryImpl.java | 47 +- .../internal/sql/engine/exec/exp/RexImpTable.java | 55 + .../sql/engine/exec/exp/RexToLixTranslator.java | 186 ++- .../sql/engine/exec/exp/agg/Accumulators.java | 42 +- .../engine/exec/exp/agg/AccumulatorsFactory.java | 15 +- .../sql/engine/exec/rel/DataSourceScanNode.java | 20 +- .../sql/engine/exec/rel/IndexScanNode.java | 8 +- .../internal/sql/engine/exec/rel/ModifyNode.java | 4 +- .../sql/engine/exec/rel/NestedLoopJoinNode.java | 93 +- .../internal/sql/engine/exec/rel/Outbox.java | 7 +- .../internal/sql/engine/exec/rel/SortNode.java | 6 + .../sql/engine/exec/rel/TableScanNode.java | 8 +- .../sql/engine/metadata/IgniteMdColumnOrigins.java | 6 +- .../sql/engine/metadata/IgniteMdSelectivity.java | 7 +- .../sql/engine/prepare/ExplainRelAsTextWriter.java | 296 ---- .../sql/engine/prepare/KeyValueGetPlan.java | 29 +- .../internal/sql/engine/prepare/PlannerPhase.java | 11 +- .../sql/engine/prepare/PrepareServiceImpl.java | 2 +- .../pruning/PartitionPruningMetadataExtractor.java | 18 +- .../prepare/pruning/PartitionPruningPredicate.java | 7 - .../sql/engine/rel/AbstractIgniteJoin.java | 19 + .../internal/sql/engine/rel/AbstractIndexScan.java | 4 +- .../internal/sql/engine/rel/IgniteIndexScan.java | 6 +- .../internal/sql/engine/rel/IgniteKeyValueGet.java | 4 +- .../internal/sql/engine/rel/IgniteLimit.java | 5 +- .../ignite/internal/sql/engine/rel/IgniteSort.java | 31 - .../sql/engine/rel/IgniteSystemViewScan.java | 17 +- .../internal/sql/engine/rel/IgniteTableScan.java | 6 +- .../engine/rel/ProjectableFilterableTableScan.java | 14 +- .../engine/rel/logical/IgniteLogicalIndexScan.java | 14 +- .../rel/logical/IgniteLogicalSystemViewScan.java | 6 +- .../engine/rel/logical/IgniteLogicalTableScan.java | 6 +- .../sql/engine/rule/HashJoinConverterRule.java | 8 +- .../sql/engine/rule/LogicalScanConverterRule.java | 8 +- .../sql/engine/rule/MergeJoinConverterRule.java | 6 +- .../sql/engine/rule/SortConverterRule.java | 95 +- .../sql/engine/rule/SortExchangeTransposeRule.java | 92 +- .../internal/sql/engine/rule/SortMergeRule.java | 85 + .../internal/sql/engine/rule/SortRemoveRule.java | 76 + .../engine/rule/TableScanToKeyValueGetRule.java | 6 +- .../sql/engine/rule/logical/ExposeIndexRule.java | 4 +- .../rule/logical/IgniteSubQueryRemoveRule.java | 2 +- .../engine/rule/logical/LogicalOrToUnionRule.java | 8 +- .../engine/rule/logical/ProjectScanMergeRule.java | 31 +- .../engine/schema/AbstractIgniteDataSource.java | 10 +- .../sql/engine/schema/IgniteDataSource.java | 5 +- .../internal/sql/engine/schema/IgniteIndex.java | 8 +- .../sql/engine/schema/IgniteTableImpl.java | 66 +- .../sql/engine/schema/TableDescriptor.java | 14 +- .../sql/engine/schema/TableDescriptorImpl.java | 29 +- .../internal/sql/engine/sql/IgniteSqlParser.java | 4 + .../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 24 +- .../ignite/internal/sql/engine/util/Commons.java | 35 + .../ignite/internal/sql/engine/util/RexUtils.java | 38 +- .../internal/sql/engine/util/RowTypeUtils.java | 39 +- .../sql/engine/exec/DummyScannableTable.java | 82 + .../sql/engine/exec/DummyUpdatableTable.java | 57 + .../exec/ExecutableTableRegistrySelfTest.java | 4 - .../engine/exec/NoOpExecutableTableRegistry.java | 74 +- .../exec/ProjectedTableRowConverterSelfTest.java | 3 +- .../internal/sql/engine/exec/QueryTimeoutTest.java | 68 +- .../engine/exec/exp/ExpressionFactoryImplTest.java | 3 +- .../exec/exp/agg/LiteralValAccumulatorTest.java | 15 +- .../exec/rel/DataSourceScanNodeExecutionTest.java | 13 +- .../exec/rel/IndexScanNodeExecutionTest.java | 36 +- .../engine/exec/rel/ScannableTableSelfTest.java | 24 +- .../engine/framework/ClusterServiceFactory.java | 8 +- .../sql/engine/framework/TestBuilders.java | 115 +- .../sql/engine/framework/TestClusterTest.java | 12 +- .../sql/engine/planner/AbstractPlannerTest.java | 13 +- .../planner/AbstractTpcQueryPlannerTest.java | 29 +- .../sql/engine/planner/AggregatePlannerTest.java | 6 +- .../planner/ColocatedHashAggregatePlannerTest.java | 6 +- .../planner/ColocatedSortAggregatePlannerTest.java | 6 +- .../sql/engine/planner/LimitOffsetPlannerTest.java | 26 +- .../planner/MapReduceHashAggregatePlannerTest.java | 6 +- .../planner/MapReduceSortAggregatePlannerTest.java | 6 +- .../planner/ProjectFilterScanMergePlannerTest.java | 40 +- .../sql/engine/planner/SystemViewPlannerTest.java | 10 +- .../planner/TpcdsColocatedQueryPlannerTest.java | 5 + .../sql/engine/planner/TpcdsQueryPlannerTest.java | 10 +- .../pruning/PartitionPruningPredicateSelfTest.java | 7 +- .../engine/schema/SqlSchemaManagerImplTest.java | 2 +- .../sql/engine/sql/IgniteSqlParserSelfTest.java | 6 +- .../sql/metrics/PlanningCacheMetricsTest.java | 2 +- .../src/test/resources/docs/operator_list.txt | 9 +- .../src/test/resources/tpcds/plan/q1.plan | 189 ++- .../src/test/resources/tpcds/plan/q10.plan | 253 ++- .../test/resources/tpcds/plan/q10_colocated.plan | 253 ++- .../src/test/resources/tpcds/plan/q12.plan | 48 + .../test/resources/tpcds/plan/q12_colocated.plan | 48 + .../src/test/resources/tpcds/plan/q15.plan | 91 +- .../test/resources/tpcds/plan/q15_colocated.plan | 91 +- .../src/test/resources/tpcds/plan/q16.plan | 129 ++ .../test/resources/tpcds/plan/q16_colocated.plan | 129 ++ .../src/test/resources/tpcds/plan/q18.plan | 147 +- .../test/resources/tpcds/plan/q18_colocated.plan | 147 +- .../src/test/resources/tpcds/plan/q19.plan | 123 +- .../test/resources/tpcds/plan/q19_colocated.plan | 123 +- .../test/resources/tpcds/plan/q1_colocated.plan | 189 ++- .../src/test/resources/tpcds/plan/q20.plan | 48 + .../test/resources/tpcds/plan/q20_colocated.plan | 48 + .../src/test/resources/tpcds/plan/q21.plan | 58 + .../test/resources/tpcds/plan/q21_colocated.plan | 58 + .../src/test/resources/tpcds/plan/q22.plan | 71 +- .../test/resources/tpcds/plan/q22_colocated.plan | 71 +- .../src/test/resources/tpcds/plan/q25.plan | 157 +- .../test/resources/tpcds/plan/q25_colocated.plan | 157 +- .../src/test/resources/tpcds/plan/q3.plan | 79 +- .../src/test/resources/tpcds/plan/q30.plan | 213 ++- .../test/resources/tpcds/plan/q30_colocated.plan | 213 ++- .../src/test/resources/tpcds/plan/q32.plan | 103 ++ .../test/resources/tpcds/plan/q32_colocated.plan | 103 ++ .../src/test/resources/tpcds/plan/q33.plan | 383 +++-- .../test/resources/tpcds/plan/q33_colocated.plan | 383 +++-- .../src/test/resources/tpcds/plan/q37.plan | 55 + .../test/resources/tpcds/plan/q37_colocated.plan | 55 + .../test/resources/tpcds/plan/q3_colocated.plan | 79 +- .../src/test/resources/tpcds/plan/q40.plan | 75 + .../test/resources/tpcds/plan/q40_colocated.plan | 75 + .../src/test/resources/tpcds/plan/q41.plan | 91 +- .../test/resources/tpcds/plan/q41_colocated.plan | 91 +- .../src/test/resources/tpcds/plan/q42.plan | 73 +- .../test/resources/tpcds/plan/q42_colocated.plan | 73 +- .../src/test/resources/tpcds/plan/q43.plan | 73 +- .../test/resources/tpcds/plan/q43_colocated.plan | 73 +- .../src/test/resources/tpcds/plan/q46.plan | 139 +- .../test/resources/tpcds/plan/q46_colocated.plan | 139 +- .../src/test/resources/tpcds/plan/q5.plan | 205 +++ .../src/test/resources/tpcds/plan/q50.plan | 66 + .../test/resources/tpcds/plan/q50_colocated.plan | 66 + .../src/test/resources/tpcds/plan/q51.plan | 141 +- .../test/resources/tpcds/plan/q51_colocated.plan | 141 +- .../src/test/resources/tpcds/plan/q52.plan | 79 +- .../test/resources/tpcds/plan/q52_colocated.plan | 79 +- .../src/test/resources/tpcds/plan/q53.plan | 99 +- .../test/resources/tpcds/plan/q53_colocated.plan | 99 +- .../src/test/resources/tpcds/plan/q54.plan | 287 ++-- .../test/resources/tpcds/plan/q54_colocated.plan | 287 ++-- .../src/test/resources/tpcds/plan/q55.plan | 79 +- .../test/resources/tpcds/plan/q55_colocated.plan | 79 +- .../src/test/resources/tpcds/plan/q56.plan | 407 +++-- .../test/resources/tpcds/plan/q56_colocated.plan | 407 +++-- .../src/test/resources/tpcds/plan/q58.plan | 284 ++++ .../test/resources/tpcds/plan/q58_colocated.plan | 284 ++++ .../test/resources/tpcds/plan/q5_colocated.plan | 205 +++ .../src/test/resources/tpcds/plan/q6.plan | 217 ++- .../src/test/resources/tpcds/plan/q60.plan | 383 +++-- .../test/resources/tpcds/plan/q60_colocated.plan | 383 +++-- .../src/test/resources/tpcds/plan/q62.plan | 65 + .../test/resources/tpcds/plan/q62_colocated.plan | 65 + .../src/test/resources/tpcds/plan/q63.plan | 99 +- .../test/resources/tpcds/plan/q63_colocated.plan | 99 +- .../src/test/resources/tpcds/plan/q65.plan | 173 +- .../test/resources/tpcds/plan/q65_colocated.plan | 173 +- .../src/test/resources/tpcds/plan/q66.plan | 152 ++ .../test/resources/tpcds/plan/q66_colocated.plan | 152 ++ .../src/test/resources/tpcds/plan/q68.plan | 141 +- .../test/resources/tpcds/plan/q68_colocated.plan | 141 +- .../src/test/resources/tpcds/plan/q69.plan | 315 ++-- .../test/resources/tpcds/plan/q69_colocated.plan | 315 ++-- .../test/resources/tpcds/plan/q6_colocated.plan | 217 ++- .../src/test/resources/tpcds/plan/q72.plan | 197 ++- .../test/resources/tpcds/plan/q72_colocated.plan | 197 ++- .../src/test/resources/tpcds/plan/q74.plan | 255 +++ .../test/resources/tpcds/plan/q74_colocated.plan | 255 +++ .../src/test/resources/tpcds/plan/q75.plan | 309 ++++ .../test/resources/tpcds/plan/q75_colocated.plan | 309 ++++ .../src/test/resources/tpcds/plan/q76.plan | 165 +- .../test/resources/tpcds/plan/q76_colocated.plan | 165 +- .../src/test/resources/tpcds/plan/q77.plan | 255 +++ .../test/resources/tpcds/plan/q77_colocated.plan | 255 +++ .../src/test/resources/tpcds/plan/q78.plan | 269 ++-- .../test/resources/tpcds/plan/q78_colocated.plan | 269 ++-- .../src/test/resources/tpcds/plan/q79.plan | 119 +- .../test/resources/tpcds/plan/q79_colocated.plan | 119 +- .../src/test/resources/tpcds/plan/q80.plan | 278 ++++ .../test/resources/tpcds/plan/q80_colocated.plan | 278 ++++ .../src/test/resources/tpcds/plan/q81.plan | 213 ++- .../test/resources/tpcds/plan/q81_colocated.plan | 213 ++- .../src/test/resources/tpcds/plan/q82.plan | 55 + .../test/resources/tpcds/plan/q82_colocated.plan | 55 + .../src/test/resources/tpcds/plan/q83.plan | 297 ++++ .../test/resources/tpcds/plan/q83_colocated.plan | 297 ++++ .../src/test/resources/tpcds/plan/q85.plan | 159 +- .../test/resources/tpcds/plan/q85_colocated.plan | 159 +- .../src/test/resources/tpcds/plan/q89.plan | 101 +- .../test/resources/tpcds/plan/q89_colocated.plan | 101 +- .../src/test/resources/tpcds/plan/q90.plan | 177 ++- .../test/resources/tpcds/plan/q90_colocated.plan | 177 ++- .../src/test/resources/tpcds/plan/q92.plan | 104 ++ .../test/resources/tpcds/plan/q92_colocated.plan | 104 ++ .../src/test/resources/tpcds/plan/q93.plan | 91 +- .../test/resources/tpcds/plan/q93_colocated.plan | 91 +- .../src/test/resources/tpcds/plan/q94.plan | 129 ++ .../test/resources/tpcds/plan/q94_colocated.plan | 129 ++ .../src/test/resources/tpcds/plan/q95.plan | 151 ++ .../test/resources/tpcds/plan/q95_colocated.plan | 151 ++ .../src/test/resources/tpcds/plan/q96.plan | 85 +- .../test/resources/tpcds/plan/q96_colocated.plan | 85 +- .../src/test/resources/tpcds/plan/q98.plan | 47 + .../test/resources/tpcds/plan/q98_colocated.plan | 47 + .../src/test/resources/tpcds/plan/q99.plan | 65 + .../test/resources/tpcds/plan/q99_colocated.plan | 65 + .../src/test/resources/tpch/plan/q10.plan | 109 +- .../src/test/resources/tpch/plan/q18.plan | 135 +- .../src/test/resources/tpch/plan/q2.plan | 233 ++- .../src/test/resources/tpch/plan/q21.plan | 227 ++- .../src/test/resources/tpch/plan/q3.plan | 93 +- .../internal/sql/BaseSqlIntegrationTest.java | 2 +- .../internal/sql/engine/util/SqlTestUtils.java | 55 +- .../src/testFixtures/resources/tpcds/query12.sql | 2 +- .../src/testFixtures/resources/tpcds/query16.sql | 8 +- .../src/testFixtures/resources/tpcds/query20.sql | 2 +- .../src/testFixtures/resources/tpcds/query21.sql | 4 +- .../src/testFixtures/resources/tpcds/query32.sql | 6 +- .../src/testFixtures/resources/tpcds/query37.sql | 2 +- .../src/testFixtures/resources/tpcds/query40.sql | 4 +- .../src/testFixtures/resources/tpcds/query5.sql | 6 +- .../src/testFixtures/resources/tpcds/query50.sql | 10 +- .../src/testFixtures/resources/tpcds/query58.sql | 6 +- .../src/testFixtures/resources/tpcds/query62.sql | 10 +- .../src/testFixtures/resources/tpcds/query66.sql | 8 +- .../src/testFixtures/resources/tpcds/query74.sql | 12 +- .../src/testFixtures/resources/tpcds/query75.sql | 2 +- .../src/testFixtures/resources/tpcds/query77.sql | 12 +- .../src/testFixtures/resources/tpcds/query80.sql | 6 +- .../src/testFixtures/resources/tpcds/query82.sql | 2 +- .../src/testFixtures/resources/tpcds/query83.sql | 6 +- .../src/testFixtures/resources/tpcds/query92.sql | 6 +- .../src/testFixtures/resources/tpcds/query94.sql | 8 +- .../src/testFixtures/resources/tpcds/query95.sql | 8 +- .../src/testFixtures/resources/tpcds/query98.sql | 2 +- .../src/testFixtures/resources/tpcds/query99.sql | 10 +- .../internal/storage/engine/MvTableStorage.java | 12 +- .../internal/storage/engine/StorageEngine.java | 15 +- .../engine/ThreadAssertingStorageEngine.java | 19 +- ...va => AbstractPersistentStorageEngineTest.java} | 130 +- .../storage/engine/AbstractStorageEngineTest.java | 335 +--- .../engine/AbstractVolatileStorageEngineTest.java} | 26 +- .../impl/TestMvPartitionStorageFactory.java} | 20 +- .../internal/storage/impl/TestMvTableStorage.java | 21 +- .../internal/storage/impl/TestStorageEngine.java | 9 +- .../storage/impl/TestStorageEngineTest.java} | 20 +- .../PersistentPageMemoryStorageEngine.java | 9 +- .../PersistentPageMemoryTableStorage.java | 9 + .../VolatilePageMemoryStorageEngine.java | 2 +- .../PersistentPageMemoryStorageEngineTest.java | 8 +- .../VolatilePageMemoryStorageEngineTest.java | 3 +- .../storage/rocksdb/ColumnFamilyUtils.java | 2 +- .../storage/rocksdb/RocksDbMvPartitionStorage.java | 1 + .../storage/rocksdb/RocksDbStorageEngine.java | 24 +- .../rocksdb/index/AbstractRocksDbIndexStorage.java | 43 +- .../rocksdb/instance/SharedRocksDbInstance.java | 45 + .../rocksdb/engine/RocksDbStorageEngineTest.java | 9 +- .../internal/table/distributed/TableManager.java | 4 +- .../disaster/DisasterRecoveryManager.java | 29 +- .../table/distributed/disaster/TableState.java} | 50 +- .../distributed/schema/SchemaSyncServiceImpl.java | 14 +- .../distributed/storage/NullStorageEngine.java | 10 +- .../table/ColocationHashCalculationTest.java | 60 + .../table/distributed/PartitionMoverTest.java | 14 +- .../distributed/TableManagerRecoveryTest.java | 2 +- .../schema/SchemaSyncServiceImplTest.java | 14 +- .../storage/NullStorageEngineTest.java} | 23 +- .../table/impl/DummyInternalTableImpl.java | 5 + .../disaster/ItDisasterRecoveryMetricTest.java | 7 +- .../ignite/internal/tx/ItTxTimeoutOneNodeTest.java | 45 +- .../tx/readonly/ItReadOnlyTxInPastTest.java | 49 +- .../tx/distributed/ItTxResourcesVacuumTest.java | 9 - .../TransactionExpirationRegistryBenchmark.java | 6 +- .../internal/tx/impl/TxCleanupRequestHandler.java | 3 +- 560 files changed, 27129 insertions(+), 11513 deletions(-)
