This is an automated email from the ASF dual-hosted git repository.
sdanilov pushed a change to branch ignite-19778
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit 6c7fc104a0 IGNITE-19778 Review fixes
omit 2e852fe634 IGNITE-19778 Review fixes
omit eb2d457a9c IGNITE-19778 Review fixes
omit bdf5ff9177 .
omit 21d346c96b .
omit 2b3c39fbd6 .
omit d38f2e0cdd IGNITE-19778 ....
omit 75c6f48b6a IGNITE-19778 ....
omit 808d0f0cdb IGNITE-19778 ....
omit 67e5121fbf IGNITE-19778 ....
omit 5ecae80ac8 IGNITE-19778 ....
omit 5b0beaa208 IGNITE-19778 ....
omit 37860bf289 IGNITE-19778 ....
omit 9cb47fa014 IGNITE-19778 ....
omit 4463ad71f4 IGNITE-19778 ....
omit 0d2c60213f IGNITE-19778 ....
omit f926bb14d1 IGNITE-19778 ....
omit a5af5f3a46 IGNITE-19778 Initial
add 00bbecb8a5 IGNITE-19667 Make ClientTableCommon.readTable async (#2293)
add 8586df07f8 IGNITE-19578 Decrease count of lease messages to meta
storage (#2141)
add 96aaa46976 IGNITE-19609 Java client: Add data streamer metrics (#2298)
add 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 eaf37c0f08 IGNITE-19778 Initial
add 266ee432f2 IGNITE-19778 ....
add 1febfb3ef3 IGNITE-19778 ....
add ab5af9980a IGNITE-19778 ....
add 427e480ff1 IGNITE-19778 ....
add a387a7f000 IGNITE-19778 ....
add c87e6323fa IGNITE-19778 ....
add a4406068f4 IGNITE-19778 ....
add 0f39557714 IGNITE-19778 ....
add a2f5b3ccf1 IGNITE-19778 ....
add a9dce2bfa7 IGNITE-19778 ....
add 7fd41f217b IGNITE-19778 ....
add 24d8b52df1 .
add bb7079299d .
add eb8f35ad01 .
add b3f1fa1194 IGNITE-19778 Review fixes
add f177a56bf1 IGNITE-19778 Review fixes
add cb36185b06 IGNITE-19778 Review fixes
add 41dec8f3e6 Add todo
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (6c7fc104a0)
\
N -- N -- N refs/heads/ignite-19778 (41dec8f3e6)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
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 +
.../handler/ClientInboundMessageHandler.java | 24 +-
.../ClientComputeExecuteColocatedRequest.java | 19 +-
.../requests/table/ClientSchemasGetRequest.java | 43 +-
.../handler/requests/table/ClientTableCommon.java | 18 +-
.../ClientTablePartitionAssignmentGetRequest.java | 23 +-
.../table/ClientTupleContainsKeyRequest.java | 19 +-
.../table/ClientTupleDeleteAllExactRequest.java | 13 +-
.../table/ClientTupleDeleteAllRequest.java | 13 +-
.../table/ClientTupleDeleteExactRequest.java | 15 +-
.../requests/table/ClientTupleDeleteRequest.java | 15 +-
.../requests/table/ClientTupleGetAllRequest.java | 13 +-
.../table/ClientTupleGetAndDeleteRequest.java | 13 +-
.../table/ClientTupleGetAndReplaceRequest.java | 13 +-
.../table/ClientTupleGetAndUpsertRequest.java | 13 +-
.../requests/table/ClientTupleGetRequest.java | 13 +-
.../table/ClientTupleInsertAllRequest.java | 13 +-
.../requests/table/ClientTupleInsertRequest.java | 15 +-
.../table/ClientTupleReplaceExactRequest.java | 19 +-
.../requests/table/ClientTupleReplaceRequest.java | 15 +-
.../table/ClientTupleUpsertAllRequest.java | 13 +-
.../requests/table/ClientTupleUpsertRequest.java | 11 +-
.../ignite/internal/client/ClientMetricSource.java | 107 ++-
.../ignite/internal/client/ReliableChannel.java | 9 +
.../internal/client/table/ClientDataStreamer.java | 5 +-
.../client/table/ClientKeyValueBinaryView.java | 1 +
.../apache/ignite/client/ClientMetricsTest.java | 45 +
.../ignite/client/PartitionAwarenessTest.java | 359 ++++----
.../java/org/apache/ignite/client/TestServer.java | 12 +
.../ignite/client/fakes/FakeIgniteTables.java | 4 +-
.../internal/streamer/StreamerMetricSink.java} | 32 +-
.../internal/streamer/StreamerSubscriber.java | 39 +-
.../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 +-
.../apache/ignite/internal/util/IgniteUtils.java | 53 ++
.../lang/IgniteInternalCheckedException.java | 9 +-
.../ignite/lang/IgniteInternalException.java | 9 +-
.../pagememory/util/PartitionlessLinks.java | 2 +-
.../MultiActorPlacementDriverTest.java | 55 +-
.../PlacementDriverManagerTest.java | 38 +-
.../internal/placementdriver/LeaseUpdater.java | 110 ++-
.../placementdriver/PlacementDriverManager.java | 6 +-
.../internal/placementdriver/leases/Lease.java | 63 +-
.../placementdriver/leases/LeaseBatch.java} | 32 +-
.../placementdriver/leases/LeaseTracker.java | 103 ++-
.../negotiation/LeaseNegotiator.java | 16 +-
.../placementdriver/PlacementDriverTest.java | 33 +-
.../leases/LeaseSerializationTest.java | 46 +-
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 +-
.../zones/ItDistributionZonesFilterTest.java | 1 +
.../ItRaftCommandLeftInLogUntilRestartTest.java | 3 +-
.../runner/app/client/ItThinClientComputeTest.java | 2 +-
.../ignite/internal/table/ItRoReadsTest.java | 70 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 24 +-
.../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 +-
.../apache/ignite/internal/table/DataStreamer.java | 3 +-
.../internal/table/IgniteTablesInternal.java | 7 +-
.../internal/table/distributed/TableManager.java | 256 +++---
.../replicator/PartitionReplicaListener.java | 20 +-
.../table/ColocationHashCalculationTest.java | 72 +-
.../internal/table/MutableRowTupleAdapterTest.java | 35 +-
.../replication/PartitionReplicaListenerTest.java | 12 +-
.../table/type/NumericTypesSerializerTest.java | 6 +-
153 files changed, 6529 insertions(+), 2124 deletions(-)
copy
modules/{cli/src/main/java/org/apache/ignite/internal/cli/core/call/CallOutput.java
=>
core/src/main/java/org/apache/ignite/internal/streamer/StreamerMetricSink.java}
(61%)
copy
modules/{cli/src/main/java/org/apache/ignite/internal/cli/core/decorator/DecoratorRegistry.java
=>
placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/leases/LeaseBatch.java}
(54%)
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
create mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/BinaryRowImpl.java
