This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-24979
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from cc5425b0843 minor after review.
add 132949f2710 IGNITE-24970 Fix wheels building by GitHub Actions (#5528)
add 8076b986934 IGNITE-24967 Add ability to explicitly specify read
timestamp for RO transactions (#5526)
add 61ca2438a51 IGNITE-24973 Only log long handling warnings in tests
(#5534)
add 4938df8d012 IGNITE-24588 Fixed client-side tuple serialization when
the schema has field names containing non-standard characters (#5493)
add cf0678d8831 IGNITE-24949 Refactor createTableLocally (#5512)
add 63cf4bd7bcd IGNITE-23439 C++: Implement query cancellation (#5532)
add 1e7c76b3636 IGNITE-24982 C++: Add missing headers to public (#5540)
add bf7a16e7da4 IGNITE-24843 Sql. Add tests to verify indexes of temporal
types (#5517)
add 68bb7056ebd IGNITE-24977 Ignore tree-sitter update (#5537)
add d7bc940c771 IGNITE-24986 Fixed throttling properties parsing and error
message (#5545)
add 43091d5a290 Bump asm from 9.7.1 to 9.8 (#5530)
add e4ba67a926b IGNITE-24561 Use direct mapping in client transactions.
add 1dfd79d2b8a IGNITE-24989 Adjust timeout on
ItClientDataStreamerLoadTest.testHighLoad (#5548)
add ce3eeabc526 IGNITE-24932 Fix hanging of module runner tests (#5501)
add 2907b367323 IGNITE-24980 Rename InternalTransaction#startTimestamp()
to schemaTimestamp() (#5550)
add 2a9f3c4b42c IGNITE-25003 Remove ALTER ZONE SET STORAGE PROFILES doc
(#5555)
add 756e68a6140 IGNITE-24788 Configurable coalescing for RAFT heartbeat
(#5477)
add 4c334bd2a8f IGNITE-24497 Rename docker image in docs (#5275)
add 84ddf9747af IGNITE-24702 Fix of CompactedException on the end of
rebalancing (#5468)
add cfc88f22976 IGNITE-24905 Fix MetricSetMbean doesn't support custom
composite metrics (#5481)
add 858c4c1b18e Bump Microsoft.Extensions.Logging.Console from 9.0.2 to
9.0.3 in /modules/platforms/dotnet (#5546)
add 844eab6f3e5 IGNITE-25004 Notify failure handler in CatalogManagerImpl
(#5554)
add 8a48d82a614 IGNITE-24985 Add a test where a node joins to the cluster
of two (#5542)
add 4d6523fa157 IGNITE-24837 C++: Fix error codes (#5557)
add d90b50e8707 IGNITE-22857 C++ Remove NUMBER and BITMASK types (#5558)
add 7dc56ce5186 IGNITE-24974 Pool starvation when stopping zone in
colocation mode (#5547)
add 3d844178311 IGNITE-24997 Adapt runner test for the colocation track
(#5551)
add 6a088094c6f IGNITE-25018 Fix flaky ItLearnersTest (#5566)
add 42cb0e5733e IGNITE-25019 Remove unneeded future from
ClusterManagementGroupManager (#5567)
add 00f0183b12b IGNITE-25015 Fix ItAbstractDataStreamerTest test when the
colocation feature is enabled (#5563)
add 6bf133d8598 IGNITE-24258 .NET: Add QualifiedName API (#5565)
add 708aa899dfc IGNITE-25020 Fix NPE in TableManagerTest when colocation
is enabled (#5570)
add f35f6da3198 IGNITE-24966 Sql. Improve OrderedMergePublisher
performance (#5525)
add f327dbaa7f5 IGNITE-25024 Remove async from
SchemaManager#dropRegistryAsync (#5571)
add 877f3bd9d57 IGNITE-24840 Sql. Extend SQL logic test coverage for TIME
types (#5553)
add 1bfd1c3b7b5 Merge branch 'main' into ignite-24979
No new revisions were added by this update.
Summary of changes:
.github/dependabot.yml | 4 +
.github/workflows/python_dbapi_wheels.yml | 10 +-
DEVNOTES.md | 4 +-
README.md | 2 +-
docs/_docs/sql-reference/distribution-zones.adoc | 1 -
examples/README.md | 26 +-
gradle/libs.versions.toml | 4 +-
.../apache/ignite/lang/util/IgniteNameUtils.java | 4 +-
.../org/apache/ignite/table/QualifiedName.java | 2 +-
modules/catalog-compaction/build.gradle | 1 +
.../compaction/ItCatalogCompactionTest.java | 4 +-
.../compaction/AbstractCatalogCompactionTest.java | 8 +-
modules/catalog/build.gradle | 2 +
.../internal/catalog/BulkUpdateProducer.java | 2 +-
.../ignite/internal/catalog/CatalogManager.java | 12 +
.../internal/catalog/CatalogManagerImpl.java | 34 +-
.../internal/catalog/commands/CatalogUtils.java | 4 +-
.../catalog/commands/CreateSchemaCommand.java | 4 +-
.../descriptors/CatalogHashIndexDescriptor.java | 13 +-
.../CatalogHashIndexDescriptorSerializers.java | 21 +-
.../descriptors/CatalogIndexDescriptor.java | 5 +-
.../descriptors/CatalogObjectDescriptor.java | 35 +-
.../descriptors/CatalogSchemaDescriptor.java | 6 +-
.../CatalogSchemaDescriptorSerializers.java | 20 +-
.../descriptors/CatalogSortedIndexDescriptor.java | 11 +-
.../CatalogSortedIndexDescriptorSerializers.java | 21 +-
.../descriptors/CatalogSystemViewDescriptor.java | 11 +-
.../CatalogSystemViewDescriptorSerializers.java | 20 +-
.../descriptors/CatalogTableDescriptor.java | 15 +-
.../CatalogTableDescriptorSerializers.java | 20 +-
.../catalog/descriptors/CatalogZoneDescriptor.java | 13 +-
.../CatalogZoneDescriptorSerializers.java | 21 +-
.../storage/AbstractChangeIndexStatusEntry.java | 9 +-
.../internal/catalog/storage/AlterColumnEntry.java | 5 +-
.../internal/catalog/storage/AlterZoneEntry.java | 5 +-
.../internal/catalog/storage/DropColumnsEntry.java | 5 +-
.../internal/catalog/storage/DropSchemaEntry.java | 3 +-
.../internal/catalog/storage/DropTableEntry.java | 5 +-
.../internal/catalog/storage/DropZoneEntry.java | 3 +-
.../internal/catalog/storage/NewColumnsEntry.java | 5 +-
.../internal/catalog/storage/NewIndexEntry.java | 7 +-
.../internal/catalog/storage/NewSchemaEntry.java | 5 +-
.../catalog/storage/NewSystemViewEntry.java | 7 +-
.../internal/catalog/storage/NewTableEntry.java | 7 +-
.../internal/catalog/storage/NewZoneEntry.java | 5 +-
.../catalog/storage/ObjectIdGenUpdateEntry.java | 3 +-
.../internal/catalog/storage/RemoveIndexEntry.java | 5 +-
.../internal/catalog/storage/RenameIndexEntry.java | 9 +-
.../internal/catalog/storage/RenameTableEntry.java | 5 +-
.../catalog/storage/SetDefaultZoneEntry.java | 6 +-
.../internal/catalog/storage/UpdateEntry.java | 5 +-
...CatalogManagerDescriptorCausalityTokenTest.java | 78 ++--
.../internal/catalog/CatalogManagerSelfTest.java | 5 +-
.../internal/catalog/CatalogSystemViewTest.java | 5 +-
.../commands/AbstractCommandValidationTest.java | 8 +-
.../catalog/commands/CatalogUtilsTest.java | 2 +-
.../descriptors/CatalogSchemaDescriptorTest.java | 3 +-
.../descriptors/CatalogZoneDescriptorTest.java | 2 +-
.../storage/CatalogEntrySerializationTest.java | 98 +++--
.../CatalogSerializationCompatibilityTest.java | 68 +--
...logSerializationCompatibilityV1ReadsV1Test.java | 4 +-
...logSerializationCompatibilityV2ReadsV1Test.java | 4 +-
...logSerializationCompatibilityV2ReadsV2Test.java | 4 +-
.../storage/TestCatalogObjectDescriptors.java | 27 +-
.../catalog/storage/UpdateLogImplTest.java | 3 +-
.../internal/catalog/BaseCatalogManagerTest.java | 4 +-
.../ignite/internal/catalog/CatalogTestUtils.java | 38 +-
.../internal/client/proto/HandshakeUtils.java | 3 -
.../client/proto/ProtocolBitmaskFeature.java | 7 +-
.../internal/client/proto/tx/ClientTxUtils.java} | 13 +-
.../ignite/client/handler/ItClientHandlerTest.java | 4 +-
.../ignite/client/handler/ClientContext.java | 9 +-
.../ignite/client/handler/ClientHandlerModule.java | 3 +-
.../handler/ClientInboundMessageHandler.java | 44 +-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 2 +-
.../requests/sql/ClientSqlExecuteRequest.java | 2 +-
.../sql/ClientSqlQueryMetadataRequest.java | 2 +-
.../handler/requests/table/ClientTableCommon.java | 100 +++--
.../table/ClientTupleContainsAllKeysRequest.java | 6 +-
.../table/ClientTupleContainsKeyRequest.java | 6 +-
.../table/ClientTupleDeleteAllExactRequest.java | 6 +-
.../table/ClientTupleDeleteAllRequest.java | 6 +-
.../table/ClientTupleDeleteExactRequest.java | 6 +-
.../requests/table/ClientTupleDeleteRequest.java | 6 +-
.../requests/table/ClientTupleGetAllRequest.java | 11 +-
.../table/ClientTupleGetAndDeleteRequest.java | 6 +-
.../table/ClientTupleGetAndReplaceRequest.java | 6 +-
.../table/ClientTupleGetAndUpsertRequest.java | 6 +-
.../requests/table/ClientTupleGetRequest.java | 7 +-
.../table/ClientTupleInsertAllRequest.java | 6 +-
.../requests/table/ClientTupleInsertRequest.java | 6 +-
.../table/ClientTupleReplaceExactRequest.java | 6 +-
.../requests/table/ClientTupleReplaceRequest.java | 6 +-
.../table/ClientTupleUpsertAllRequest.java | 6 +-
.../requests/table/ClientTupleUpsertRequest.java | 6 +-
.../requests/tx/ClientTransactionBeginRequest.java | 58 ++-
.../tx/ClientTransactionCommitRequest.java | 111 ++++-
.../tx/ClientTransactionRollbackRequest.java | 33 +-
.../ignite/internal/client/PartitionMapping.java} | 40 +-
.../ignite/internal/client/ReliableChannel.java | 78 +++-
.../ignite/internal/client/TcpClientChannel.java | 3 +-
.../ignite/internal/client/WriteContext.java} | 12 +-
.../internal/client/compute/ClientCompute.java | 10 +-
.../client/compute/ClientJobExecution.java | 4 +
.../ignite/internal/client/sql/ClientSql.java | 10 +-
.../internal/client/table/ClientDataStreamer.java | 1 +
.../client/table/ClientKeyValueBinaryView.java | 86 ++--
.../internal/client/table/ClientKeyValueView.java | 102 ++---
.../client/table/ClientPartitionManager.java | 8 +-
.../client/table/ClientRecordBinaryView.java | 74 ++--
.../client/table/ClientRecordSerializer.java | 18 +-
.../internal/client/table/ClientRecordView.java | 70 ++--
.../ignite/internal/client/table/ClientTable.java | 203 ++++++---
.../client/table/ClientTupleSerializer.java | 125 ++++--
.../client/table/PartitionAwarenessProvider.java | 31 +-
.../internal/client/tx/ClientLazyTransaction.java | 26 +-
.../internal/client/tx/ClientTransaction.java | 259 +++++++++++-
.../internal/client/tx/ClientTransactions.java | 38 +-
.../client/ObservableTimestampPropagationTest.java | 7 +-
.../ignite/client/TestClientHandlerModule.java | 6 +-
.../ignite/client/fakes/FakeInternalTable.java | 20 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 15 +-
.../RepeatedFinishClientTransactionTest.java | 104 ++++-
.../management/raft/ItCmgRaftServiceTest.java | 3 +-
.../management/ClusterManagementGroupManager.java | 63 +--
.../ClusterManagementGroupManagerTest.java | 2 +-
.../internal/lang/IgniteSystemProperties.java | 3 +
.../util/subscription/OrderedMergePublisher.java | 199 ++++++---
.../java/org/apache/ignite/table/TupleHelper.java | 0
.../testframework/BaseIgniteAbstractTest.java | 1 +
...tDistributionZoneMetaStorageCompactionTest.java | 75 +++-
...niteDistributionZoneManagerNodeRestartTest.java | 7 +-
.../rebalance/ItRebalanceDistributedTest.java | 1 +
.../distributionzones/DataNodesHistory.java | 1 +
.../distributionzones/DistributionZoneManager.java | 32 +-
.../rebalance/DistributionZoneRebalanceEngine.java | 13 +-
.../DistributionZoneRebalanceEngineV2.java | 12 +-
.../RebalanceMinimumRequiredTimeProviderImpl.java | 111 +++--
.../distributionzones/rebalance/RebalanceUtil.java | 33 +-
.../ZoneRebalanceRaftGroupEventsListener.java | 12 +-
.../rebalance/ZoneRebalanceUtil.java | 40 +-
.../DistributionZoneCausalityDataNodesTest.java | 450 +++++++++++---------
.../DistributionZoneRebalanceEngineTest.java | 7 +-
...balanceMinimumRequiredTimeProviderImplTest.java | 7 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 9 +-
.../ZoneRebalanceUtilUpdateAssignmentsTest.java | 6 +-
.../DistributionZonesTestUtil.java | 4 +-
modules/distribution-zones/tech-notes/rebalance.md | 6 +-
.../ignite/internal/jdbc/JdbcConnection.java | 2 +-
.../metastorage/impl/ItMetaStorageServiceTest.java | 3 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 27 +-
.../metastorage/server/WatchProcessor.java | 5 +
.../MetaStorageDeployWatchesCorrectnessTest.java | 2 +-
.../impl/MetaStorageManagerRecoveryTest.java | 2 +-
.../impl/StandaloneMetaStorageManager.java | 12 +-
.../metrics/exporters/jmx/MetricSetMbean.java | 6 +
.../metrics/exporters/jmx/JmxExporterTest.java | 149 ++++++-
.../network/TrackableNetworkMessageHandler.java | 7 +-
.../replicator/ItBigZoneOperationTest.java} | 33 +-
.../partition/replicator/fixtures/Node.java | 1 +
.../replicator/NaiveAsyncReadWriteLock.java | 186 +++++++++
.../PartitionReplicaLifecycleManager.java | 62 +--
.../ReadWriteSingleRowPkReplicaRequest.java | 6 +
.../ReadWriteSingleRowReplicaRequest.java | 6 +
.../ReadWriteSwapRowReplicaRequest.java | 7 +-
.../replicator/NaiveAsyncReadWriteLockTest.java | 140 +++++++
.../PartitionReplicaLifecycleManagerTest.java | 10 +-
.../schema/CatalogValidationSchemasSourceTest.java | 4 +-
modules/platforms/cpp/cmake/dependencies.cmake | 2 +
modules/platforms/cpp/ignite/client/CMakeLists.txt | 6 +
.../platforms/cpp/ignite/client/cancel_handle.cpp | 81 ++++
.../platforms/cpp/ignite/client/cancel_handle.h | 90 ++++
.../client/{ssl_mode.h => cancellation_token.h} | 17 +-
.../ignite/client/detail/argument_check_utils.h | 2 +-
.../client/detail/cancellation_token_impl.cpp | 124 ++++++
.../ignite/client/detail/cancellation_token_impl.h | 91 ++++
.../ignite/client/detail/cluster_connection.cpp | 17 +-
.../cpp/ignite/client/detail/cluster_connection.h | 79 ++--
.../cpp/ignite/client/detail/node_connection.h | 17 +-
.../cpp/ignite/client/detail/sql/result_set_impl.h | 4 +-
.../cpp/ignite/client/detail/sql/sql_impl.cpp | 44 +-
.../cpp/ignite/client/detail/sql/sql_impl.h | 17 +-
.../cpp/ignite/client/detail/table/table_impl.h | 3 +-
.../cpp/ignite/client/detail/type_mapping_utils.h | 2 +-
.../platforms/cpp/ignite/client/detail/utils.cpp | 12 -
.../platforms/cpp/ignite/client/ignite_client.cpp | 2 +-
modules/platforms/cpp/ignite/client/sql/sql.cpp | 13 +-
modules/platforms/cpp/ignite/client/sql/sql.h | 35 +-
.../cpp/ignite/client/table/ignite_tuple.h | 9 +-
modules/platforms/cpp/ignite/common/CMakeLists.txt | 5 +-
modules/platforms/cpp/ignite/common/bit_array.h | 153 -------
.../platforms/cpp/ignite/common/bit_array_test.cpp | 238 -----------
modules/platforms/cpp/ignite/common/ignite_error.h | 52 ++-
.../platforms/cpp/ignite/common/ignite_result.h | 2 +-
modules/platforms/cpp/ignite/common/ignite_type.h | 6 -
modules/platforms/cpp/ignite/common/primitive.h | 29 +-
.../platforms/cpp/ignite/common/primitive_test.cpp | 2 -
.../transactions.cpp => common/uuid.cpp} | 18 +-
modules/platforms/cpp/ignite/common/uuid.h | 7 +
.../network/detail/win/win_async_client_pool.cpp | 2 +-
.../cpp/ignite/network/length_prefix_codec.cpp | 2 +-
.../ignite/network/ssl/secure_socket_client.cpp | 4 +-
.../cpp/ignite/network/ssl/secure_utils.cpp | 2 +-
.../cpp/ignite/odbc/app/application_data_buffer.h | 9 -
.../ignite/odbc/query/column_metadata_query.cpp | 2 +-
.../platforms/cpp/ignite/odbc/query/data_query.cpp | 4 -
.../cpp/ignite/odbc/query/type_info_query.cpp | 5 +-
.../platforms/cpp/ignite/odbc/sql_connection.cpp | 1 +
modules/platforms/cpp/ignite/odbc/type_traits.cpp | 12 +-
.../platforms/cpp/ignite/protocol/CMakeLists.txt | 2 +-
.../cpp/ignite/protocol/client_operation.h | 5 +-
modules/platforms/cpp/ignite/protocol/messages.cpp | 6 +-
.../cpp/ignite/protocol/protocol_version.cpp | 5 +-
modules/platforms/cpp/ignite/protocol/utils.cpp | 42 +-
modules/platforms/cpp/ignite/protocol/utils.h | 7 -
.../cpp/tests/client-test/all_fields_type.h | 1 -
.../cpp/tests/client-test/column_order_test.cpp | 8 +-
.../cpp/tests/client-test/ignite_runner_suite.h | 2 +-
.../client-test/schema_synchronization_test.cpp | 18 +-
.../platforms/cpp/tests/client-test/sql_test.cpp | 234 +++++++++--
.../cpp/tests/client-test/transactions_test.cpp | 4 +-
.../cpp/tests/odbc-test/meta_queries_test.cpp | 2 +-
.../cpp/tests/test-common/ignite_runner.cpp | 7 +
.../cpp/tests/test-common/ignite_runner.h | 12 +-
.../IgniteDistributedCacheTests.cs | 9 +-
.../Apache.Ignite.Tests/Apache.Ignite.Tests.csproj | 2 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 9 +-
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 6 +-
.../dotnet/Apache.Ignite.Tests/IgniteProxyTests.cs | 2 +-
.../dotnet/Apache.Ignite.Tests/MetricsTests.cs | 2 +-
.../Apache.Ignite.Tests/ProjectFilesTests.cs | 2 +-
.../Proto/ColocationHashTests.cs | 1 -
.../dotnet/Apache.Ignite.Tests/RetryPolicyTests.cs | 2 +-
.../Table/IgniteNameUtilsTests.cs | 104 +++++
.../Table/KeyColumnOrderTests.cs | 3 +-
.../Table/KeyValueViewBinaryTests.cs | 2 +-
.../Table/KeyValueViewPocoTests.cs | 2 +-
.../Table/KeyValueViewPrimitiveTests.cs | 2 +-
.../Table/QualifiedNameTests.cs | 193 +++++++++
.../Table/RecordViewBinaryTests.cs | 2 +-
.../Table/RecordViewPocoTests.cs | 3 +-
.../Table/SchemaSynchronizationTest.cs | 2 +-
.../Table/SchemaValidationTest.cs | 3 +-
.../Apache.Ignite.Tests/Table/TablesTests.cs | 43 +-
.../dotnet/Apache.Ignite/ClientOperationType.cs | 2 +-
.../dotnet/Apache.Ignite/Compute/JobTarget.cs | 17 +-
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 37 +-
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 9 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 8 +-
.../Apache.Ignite/Internal/ConnectionContext.cs | 13 +-
.../Internal/Linq/ExpressionWalker.cs | 2 +-
.../Internal/Linq/IIgniteQueryableInternal.cs | 3 +-
.../Internal/Linq/IgniteQueryProvider.cs | 5 +-
.../Apache.Ignite/Internal/Linq/IgniteQueryable.cs | 3 +-
.../Apache.Ignite/Internal/Proto/ClientOp.cs | 8 +-
.../Internal/Proto/ClientOpExtensions.cs | 4 +-
.../Proto/ProtocolBitmaskFeature.cs} | 21 +-
.../Internal/Table/IgniteNameUtils.cs | 227 ++++++++++
.../Apache.Ignite/Internal/Table/KeyValueView.cs | 2 +-
.../Apache.Ignite/Internal/Table/RecordView.cs | 2 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 11 +-
.../dotnet/Apache.Ignite/Internal/Table/Tables.cs | 107 +++--
.../platforms/dotnet/Apache.Ignite/Table/ITable.cs | 5 +
.../dotnet/Apache.Ignite/Table/ITables.cs | 7 +
.../dotnet/Apache.Ignite/Table/QualifiedName.cs | 151 +++++++
modules/platforms/python/CMakeLists.txt | 1 +
modules/platforms/python/MANIFEST.in | 1 -
modules/platforms/python/cpp_module/CMakeLists.txt | 11 +-
.../apache/ignite/internal/raft/RaftManager.java | 49 +--
.../raft/RaftNodeDisruptorConfiguration.java | 52 ---
.../ignite/internal/raft/ItLearnersTest.java | 34 +-
.../apache/ignite/internal/raft/ItLozaTest.java | 18 +-
.../internal/raft/ItRaftGroupServiceTest.java | 124 +++++-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 2 +
.../java/org/apache/ignite/internal/raft/Loza.java | 71 +---
.../internal/raft/server/RaftGroupOptions.java | 48 ++-
.../internal/raft/server/impl/JraftServerImpl.java | 18 +-
.../apache/ignite/raft/jraft/RaftGroupService.java | 26 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 70 ++--
.../raft/jraft/disruptor/StripedDisruptor.java | 28 +-
.../ignite/raft/jraft/option/NodeOptions.java | 18 +
.../rpc/impl/core/DefaultRaftClientService.java | 3 +-
.../ignite/disruptor/StripedDisruptorTest.java | 7 +
.../org/apache/ignite/internal/raft/LozaTest.java | 5 +-
.../ignite/raft/jraft/core/FSMCallerTest.java | 2 +
.../raft/jraft/core/ReadOnlyServiceTest.java | 2 +
.../raft/jraft/storage/impl/LogManagerTest.java | 2 +
modules/runner/build.gradle | 20 +-
.../benchmark/AbstractMultiNodeBenchmark.java | 17 +-
...sertKvBenchmark.java => ClientKvBenchmark.java} | 72 ++--
...sertKvBenchmark.java => RemoteKvBenchmark.java} | 101 +----
.../internal/client/ItClientDirectMappingTest.java | 150 +++++++
.../inmemory/ItRaftStorageVolatilityTest.java | 46 ++-
.../ignite/internal/runner/app/ItAddNodeTest.java} | 39 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 36 +-
.../runner/app/ItIgniteNodeRestartTest.java | 38 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 2 +
.../runner/app/ItReplicaStateManagerTest.java | 15 +-
.../app/client/ItAbstractThinClientTest.java | 4 +-
.../app/client/ItThinClientTransactionsTest.java | 253 +++++++++++-
.../streamer/ItClientDataStreamerLoadTest.java | 2 +
.../ignite/internal/table/ItTableScanTest.java | 27 +-
.../partition/ItAbstractPartitionManagerTest.java | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 1 +
.../ignite/internal/schema/SchemaManager.java | 16 +-
.../ignite/internal/schema/SchemaManagerTest.java | 6 +-
.../internal/sql/engine/ItTemporalIndexTest.java | 323 +++++++++++++++
.../ignite/internal/sql/sqllogic/Statement.java | 1 +
.../sql/group1/types/time/test_time.test | 143 +++++++
.../sql/group1/types/time/time_parsing.test | 82 ++++
.../internal/sql/engine/SqlQueryProcessor.java | 2 +-
.../sql/engine/exec/fsm/QueryExecutor.java | 2 +-
.../sql/engine/tx/QueryTransactionContextImpl.java | 2 +-
.../sql/engine/framework/ExplicitTxContext.java | 2 +-
.../sql/engine/framework/NoOpTransaction.java | 7 +-
.../pagememory/PersistentPageMemoryDataRegion.java | 6 +-
.../disaster/system/ItCmgDisasterRecoveryTest.java | 4 +-
.../table/ItKeyValueBinaryViewApiTest.java | 290 ++++++++-----
.../internal/table/ItKeyValueViewApiBaseTest.java | 6 +-
.../internal/table/ItKeyValueViewApiTest.java | 5 +-
.../table/ItKeyValueViewSimpleSchemaApiTest.java | 25 +-
.../internal/table/ItOperationRetryTest.java | 13 +-
.../internal/table/ItRecordBinaryViewApiTest.java | 456 +++++++++++++--------
.../internal/table/ItRecordViewApiBaseTest.java | 6 +-
.../ignite/internal/table/ItRecordViewApiTest.java | 25 +-
.../table/ItTableViewApiUnifiedBaseTest.java | 123 +++---
.../ignite/internal/table/AbstractTableView.java | 2 +-
.../ignite/internal/table/InternalTable.java | 12 +-
.../internal/table/KeyValueBinaryViewImpl.java | 5 +-
...lueTupleStreamerPartitionAwarenessProvider.java | 3 +-
.../ignite/internal/table/KeyValueViewImpl.java | 5 +-
.../internal/table/RecordBinaryViewImpl.java | 5 +-
.../ignite/internal/table/RecordViewImpl.java | 5 +-
.../TupleStreamerPartitionAwarenessProvider.java | 3 +-
.../table/distributed/TableAssignmentsService.java | 257 ++++++++++++
.../internal/table/distributed/TableManager.java | 296 ++++---------
.../distributed/disaster/GroupUpdateRequest.java | 35 +-
.../replicator/PartitionReplicaListener.java | 58 ++-
.../distributed/storage/InternalTableImpl.java | 80 ++--
.../table/partition/HashPartitionManagerImpl.java | 18 +-
.../ignite/internal/utils/RebalanceUtilEx.java | 21 +-
.../distributed/TableManagerRecoveryTest.java | 3 +-
.../table/distributed/TableManagerTest.java | 17 +-
.../disaster/DisasterRecoveryMsInvokeTest.java | 11 +-
modules/table/tech-notes/rebalance.md | 16 +-
.../ItDisasterRecoveryReconfigurationTest.java | 4 +-
.../TransactionExpirationRegistryBenchmark.java | 7 +-
.../ignite/internal/tx/InternalTransaction.java | 20 +-
.../ignite/internal/tx/InternalTxOptions.java | 28 +-
.../org/apache/ignite/internal/tx/TxManager.java | 13 +
.../tx/impl/PublicApiThreadingTransaction.java | 9 +-
.../internal/tx/impl/ReadOnlyTransactionImpl.java | 8 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 9 +-
.../tx/impl/RemoteReadWriteTransaction.java | 167 ++++++++
.../tx/impl/TransactionExpirationRegistry.java | 61 ++-
.../ignite/internal/tx/impl/TxManagerImpl.java | 90 ++--
.../apache/ignite/internal/tx/TxManagerTest.java | 25 ++
.../tx/impl/ReadOnlyTransactionImplTest.java | 2 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 2 +-
...ransactionExpirationRegistryConcurrentTest.java | 11 +-
.../tx/impl/TransactionExpirationRegistryTest.java | 15 +
.../internal/tx/test/ItTransactionTestUtils.java | 27 ++
packaging/build.gradle | 2 +-
packaging/docker/docker-compose.yml | 2 +-
364 files changed, 7956 insertions(+), 3410 deletions(-)
copy
modules/{api/src/main/java/org/apache/ignite/table/DataStreamerOperationType.java
=>
client-common/src/main/java/org/apache/ignite/internal/client/proto/tx/ClientTxUtils.java}
(79%)
copy
modules/{client-common/src/main/java/org/apache/ignite/internal/jdbc/proto/event/JdbcQueryCloseResult.java
=>
client/src/main/java/org/apache/ignite/internal/client/PartitionMapping.java}
(54%)
copy
modules/{api/src/main/java/org/apache/ignite/table/partition/Partition.java =>
client/src/main/java/org/apache/ignite/internal/client/WriteContext.java} (78%)
rename modules/{table =>
core}/src/main/java/org/apache/ignite/table/TupleHelper.java (100%)
copy
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/impl/ReadWriteTransactionImplColocationTest.java
=>
partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItBigZoneOperationTest.java}
(50%)
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/NaiveAsyncReadWriteLock.java
create mode 100644
modules/partition-replicator/src/test/java/org/apache/ignite/internal/partition/replicator/NaiveAsyncReadWriteLockTest.java
create mode 100644 modules/platforms/cpp/ignite/client/cancel_handle.cpp
create mode 100644 modules/platforms/cpp/ignite/client/cancel_handle.h
copy modules/platforms/cpp/ignite/client/{ssl_mode.h => cancellation_token.h}
(74%)
create mode 100644
modules/platforms/cpp/ignite/client/detail/cancellation_token_impl.cpp
create mode 100644
modules/platforms/cpp/ignite/client/detail/cancellation_token_impl.h
delete mode 100644 modules/platforms/cpp/ignite/common/bit_array.h
delete mode 100644 modules/platforms/cpp/ignite/common/bit_array_test.cpp
copy modules/platforms/cpp/ignite/{client/transaction/transactions.cpp =>
common/uuid.cpp} (72%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/IgniteNameUtilsTests.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/QualifiedNameTests.cs
copy modules/platforms/dotnet/Apache.Ignite/{IAuthenticator.cs =>
Internal/Proto/ProtocolBitmaskFeature.cs} (74%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Table/IgniteNameUtils.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Table/QualifiedName.cs
delete mode 100644
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/RaftNodeDisruptorConfiguration.java
copy
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/{UpsertKvBenchmark.java
=> ClientKvBenchmark.java} (68%)
copy
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/{UpsertKvBenchmark.java
=> RemoteKvBenchmark.java} (50%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/client/ItClientDirectMappingTest.java
copy
modules/{metrics/src/integrationTest/java/org/apache/ignite/internal/metrics/exporters/ItMetricsTest.java
=>
runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItAddNodeTest.java}
(51%)
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItTemporalIndexTest.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableAssignmentsService.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/RemoteReadWriteTransaction.java
