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
