This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-24911
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 05633e95472 Do not render collations for merge join.
add 1213992073d minor after review
add e4279a19141 IGNITE-25232 Sql. Fix flaky
test_incorrect_timestamp_ltz.test (#5758)
add c3b36c99450 IGNITE-25099 Delayed acks for directly mapped client
transactions
add a38e83ee665 IGNITE-25384 Ignore StorageClosedException in Raft
snapshot streaming (#5815)
add b1fd14ba518 IGNITE-22388 Refactor TableManagerTest and remove dead
code (#5814)
add f1730325375 IGNITE-25385 Make TransactionExpirationRegistry
thread-safe (#5819)
add 3b9e19d3778 IGNITE-25381 Fix several
ItDisasterRecoveryReconfigurationTest tests. (#5813)
add 122116ee204 IGNITE-25356 Switch to NaiveAsyncReadWriteLock (#5798)
add 56509fb61f6 IGNITE-25386 Simplify test config overrides (#5817)
add c07e45c08dc IGNITE-25382 Remove compute thread pool size from test
configurations (#5812)
add 38c03aadfa7 IGNITE-25398 Handle RecipientLeftException in
topology-aware raft client (#5828)
add 0aa4d23850b IGNITE-24661 Fix volatile storage docs (#5822)
add 0bb6a754cfa IGNITE-24576 Catalog API - add validation for sort order
definition in Hash indexes (#5832)
add a060bf5159d IGNITE-24496 Fix variable interpolation in packaging
docker-compose (#5821)
add 1b30f24fedd IGNITE-24577 Add test to catalog API with index with
explicit quoted columns (#5826)
add ab24b829b17 IGNITE-25399 Fixed unclear and ugly log message
"[Replicator] Replicator Replicator" (#5831)
add 0941428e9c6 IGNITE-25400 Explicitly reject network connections to self
(#5829)
add 6fa73e29608 IGNITE-25397 .NET: Add RunInTransaction (#5833)
add c4a8b3e4ce1 IGNITE-25352 Sql. Support NULL ORDERING for indexes (#5834)
add 774cf3bdcb5 IGNITE-25392 Implement removeAll()/deleteAll() in KV and
Record views (#5835)
add bbd43f1c702 IGNITE-25395 Move TraceID to the end of error messages
(#5823)
add 3089dfec9c6 IGNITE-25394 Fixed log flooding on remaining nodes when a
node is stopped (#5827)
add 316a0302ef8 IGNITE-25354 .NET: Exclude tests and benchmarks from
release (#5840)
add a1171be225e IGNITE-21461 Add an ability to dynamically change failure
handler configuration (#5837)
add 258c97465e6 IGNITE-24495 Dynamically compute data region sizes (#5841)
add 5c8b5028cba Bump org.junit.platform:junit-platform-console from 1.11.1
to 1.12.2 (#5806)
add 9905a7c2391 IGNITE-25364 Fix migration-tools repack modules publishing
settings (#5801)
add c6a0e89d687 IGNITE-25416: test
QueryTimeoutTest#testTimeoutDistributedRead mute (#5843)
add 14313e7b0fa IGNITE-25415 .NET: Fix platform executor path resolver
(#5842)
add 45b2e176748 IGNITE-25341 Revert IGNITE-22486 because it breaks
compatibility (#5846)
add 94ad16786b7 IGNITE-25190 Current timestamp / date adjusted to user
time zone when cast to varchar (#5784)
add 60e6523ab70 IGNITE-25420 Revert "IGNITE-24495 Dynamically compute data
region sizes (#5841)" (#5848)
add 3a1adc15f2d IGNITE-18426 Sql. Fix distribution function to use the
distribution zone ID instead of the table ID (#5820)
add 1253c75ffc1 IGNITE-25279 Merge two different
ZonePartitionReplicaListenerTest (#5830)
add 4bc9a6b5b42 IGNITE-25426 Ignore NodeStoppingException when destroying
table (#5854)
add bafe828ee5f IGNITE-25417 Fix cluster id mismatch error text (#5845)
add 9b49d3340d6 IGNITE-25363 Sql. Delayed NODE_LEFT event processing may
cause query to hang (#5811)
add 51824cf7f3b IGNITE-25378 Retry flush requests on RocksDb write
throttling (#5808)
add be0cae80a39 IGNITE-25433 Indicate zone based replication on node start
(#5856)
add ddad2f96844 IGNITE-25368 Sql. Make PLAN FOR optional in EXPLAIN PLAN
FOR (#5847)
add 2920aaa0c6d IGNITE-24261 C++ Client: Add qualified names support
(#5860)
add 4a1d40e68dd IGNITE-25104 Support DisasterRecoveryManager methods in
CLI for the Colocation track (#5852)
add 2390a7984b5 IGNITE-25439 Jdbc. Fix java 11 compatibility in tests
(#5861)
add 884fc080757 IGNITE-24314 Fix flaky
ItNodeTest.testInstallSnapshotWithThrottle (#5858)
add 62202509481 IGNITE-25350 Add quorum size parameter to the Catalog API
(#5810)
add bbe5ac37779 IGNITE-24630 Sql. Forbid DESCRIBE statement (#5857)
add 9e6a31e13c5 IGNITE-17557 enable ItPublicApiColocationTest tests (#5866)
add 57e7f421bbb IGNITE-25440 Update ticket mentions (#5864)
add f53e66e2119 IGNITE-25332 Update ignite 2 dependency in migration tools
to 2.17 (#5787)
add 19f11cb1bb7 IGNITE-17592 Fix synchronous await on futures in raft
group events rebalance listener (#5824)
add 9a1f2f8efad IGNITE-25435 Sql. Explain. Improve test coverage of scan
operators (#5859)
add ceabd2e4e27 IGNITE-25442 RPM distribution should mark config files as
such (#5867)
add 273524d8f87 Merge branch 'main' into ignite-24911
No new revisions were added by this update.
Summary of changes:
.../migration-tools-integration-test.gradle | 14 +-
.../config/storage/volatile.adoc | 28 +-
gradle.properties | 3 +-
gradle/libs.versions.toml | 2 +-
migration-tools/README.md | 7 +-
migration-tools/modules/e2e-ai3-tests/build.gradle | 2 +-
.../modules/ignite2-repack/build.gradle | 2 +-
.../modules/ignite3-repack/build.gradle | 5 +-
.../modules/ignite3-slim-repack/build.gradle | 2 +-
.../tests/containers/Ignite2ClusterContainer.java | 5 +-
.../migration-tools-config-converter/build.gradle | 3 +-
.../config/ConfigurationConverterTest.java | 7 +-
.../migration-tools-persistence/build.gradle | 3 +-
.../persistence/MigrationCacheProcessor.java | 3 +-
.../persistence/MigrationKernalContext.java | 2 -
.../tests/e2e/impl/MyBinaryKeyValueCacheTest.java | 2 +-
.../apache/ignite/catalog/annotations/Zone.java | 7 +
.../catalog/definitions/TableDefinition.java | 9 +
.../ignite/catalog/definitions/ZoneDefinition.java | 31 ++
.../java/org/apache/ignite/lang/ErrorGroup.java | 4 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 4 +-
.../apache/ignite/lang/util/IgniteNameUtils.java | 6 +-
.../java/org/apache/ignite/table/KeyValueView.java | 14 +
.../org/apache/ignite/table/QualifiedName.java | 4 +-
.../java/org/apache/ignite/table/RecordView.java | 15 +
.../compaction/ItCatalogCompactionTest.java | 1 -
.../ignite/internal/catalog/ItCatalogDslTest.java | 51 ++-
.../internal/matcher/ZoneDefinitionMatcher.java | 14 +
.../catalog/sql/CreateFromAnnotationsImpl.java | 3 +
.../catalog/sql/CreateFromDefinitionImpl.java | 3 +
.../internal/catalog/sql/CreateTableImpl.java | 9 +
.../internal/catalog/sql/CreateZoneImpl.java | 7 +
.../internal/catalog/sql/IgniteCatalogSqlImpl.java | 15 +-
.../apache/ignite/internal/catalog/sql/Option.java | 4 +
.../catalog/sql/CreateFromAnnotationsTest.java | 23 +-
.../catalog/sql/CreateFromDefinitionTest.java | 17 +-
.../internal/catalog/sql/CreateTableTest.java | 26 ++
.../catalog/sql/InvalidDefinitionTest.java | 24 ++
.../partitions/reset/ItResetPartitionsTest.java | 9 +-
.../restart/ItRestartPartitionsTest.java | 5 +
.../partitions/states/ItPartitionStatesTest.java | 73 +++-
.../call/recovery/reset/ResetPartitionsCall.java | 24 +-
.../recovery/restart/RestartPartitionsCall.java | 27 +-
.../call/recovery/states/PartitionStatesCall.java | 51 ++-
.../partitions/reset/ResetPartitionsMixin.java | 2 +-
.../partitions/restart/RestartPartitionsTest.java | 33 +-
.../ignite/internal/client/proto/ClientOp.java | 31 ++
.../client/proto/ProtocolBitmaskFeature.java | 7 +-
.../internal/client/proto/tx/ClientTxUtils.java | 2 +-
.../ignite/client/handler/ItClientHandlerTest.java | 5 +-
.../ignite/client/handler/ClientContext.java | 18 +-
.../ignite/client/handler/ClientHandlerModule.java | 3 +-
.../handler/ClientInboundMessageHandler.java | 46 ++-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 2 +-
.../requests/sql/ClientSqlExecuteRequest.java | 2 +-
.../sql/ClientSqlQueryMetadataRequest.java | 2 +-
.../handler/requests/table/ClientTableCommon.java | 36 +-
.../table/ClientTupleContainsAllKeysRequest.java | 2 +-
.../table/ClientTupleContainsKeyRequest.java | 2 +-
.../table/ClientTupleDeleteAllExactRequest.java | 6 +-
.../table/ClientTupleDeleteAllRequest.java | 6 +-
.../table/ClientTupleDeleteExactRequest.java | 6 +-
.../requests/table/ClientTupleDeleteRequest.java | 6 +-
.../requests/table/ClientTupleGetAllRequest.java | 2 +-
.../table/ClientTupleGetAndDeleteRequest.java | 6 +-
.../table/ClientTupleGetAndReplaceRequest.java | 6 +-
.../table/ClientTupleGetAndUpsertRequest.java | 6 +-
.../requests/table/ClientTupleGetRequest.java | 2 +-
.../table/ClientTupleInsertAllRequest.java | 8 +-
.../requests/table/ClientTupleInsertRequest.java | 8 +-
.../table/ClientTupleReplaceExactRequest.java | 6 +-
.../requests/table/ClientTupleReplaceRequest.java | 6 +-
.../table/ClientTupleUpsertAllRequest.java | 6 +-
.../requests/table/ClientTupleUpsertRequest.java | 8 +-
.../tx/ClientTransactionCommitRequest.java | 2 -
.../tx/ClientTransactionRollbackRequest.java | 5 +
.../ignite/internal/client/ClientChannel.java | 7 +
.../internal/client/ClientChannelFactory.java | 3 +-
.../client/ClientTransactionInflights.java | 142 +++++++
.../ignite/internal/client/ProtocolContext.java | 16 +
.../ignite/internal/client/ReliableChannel.java | 27 +-
.../ignite/internal/client/TcpClientChannel.java | 27 +-
.../client/table/ClientKeyValueBinaryView.java | 10 +
.../internal/client/table/ClientKeyValueView.java | 10 +
.../client/table/ClientRecordBinaryView.java | 10 +
.../internal/client/table/ClientRecordView.java | 10 +
.../ignite/internal/client/table/ClientTable.java | 74 +++-
.../client/table/ClientTupleSerializer.java | 18 +-
.../table/api/PublicApiClientKeyValueView.java | 10 +
.../table/api/PublicApiClientRecordView.java | 10 +
.../internal/client/tx/ClientLazyTransaction.java | 11 +-
.../internal/client/tx/ClientTransaction.java | 114 +++---
.../internal/client/tx/ClientTransactions.java | 5 +-
.../client/ClientTransactionInflightTest.java | 97 +++++
.../org/apache/ignite/client/MultiClusterTest.java | 8 +-
.../org/apache/ignite/client/RetryPolicyTest.java | 4 +
.../ignite/client/TestClientHandlerModule.java | 1 +
.../apache/ignite/client/fakes/FakeTxManager.java | 5 +-
.../RepeatedFinishClientTransactionTest.java | 20 +-
.../ignite/internal/compute/ItComputeBaseTest.java | 2 +
.../internal/compute/ItComputeTestClient.java | 2 +
.../platform/dotnet/DotNetComputeExecutor.java | 2 +-
.../configuration/tree/ConverterToMapVisitor.java | 64 ++-
.../InjectedValueConfigurationTest.java | 2 +-
.../configuration/hocon/HoconConverterTest.java | 18 +-
.../ConfigurationDuplicatesValidatorTest.java | 1 -
.../ignite/internal/lang/ErrorGroupHelper.java | 4 +-
.../ignite/internal/lang/ErrorGroupTest.java | 14 +-
.../testframework/log4j2/LogInspector.java | 46 ++-
.../RebalanceRaftGroupEventsListener.java | 408 ++++++++++---------
.../ZoneRebalanceRaftGroupEventsListener.java | 412 ++++++++++---------
.../ignite/internal/failure/FailureManager.java | 62 ++-
.../internal/failure/FailureProcessorTest.java | 40 ++
.../ignite/jdbc/ItJdbcClientTimeZoneTest.java | 81 +++-
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 52 ++-
.../ignite/internal/jdbc/JdbcResultSetTest.java | 434 +++++++++++++++++++++
.../internal/network/RecipientLeftException.java | 4 +
.../network/netty/ItConnectionManagerTest.java | 11 +
.../internal/network/DefaultMessagingService.java | 27 +-
.../internal/network/netty/ConnectionManager.java | 6 +-
.../recovery/RecoveryClientHandshakeManager.java | 16 +
.../recovery/message/HandshakeRejectionReason.java | 8 +-
.../message/HandshakeRejectionReasonTest.java | 2 +
.../checkpoint/CheckpointPagesWriterTest.java | 3 +-
.../PartitionReplicaLifecycleManager.java | 1 -
.../ReadWriteMultiRowPkReplicaRequest.java | 10 +-
.../ReadWriteMultiRowReplicaRequest.java | 14 +-
.../replication/ReadWriteReplicaRequest.java | 27 ++
.../ReadWriteSingleRowPkReplicaRequest.java | 12 +-
.../ReadWriteSingleRowReplicaRequest.java | 12 +-
.../ReadWriteSwapRowReplicaRequest.java | 10 +-
.../outgoing/OutgoingSnapshotsManager.java | 7 +-
.../ZonePartitionReplicaListenerTest.java | 215 ----------
.../incoming/IncomingSnapshotCopierTest.java | 2 +-
modules/platforms/build.gradle | 2 +-
modules/platforms/cpp/cmake/dependencies.cmake | 2 +
modules/platforms/cpp/ignite/client/CMakeLists.txt | 7 +
.../cpp/ignite/client/compute/job_target.cpp | 9 +-
.../cpp/ignite/client/compute/job_target.h | 9 +
.../ignite/client/detail/argument_check_utils.h | 24 +-
.../ignite/client/detail/cluster_connection.cpp | 39 +-
.../cpp/ignite/client/detail/cluster_connection.h | 77 ++--
.../client/detail/compute/colocated_job_target.h | 9 +-
.../ignite/client/detail/compute/compute_impl.cpp | 20 +-
.../cpp/ignite/client/detail/node_connection.h | 25 +-
.../cpp/ignite/client/detail/response_handler.h | 4 +-
.../cpp/ignite/client/detail/sql/result_set_impl.h | 4 +-
.../cpp/ignite/client/detail/sql/sql_impl.cpp | 6 +-
.../cpp/ignite/client/detail/table/name_utils.cpp | 133 +++++++
.../cpp/ignite/client/detail/table/name_utils.h | 167 ++++++++
.../ignite/client/detail/table/name_utils_test.cpp | 139 +++++++
.../cpp/ignite/client/detail/table/schema.h | 6 +-
.../cpp/ignite/client/detail/table/table_impl.cpp | 44 ++-
.../cpp/ignite/client/detail/table/table_impl.h | 26 +-
.../cpp/ignite/client/detail/table/tables_impl.cpp | 64 ++-
.../cpp/ignite/client/detail/table/tables_impl.h | 18 +-
.../client/detail/transaction/transaction_impl.h | 2 +-
.../client/detail/transaction/transactions_impl.h | 2 +-
.../platforms/cpp/ignite/client/detail/utils.cpp | 1 +
.../cpp/ignite/client/sql/sql_statement.h | 4 +-
.../cpp/ignite/client/table/qualified_name.cpp | 83 ++++
.../cpp/ignite/client/table/qualified_name.h | 113 ++++++
.../ignite/client/table/qualified_name_test.cpp | 354 +++++++++++++++++
.../platforms/cpp/ignite/client/table/table.cpp | 6 +-
modules/platforms/cpp/ignite/client/table/table.h | 12 +-
.../platforms/cpp/ignite/client/table/tables.cpp | 8 +
modules/platforms/cpp/ignite/client/table/tables.h | 36 +-
modules/platforms/cpp/ignite/common/CMakeLists.txt | 1 +
.../ignite/{odbc => common/detail}/string_utils.h | 0
.../{odbc => common/detail}/string_utils_test.cpp | 1 -
.../platforms/cpp/ignite/common/ignite_result.h | 23 +-
modules/platforms/cpp/ignite/odbc/CMakeLists.txt | 1 -
.../cpp/ignite/odbc/config/config_tools.cpp | 2 +-
.../cpp/ignite/odbc/config/configuration.cpp | 2 +-
.../cpp/ignite/odbc/config/connection_info.cpp | 2 +-
.../platforms/cpp/ignite/odbc/meta/column_meta.cpp | 2 +-
.../cpp/ignite/odbc/query/table_metadata_query.cpp | 2 +-
.../{extension_types.h => bitmask_feature.h} | 38 +-
.../platforms/cpp/ignite/protocol/bitset_span.h | 29 +-
.../cpp/ignite/protocol/client_operation.h | 10 +-
modules/platforms/cpp/ignite/protocol/messages.cpp | 11 +-
.../cpp/ignite/protocol/protocol_context.h | 31 +-
.../cpp/tests/client-test/column_order_test.cpp | 29 +-
.../cpp/tests/client-test/compute_test.cpp | 4 +-
.../cpp/tests/client-test/ignite_runner_suite.h | 5 +-
.../cpp/tests/client-test/tables_test.cpp | 10 +-
.../cpp/tests/client-test/transactions_test.cpp | 3 +-
.../cpp/tests/odbc-test/meta_queries_test.cpp | 2 +-
modules/platforms/cpp/tests/odbc-test/odbc_suite.h | 1 -
.../Apache.Extensions.Caching.Ignite.Tests.csproj | 1 +
.../Apache.Ignite.Benchmarks.csproj | 1 +
.../Apache.Ignite.Internal.Generators.csproj | 1 +
.../Apache.Ignite.Tests/Apache.Ignite.Tests.csproj | 1 +
.../Transactions/TransactionsTests.cs | 61 +++
.../Apache.Ignite/Transactions/ITransactions.cs | 80 ++++
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 22 +-
.../ignite/raft/server/ItConnectionErrorTest.java | 208 ++++++++++
.../ignite/raft/server/JraftAbstractTest.java | 5 +
.../ignite/internal/raft/RaftGroupServiceImpl.java | 29 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 5 +
.../apache/ignite/raft/jraft/core/Replicator.java | 33 +-
.../ignite/raft/jraft/core/ReplicatorTest.java | 31 +-
.../raft/client/TopologyAwareRaftGroupService.java | 3 +-
.../ignite/internal/replicator/ReplicaManager.java | 25 +-
.../ignite/internal/replicator/ReplicaResult.java | 4 +
.../exception/PrimaryReplicaMissException.java | 1 +
.../rest/compute/ItComputeControllerTest.java | 2 +
.../internal/rocksdb/flush/RocksDbFlusher.java | 13 +-
.../internal/rocksdb/flush/RocksDbFlusherTest.java | 141 +++++++
.../internal/benchmark/ClientKvBenchmark.java | 2 +-
.../internal/client/ItClientDirectMappingTest.java | 1 -
.../app/client/ItAbstractThinClientTest.java | 63 +--
.../app/client/ItThinClientTransactionsTest.java | 182 ++++++++-
.../ItThinClientTransactionsWithReplicasTest.java | 108 +++++
.../streamer/ItAbstractDataStreamerTest.java | 6 +-
.../internal/table/ItPublicApiColocationTest.java | 47 ++-
.../table/ItRebalanceWithPartitionReturnTest.java | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 3 +
.../ignite/internal/app/IgniteServerImpl.java | 2 +-
.../internal/restart/RestartProofKeyValueView.java | 10 +
.../internal/restart/RestartProofRecordView.java | 10 +
.../apache/ignite/internal/ConfigOverrideTest.java | 100 +++++
.../storage/LocalFileConfigurationStorageTest.java | 61 +--
.../java/org/apache/ignite/internal/Cluster.java | 44 +--
.../ignite/internal/ClusterConfiguration.java | 272 +++----------
.../internal/ClusterPerClassIntegrationTest.java | 19 +-
.../internal/ClusterPerTestIntegrationTest.java | 1 -
.../testframework/TestIgnitionManager.java | 45 ++-
.../internal/sql/engine/ItColocatedDataTest.java | 174 +++++++++
.../internal/sql/engine/ItSecondaryIndexTest.java | 65 ++-
.../ignite/internal/sql/engine/ItSetOpTest.java | 13 +-
.../integrationTest/sql/group1/explain/scan.test | 274 +++++++++----
.../timestamp/test_incorrect_timestamp_ltz.test | 2 +
modules/sql-engine/src/main/codegen/config.fmpp | 3 +-
.../src/main/codegen/includes/parserImpls.ftl | 48 +--
.../internal/sql/engine/SqlQueryProcessor.java | 6 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 13 +-
.../internal/sql/engine/exec/ExecutionContext.java | 10 +
.../sql/engine/exec/ExecutionServiceImpl.java | 46 +--
.../sql/engine/exec/MailboxRegistryImpl.java | 4 +-
.../sql/engine/exec/exp/RexToLixTranslator.java | 2 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 16 +-
.../internal/sql/engine/exec/rel/Outbox.java | 10 +-
.../internal/sql/engine/externalize/RelJson.java | 4 +-
.../sql/engine/message/MessageListener.java | 13 +-
.../sql/engine/message/MessageServiceImpl.java | 31 +-
.../sql/engine/prepare/ExplainRelAsTextWriter.java | 18 +-
.../sql/engine/prepare/IgniteSqlValidator.java | 6 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 6 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 17 +-
.../internal/sql/engine/rel/IgniteIndexScan.java | 3 +-
.../internal/sql/engine/rel/IgniteMergeJoin.java | 5 +-
.../engine/rel/ProjectableFilterableTableScan.java | 3 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 10 +-
.../internal/sql/engine/sql/IgniteSqlExplain.java | 89 +++++
.../internal/sql/engine/sql/IgniteSqlParser.java | 14 +-
.../sql/engine/sql/IgniteSqlParserUtil.java | 45 ---
.../sql/engine/trait/DistributionFunction.java | 8 +-
.../sql/engine/trait/IgniteDistributions.java | 4 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 252 ++++++------
.../sql/engine/exec/PartitionProvidersTest.java | 6 +-
.../internal/sql/engine/exec/QueryTimeoutTest.java | 2 +
.../sql/engine/exec/RuntimeSortedIndexTest.java | 6 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 7 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 2 +-
.../sql/engine/framework/TestBuilders.java | 1 +
.../internal/sql/engine/framework/TestNode.java | 2 +-
.../sql/engine/planner/DmlPlannerTest.java | 12 +-
.../sql/engine/sql/AbstractParserTest.java | 4 +-
.../sql/engine/sql/ExplainPlanForParserTest.java | 78 ++++
.../sql/engine/sql/IgniteSqlParserSelfTest.java | 17 +-
.../internal/sql/engine/sql/SqlDdlParserTest.java | 48 ++-
.../src/test/resources/tpcds/plan/q64.plan | 330 ++++++++--------
.../src/test/resources/tpch/plan/q1.plan | 16 +-
.../src/test/resources/tpch/plan/q21.plan | 72 ++--
.../src/test/resources/tpch/plan/q5.plan | 52 +--
.../src/test/resources/tpch/plan/q7.plan | 52 +--
.../src/test/resources/tpch/plan/q8.plan | 70 ++--
.../src/test/resources/tpch/plan/q9.plan | 52 +--
.../internal/sql/BaseSqlIntegrationTest.java | 18 +-
.../internal/sql/engine/util/QueryChecker.java | 15 +-
.../index/StorageSortedIndexDescriptor.java | 23 +-
.../ignite/internal/storage/util/StorageUtils.java | 4 +-
.../storage/engine/AbstractStorageEngineTest.java | 4 +-
.../index/AbstractSortedIndexStorageTest.java | 3 +-
.../storage/rocksdb/ColumnFamilyUtils.java | 14 +-
.../storage/rocksdb/ColumnFamilyUtilsTest.java | 18 +-
.../instance/SharedRocksDbInstanceTest.java | 22 +-
.../table/AsyncApiKeyValueViewAdapter.java | 10 +
.../internal/table/AsyncApiRecordViewAdapter.java | 10 +
.../ignite/internal/table/RemoveAllApiTest.java | 178 +++++++++
.../internal/table/KeyValueBinaryViewImpl.java | 12 +
.../ignite/internal/table/KeyValueViewImpl.java | 10 +
.../table/PublicApiThreadingKeyValueView.java | 10 +
.../table/PublicApiThreadingRecordView.java | 10 +
.../internal/table/RecordBinaryViewImpl.java | 10 +
.../ignite/internal/table/RecordViewImpl.java | 10 +
.../internal/table/distributed/TableManager.java | 251 +++++++-----
.../replicator/PartitionReplicaListener.java | 26 +-
.../distributed/storage/InternalTableImpl.java | 47 ++-
.../distributed/storage/NullMvTableStorage.java | 6 +-
.../distributed/storage/NullStorageEngine.java | 2 +-
.../internal/table/distributed/IndexBaseTest.java | 4 +-
.../table/distributed/SortedIndexLockerTest.java | 2 +-
.../table/distributed/StorageCleanupTest.java | 4 +-
.../distributed/StorageUpdateHandlerTest.java | 4 +-
.../table/distributed/TableManagerTest.java | 243 ++++++------
.../PartitionReplicaListenerIndexLockingTest.java | 2 +-
...itionReplicaListenerSortedIndexLockingTest.java | 2 +-
.../replication/PartitionReplicaListenerTest.java | 2 +-
.../ZonePartitionReplicaListenerTest.java | 93 ++++-
.../ItDisasterRecoveryReconfigurationTest.java | 25 +-
.../ItTransactionPrimaryChangeTest.java | 1 -
.../tx/distributed/ItTxResourcesVacuumTest.java | 1 -
.../ignite/internal/tx/InternalTransaction.java | 10 +
.../org/apache/ignite/internal/tx/TxManager.java | 5 +-
.../tx/impl/RemoteReadWriteTransaction.java | 19 +-
.../tx/impl/TransactionExpirationRegistry.java | 33 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 26 +-
packaging/db/build.gradle | 13 +-
packaging/docker/docker-compose.yml | 2 +-
settings.gradle | 2 +-
322 files changed, 7399 insertions(+), 2689 deletions(-)
copy
modules/api/src/main/java/org/apache/ignite/table/DataStreamerOperationType.java
=> buildscripts/migration-tools-integration-test.gradle (80%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/ClientTransactionInflights.java
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/ClientTransactionInflightTest.java
delete mode 100644
modules/partition-replicator/src/test/java/org/apache/ignite/internal/partition/replicator/ZonePartitionReplicaListenerTest.java
create mode 100644
modules/platforms/cpp/ignite/client/detail/table/name_utils.cpp
create mode 100644
modules/platforms/cpp/ignite/client/detail/table/name_utils.h
create mode 100644
modules/platforms/cpp/ignite/client/detail/table/name_utils_test.cpp
create mode 100644 modules/platforms/cpp/ignite/client/table/qualified_name.cpp
create mode 100644 modules/platforms/cpp/ignite/client/table/qualified_name.h
create mode 100644
modules/platforms/cpp/ignite/client/table/qualified_name_test.cpp
rename modules/platforms/cpp/ignite/{odbc => common/detail}/string_utils.h
(100%)
rename modules/platforms/cpp/ignite/{odbc =>
common/detail}/string_utils_test.cpp (99%)
copy modules/platforms/cpp/ignite/protocol/{extension_types.h =>
bitmask_feature.h} (59%)
create mode 100644
modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/ItConnectionErrorTest.java
create mode 100644
modules/rocksdb-common/src/test/java/org/apache/ignite/internal/rocksdb/flush/RocksDbFlusherTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientTransactionsWithReplicasTest.java
create mode 100644
modules/runner/src/test/java/org/apache/ignite/internal/ConfigOverrideTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItColocatedDataTest.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlExplain.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlParserUtil.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/sql/ExplainPlanForParserTest.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/RemoveAllApiTest.java
