This is an automated email from the ASF dual-hosted git repository. amashenkov pushed a change to branch catalog-feature in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 5b1b2d3b37 IGNITE-19932 Simplify handleChangePendingAssignmentEvent in TableManager (#2299) add 37a0ee3831 IGNITE-19865 Fix propagating trace identifier (#2291) add d13553ebda IGNITE-19688 use waitAndGetLeader instead of waitLeader and getLeader (#2259) add 37651e2928 IGNITE-19212 ODBC: Implement basic query execution (#2284) add 00181c783f IGNITE-19810 Remove excessive BinaryRow buffer copying (#2295) add 61864e4634 IGNITE-19946 Implement batch log updates for RAFT. (#2273) add 87afd9d8c8 IGNITE-19205 ODBC data buffers (#2303) add 8303cc4f02 IGNITE-19935 Allow combining individual colocation hashes (#2302) add 39a7c6800d IGNITE-19924 Test shouldn't guess id of newly created catalog object (#2296) add 4d4c9e8748 IGNITE-19778 Restore components state on metastorage recovery (#2266) No new revisions were added by this update. Summary of changes: .idea/inspectionProfiles/Project_Default.xml | 1 - .../apache/ignite/lang/IgniteCheckedException.java | 9 +- .../org/apache/ignite/lang/IgniteException.java | 9 +- .../apache/ignite/lang/IgniteExceptionUtils.java | 6 +- .../apache/ignite/lang/IgniteExceptionTest.java | 100 ++- .../internal/binarytuple/BinaryTupleCommon.java | 6 + .../internal/catalog/storage/UpdateLogImpl.java | 2 +- .../internal/catalog/CatalogServiceSelfTest.java | 207 +++-- .../ignite/client/PartitionAwarenessTest.java | 359 ++++---- .../configuration/ConfigurationChanger.java | 5 - .../storage/ConfigurationStorage.java | 10 - .../storage/TestConfigurationStorage.java | 5 - .../org/apache/ignite/internal/util/ByteUtils.java | 30 - .../ignite/internal/util/ExceptionUtils.java | 30 + .../ignite/internal/util/HashCalculator.java | 206 ++++- .../org/apache/ignite/internal/util/HashUtils.java | 52 +- .../java/org/apache/ignite/lang/ByteArray.java | 7 + .../lang/IgniteInternalCheckedException.java | 9 +- .../ignite/lang/IgniteInternalException.java | 9 +- .../distributionzones/DistributionZoneManager.java | 2 +- .../BaseDistributionZoneManagerTest.java | 2 +- .../internal/metastorage/MetaStorageManager.java | 23 +- .../impl/ItMetaStorageManagerImplTest.java | 71 -- ...MetaStorageSafeTimePropagationAbstractTest.java | 2 +- .../metastorage/impl/ItMetaStorageWatchTest.java | 6 +- .../metastorage/impl/MetaStorageManagerImpl.java | 40 +- .../server/persistence/RocksDbKeyValueStorage.java | 6 +- .../server/BasicOperationsKeyValueStorageTest.java | 6 +- .../server/SimpleInMemoryKeyValueStorage.java | 6 +- .../pagememory/util/PartitionlessLinks.java | 2 +- modules/platforms/cpp/ignite/client/CMakeLists.txt | 4 + .../cpp/ignite/client/detail/cluster_connection.h | 2 +- .../cpp/ignite/client/detail/node_connection.cpp | 18 +- .../cpp/ignite/client/detail/node_connection.h | 2 +- .../cpp/ignite/client/detail/sql/result_set_impl.h | 10 +- .../platforms/cpp/ignite/client/detail/utils.cpp | 105 +-- .../platforms/cpp/ignite/common/big_decimal.cpp | 8 +- modules/platforms/cpp/ignite/common/big_decimal.h | 11 +- modules/platforms/cpp/ignite/common/big_integer.h | 2 +- modules/platforms/cpp/ignite/network/data_buffer.h | 3 + modules/platforms/cpp/ignite/odbc/CMakeLists.txt | 2 + .../ignite/odbc/app/application_data_buffer.cpp | 441 ++++----- .../cpp/ignite/odbc/app/application_data_buffer.h | 17 +- .../odbc/app/application_data_buffer_test.cpp | 988 +++++++++++++++++++++ .../platforms/cpp/ignite/odbc/app/parameter.cpp | 226 ++++- modules/platforms/cpp/ignite/odbc/app/parameter.h | 33 +- .../cpp/ignite/odbc/app/parameter_set.cpp | 50 +- .../platforms/cpp/ignite/odbc/app/parameter_set.h | 8 + .../cpp/ignite/odbc/config/configuration.cpp | 12 + .../cpp/ignite/odbc/config/configuration.h | 19 +- .../cpp/ignite/odbc/diagnostic/diagnosable.h | 28 + .../ignite/odbc/diagnostic/diagnosable_adapter.cpp | 1 + .../platforms/cpp/ignite/odbc/meta/column_meta.cpp | 15 +- .../platforms/cpp/ignite/odbc/meta/column_meta.h | 11 +- .../query/cursor.h} | 69 +- .../platforms/cpp/ignite/odbc/query/data_query.cpp | 360 ++++++++ .../platforms/cpp/ignite/odbc/query/data_query.h | 212 +++++ .../platforms/cpp/ignite/odbc/sql_connection.cpp | 71 +- modules/platforms/cpp/ignite/odbc/sql_connection.h | 97 ++ .../platforms/cpp/ignite/odbc/sql_statement.cpp | 12 +- modules/platforms/cpp/ignite/odbc/utility.cpp | 3 + .../{client/detail => protocol}/client_operation.h | 0 modules/platforms/cpp/ignite/protocol/utils.h | 26 + modules/platforms/cpp/ignite/tuple/tuple_test.cpp | 1 + .../cpp/tests/client-test/compute_test.cpp | 4 +- .../platforms/cpp/tests/odbc-test/CMakeLists.txt | 2 + .../cpp/tests/odbc-test/api_robustness_test.cpp | 75 +- .../platforms/cpp/tests/odbc-test/error_test.cpp | 161 ++++ .../cpp/tests/odbc-test/meta_queries_test.cpp | 863 ++++++++++++++++++ .../cpp/tests/odbc-test/odbc_connection.h | 149 ++++ modules/platforms/cpp/tests/odbc-test/odbc_suite.h | 84 +- .../cpp/tests/odbc-test/odbc_test_utils.h | 90 ++ .../Apache.Ignite.Tests/Compute/ComputeTests.cs | 18 +- .../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 18 +- .../Proto/BinaryTuple/BinaryTupleBuilder.cs | 37 +- .../Apache.Ignite/Internal/Proto/HashUtils.cs | 58 +- .../ignite/raft/jraft/core/ItCliServiceTest.java | 20 +- .../apache/ignite/raft/jraft/core/ItNodeTest.java | 347 +++----- .../internal/raft/server/impl/JraftServerImpl.java | 20 +- .../storage/impl/DefaultLogStorageFactory.java | 43 +- .../raft/storage/impl/RocksDbSharedLogStorage.java | 140 +-- .../raft/storage/impl/StripeAwareLogManager.java | 260 ++++++ .../apache/ignite/raft/jraft/core/NodeImpl.java | 31 +- .../raft/jraft/disruptor/StripedDisruptor.java | 17 +- .../ignite/raft/jraft/option/NodeOptions.java | 17 +- .../raft/jraft/storage/impl/LogManagerImpl.java | 43 +- .../ignite/disruptor/StripedDisruptorTest.java | 6 +- .../ignite/raft/jraft/core/FSMCallerTest.java | 3 +- .../raft/jraft/core/ReadOnlyServiceTest.java | 3 +- .../raft/jraft/storage/impl/LogManagerTest.java | 3 +- .../apache/ignite/raft/jraft/core/TestCluster.java | 44 +- .../ignite/internal/BaseIgniteRestartTest.java | 66 +- .../ItDistributedConfigurationPropertiesTest.java | 4 +- .../ItDistributedConfigurationStorageTest.java | 4 +- .../storage/ItRebalanceDistributedTest.java | 68 +- .../zones/ItDistributionZonesFilterTest.java | 7 + ...niteDistributionZoneManagerNodeRestartTest.java | 5 +- .../runner/app/ItIgniteNodeRestartTest.java | 9 +- .../ItRaftCommandLeftInLogUntilRestartTest.java | 3 +- .../runner/app/client/ItThinClientComputeTest.java | 2 +- .../ignite/internal/table/ItRoReadsTest.java | 70 +- .../org/apache/ignite/internal/app/IgniteImpl.java | 37 +- .../storage/DistributedConfigurationStorage.java | 134 ++- .../storage/LocalConfigurationStorage.java | 5 - .../storage/LocalFileConfigurationStorage.java | 5 - .../recovery/ConfigurationCatchUpListener.java | 117 --- .../recovery/RecoveryCompletionFutureFactory.java | 51 -- .../DistributedConfigurationCatchUpTest.java | 244 ----- .../DistributedConfigurationStorageTest.java | 8 +- .../apache/ignite/internal/schema/BinaryRow.java | 18 +- .../ignite/internal/schema/BinaryRowImpl.java | 96 ++ .../ignite/internal/schema/ByteBufferRow.java | 25 +- .../org/apache/ignite/internal/schema/row/Row.java | 28 +- .../ignite/internal/schema/row/RowAssembler.java | 18 +- .../schema/marshaller/KvMarshallerTest.java | 6 +- .../storage/AbstractMvPartitionStorageTest.java | 2 +- .../storage/AbstractMvTableStorageTest.java | 12 +- .../internal/storage/BaseMvStoragesTest.java | 5 +- .../pagememory/mv/AbortWriteInvokeClosure.java | 2 +- .../mv/AbstractPageMemoryMvPartitionStorage.java | 28 +- .../mv/AddWriteCommittedInvokeClosure.java | 6 +- .../pagememory/mv/AddWriteInvokeClosure.java | 8 +- .../storage/pagememory/mv/FindRowVersion.java | 13 +- .../storage/pagememory/mv/ReadRowVersion.java | 13 +- .../internal/storage/pagememory/mv/RowVersion.java | 38 +- .../storage/pagememory/mv/ScanVersionsCursor.java | 10 +- .../storage/pagememory/mv/io/RowVersionDataIo.java | 61 +- .../internal/storage/rocksdb/GarbageCollector.java | 5 +- .../storage/rocksdb/PartitionDataHelper.java | 14 + .../storage/rocksdb/RocksDbMvPartitionStorage.java | 292 +++--- .../ItAbstractInternalTableScanTest.java | 13 +- .../ignite/distributed/ItTablePersistenceTest.java | 10 +- .../ignite/internal/table/ItColocationTest.java | 6 +- .../internal/table/distributed/TableManager.java | 12 +- .../replicator/PartitionReplicaListener.java | 20 +- .../table/ColocationHashCalculationTest.java | 72 +- .../internal/table/MutableRowTupleAdapterTest.java | 35 +- .../replication/PartitionReplicaListenerTest.java | 12 +- .../table/type/NumericTypesSerializerTest.java | 6 +- 139 files changed, 5837 insertions(+), 2539 deletions(-) create mode 100644 modules/platforms/cpp/ignite/odbc/app/application_data_buffer_test.cpp copy modules/platforms/cpp/ignite/{network/detail/win/win_async_worker_thread.h => odbc/query/cursor.h} (52%) create mode 100644 modules/platforms/cpp/ignite/odbc/query/data_query.cpp create mode 100644 modules/platforms/cpp/ignite/odbc/query/data_query.h rename modules/platforms/cpp/ignite/{client/detail => protocol}/client_operation.h (100%) create mode 100644 modules/platforms/cpp/tests/odbc-test/error_test.cpp create mode 100644 modules/platforms/cpp/tests/odbc-test/meta_queries_test.cpp create mode 100644 modules/platforms/cpp/tests/odbc-test/odbc_connection.h create mode 100644 modules/raft/src/main/java/org/apache/ignite/internal/raft/storage/impl/StripeAwareLogManager.java delete mode 100644 modules/runner/src/main/java/org/apache/ignite/internal/recovery/ConfigurationCatchUpListener.java delete mode 100644 modules/runner/src/main/java/org/apache/ignite/internal/recovery/RecoveryCompletionFutureFactory.java delete mode 100644 modules/runner/src/test/java/org/apache/ignite/internal/configuration/storage/DistributedConfigurationCatchUpTest.java create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/BinaryRowImpl.java