You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2022/10/07 12:48:48 UTC
[ignite-3] branch ignite-17820 updated (32a7d044f0 -> 9efde571c9)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-17820
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 32a7d044f0 WIP.
add ab417701e9 IGNITE-17799 Intergrate onLeaderElected callback into CMG Manager (#1155)
add fa4c1e13b1 IGNITE-17401 Add classes for complex binary tuple types (#1104)
add 0ebb99ecd1 IGNITE-17825 ThreadPoolMetricTest.test is flaky (#1162)
add 098f16b68c IGNITE-17827 Some API classes moved from "network" to "network-api" (#1164)
add 9885b6075e IGNITE-15081 (#1103) RW transactions implemented
add b2e135c270 IGNITE-17782 `sql` with white space in repl fails (#1157)
add 22aa8bdb9e IGNITE-17083 Skeleton classes for RAFT snapshots in partitions & new method in MvPartitionStorage. (#1160)
add fac922ae83 IGNITE-17831 Portability and style for ignite-3 C++ code (#1166)
add d8ead0ab84 IGNITE-17355 CLI management of metrics (#1081)
add 0cb65d0978 IGNITE-17768 Add descriptions for AI3 exceptions. Fixes #1123
add f6bad72d20 IGNITE-17844 Fixed corner case in BitmaskNativeType constructor. (#1174)
add 6f236913b5 IGNITE-17777 Thin client: use BinaryTuple for Compute and SQL results and arguments (#1171)
add 4c903a90ce IGNITE-17834 Fixed. (#1168)
add b8a9cd55e0 IGNITE-17818 Optimize sorted index scan (#1172)
add 9efde571c9 Merge branch 'main' into ignite-17820
No new revisions were added by this update.
Summary of changes:
docs/_docs/handling-exceptions.adoc | 119 ++-
.../org/apache/ignite/tx/TransactionException.java | 34 +
.../internal/binarytuple/BinaryTupleCommon.java | 26 +-
.../cli/call/metric/ItMetricCallsTest.java | 91 ++
.../ItClusterConfigCommandNotInitializedTest.java | 2 +-
.../commands/metric/ItNodeMetricCommandTest.java | 70 ++
.../internal/rest/ItGeneratedRestClientTest.java | 26 +-
.../call/cluster/topology/LogicalTopologyCall.java | 5 +-
.../cluster/topology/PhysicalTopologyCall.java | 5 +-
.../call/cluster/topology/TopologyCallOutput.java | 70 --
.../metric/NodeMetricEnableCall.java} | 34 +-
.../node/metric/NodeMetricEnableCallInput.java | 105 ++
.../metric/NodeMetricListCall.java} | 28 +-
.../cli/commands/metric/MetricSourceMixin.java | 44 +
.../internal/cli/commands/node/NodeCommand.java | 7 +-
.../cli/commands/node/NodeReplCommand.java | 7 +-
.../commands/node/metric/NodeMetricCommand.java} | 21 +-
.../node/metric/NodeMetricDisableCommand.java | 53 +
.../node/metric/NodeMetricDisableReplCommand.java | 54 +
.../node/metric/NodeMetricEnableCommand.java | 53 +
.../node/metric/NodeMetricEnableReplCommand.java | 54 +
.../node/metric/NodeMetricListCommand.java | 52 +
.../node/metric/NodeMetricListReplCommand.java | 53 +
.../node/metric/NodeMetricReplCommand.java} | 21 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 3 +-
.../cli/decorators/MetricListDecorator.java | 45 +
.../cli/commands/UrlOptionsNegativeTest.java | 12 +
.../cli/deprecated/IgniteCliInterfaceTest.java | 61 ++
.../client/proto/ClientBinaryTupleUtils.java | 234 +++-
.../internal/client/proto/ClientDataType.java | 10 +-
.../internal/client/proto/ClientMessagePacker.java | 410 +------
.../client/proto/ClientMessageUnpacker.java | 354 +-----
.../internal/client/proto/ClientMsgPackType.java | 21 -
.../proto/event/JdbcBatchPreparedStmntRequest.java | 4 +-
.../jdbc/proto/event/JdbcQueryExecuteRequest.java | 4 +-
.../jdbc/proto/event/JdbcQueryFetchResult.java | 4 +-
.../jdbc/proto/event/JdbcQuerySingleResult.java | 4 +-
.../client/proto/ClientMessagePackerTest.java | 17 -
.../proto/ClientMessagePackerUnpackerTest.java | 213 +---
.../client/proto/ClientMessageUnpackerTest.java | 9 -
.../ClientComputeExecuteColocatedRequest.java | 2 +-
.../compute/ClientComputeExecuteRequest.java | 21 +-
.../handler/requests/sql/ClientSqlCommon.java | 66 +-
.../requests/sql/ClientSqlExecuteRequest.java | 30 +-
.../handler/requests/table/ClientTableCommon.java | 9 +-
.../internal/client/compute/ClientCompute.java | 12 +-
.../internal/client/sql/ClientAsyncResultSet.java | 54 +-
.../ignite/internal/client/sql/ClientSession.java | 25 +-
.../org/apache/ignite/client/ClientSqlTest.java | 3 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 14 +-
.../ignite/client/fakes/FakeInternalTable.java | 6 +
.../cluster/management/ItClusterManagerTest.java | 78 +-
.../internal/cluster/management/MockNode.java | 3 +-
.../management/raft/ItCmgRaftServiceTest.java | 3 +-
.../management/ClusterManagementGroupManager.java | 155 ++-
.../management/raft/CmgRaftGroupListener.java | 7 -
.../internal/compute/ComputeComponentImpl.java | 2 +-
.../org/apache/ignite/hlc/HybridTimestamp.java | 2 +-
.../apache/ignite/internal/util/CursorUtils.java | 187 ----
.../java/org/apache/ignite/lang/ErrorGroups.java | 52 +-
.../ignite/internal/util/CursorUtilsTest.java | 43 -
.../server/raft/MetaStorageListener.java | 7 -
.../internal/metastorage/MetaStorageManager.java | 2 +-
modules/metrics/build.gradle | 6 +
modules/metrics/pom.xml | 17 +
.../ignite/internal/metrics/MetricManager.java | 10 +
.../ignite/internal/metrics/MetricRegistry.java | 18 +-
.../internal/metrics/rest/MetricRestFactory.java} | 25 +-
.../metrics/rest/NodeMetricController.java | 61 ++
.../rest/exception/MetricNotFoundException.java} | 13 +-
.../handler/MetricNotFoundExceptionHandler.java | 45 +
.../internal/metrics/ThreadPoolMetricTest.java | 45 +-
.../processor/messages/MessageImplGenerator.java | 13 +-
.../serialization/BaseMethodNameResolver.java | 2 +-
.../serialization/marshal/MarshalException.java | 0
.../serialization/marshal/MarshalledObject.java | 0
.../serialization/marshal/UnmarshalException.java | 0
.../marshal/UserObjectMarshaller.java | 3 +-
.../marshal/DefaultUserObjectMarshaller.java | 7 +-
.../network/MessageSerializationRegistryImpl.java | 4 +-
.../network/serialization/MarshallableTest.java | 3 +-
.../ignite/internal/pagememory/tree/BplusTree.java | 6 +-
modules/platforms/cpp/.clang-tidy | 163 +++
.../cpp/client-test/src/ignite_client_test.cpp | 2 +-
.../cpp/client-test/src/ignite_runner_suite.h | 8 +-
modules/platforms/cpp/client-test/src/main.cpp | 1 +
.../platforms/cpp/client-test/src/tables_test.cpp | 6 +-
.../platforms/cpp/client/src/cluster_connection.h | 7 +-
modules/platforms/cpp/client/src/ignite_client.cpp | 3 +-
.../platforms/cpp/client/src/node_connection.cpp | 34 +-
modules/platforms/cpp/client/src/node_connection.h | 10 +-
.../platforms/cpp/client/src/response_handler.h | 8 +-
.../platforms/cpp/client/src/table/tables_impl.cpp | 21 +-
.../platforms/cpp/client/src/table/tables_impl.h | 9 +-
modules/platforms/cpp/common/CMakeLists.txt | 1 -
modules/platforms/cpp/common/ignite_result.h | 8 +-
modules/platforms/cpp/common/uuid.h | 8 +-
.../network/src/network/length_prefix_codec.cpp | 7 +-
.../include/ignite/protocol/buffer_adapter.h | 30 +-
.../include/ignite/protocol/extension_types.h | 2 +-
.../cpp/protocol/include/ignite/protocol/reader.h | 116 +-
.../cpp/protocol/include/ignite/protocol/utils.h | 199 +---
.../cpp/protocol/include/ignite/protocol/writer.h | 67 +-
.../platforms/cpp/protocol/src/buffer_adapter.cpp | 13 +-
modules/platforms/cpp/protocol/src/reader.cpp | 57 +-
modules/platforms/cpp/protocol/src/utils.cpp | 63 +-
modules/platforms/cpp/protocol/src/writer.cpp | 17 +-
.../platforms/cpp/schema/BinaryTupleBuilder.cpp | 181 ----
modules/platforms/cpp/schema/BinaryTupleParser.cpp | 205 ----
modules/platforms/cpp/schema/CMakeLists.txt | 17 +-
modules/platforms/cpp/schema/big_decimal.cpp | 178 ++++
modules/platforms/cpp/schema/big_decimal.h | 508 +++++++++
modules/platforms/cpp/schema/big_integer.cpp | 772 ++++++++++++++
modules/platforms/cpp/schema/big_integer.h | 555 ++++++++++
.../platforms/cpp/schema/binary_tuple_builder.cpp | 376 +++++++
...BinaryTupleBuilder.h => binary_tuple_builder.h} | 269 +++--
.../{BinaryTupleHeader.h => binary_tuple_header.h} | 24 +-
.../platforms/cpp/schema/binary_tuple_parser.cpp | 320 ++++++
.../{BinaryTupleParser.h => binary_tuple_parser.h} | 108 +-
.../{BinaryTupleSchema.h => binary_tuple_schema.h} | 42 +-
.../cpp/schema/{ColumnInfo.h => column_info.h} | 14 +-
modules/platforms/cpp/schema/ignite_date.h | 153 +++
modules/platforms/cpp/schema/ignite_date_time.h | 139 +++
modules/platforms/cpp/schema/ignite_time.h | 165 +++
modules/platforms/cpp/schema/ignite_timestamp.h | 145 +++
.../cpp/schema/{DataType.cpp => ignite_type.cpp} | 60 +-
.../cpp/schema/{DataType.h => ignite_type.h} | 12 +-
modules/platforms/cpp/tests/CMakeLists.txt | 2 +
modules/platforms/cpp/tests/testDecimal.cpp | 1125 ++++++++++++++++++++
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 45 +-
.../dotnet/Apache.Ignite.Tests/ErrorGroupTests.cs | 4 +
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 30 +-
.../dotnet/Apache.Ignite.Tests/HeartbeatTests.cs | 10 +-
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 2 +-
.../Proto/BinaryTuple/BinaryTupleTests.cs | 161 +++
.../Proto/MessagePackExtensionsTest.cs | 31 -
.../dotnet/Apache.Ignite.Tests/RetryPolicyTests.cs | 27 +
.../Apache.Ignite/Internal/Compute/Compute.cs | 8 +-
.../Proto/BinaryTuple/BinaryTupleBuilder.cs | 181 +++-
.../Proto/BinaryTuple/BinaryTupleReader.cs | 24 +-
.../Internal/Proto/ClientMessagePackType.cs | 35 -
.../Internal/Proto/MessagePackReaderExtensions.cs | 70 +-
.../Internal/Proto/MessagePackWriterExtensions.cs | 115 +-
.../dotnet/Apache.Ignite/Internal/Sql/ResultSet.cs | 126 +--
.../dotnet/Apache.Ignite/Internal/Sql/Sql.cs | 12 +-
.../raft/client/service/RaftGroupListener.java | 11 -
.../apache/ignite/internal/raft/ItLozaTest.java | 3 +-
.../internal/raft/ItRaftGroupServiceTest.java | 3 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 80 ++
.../ignite/raft/server/ItJraftHlcServerTest.java | 209 ++++
.../raft/server/counter/CounterListener.java | 8 -
.../server/snasphot/UpdateCountRaftListener.java | 8 -
.../java/org/apache/ignite/internal/raft/Loza.java | 47 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 69 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 6 +
.../ignite/raft/jraft/option/NodeOptions.java | 13 +
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 7 +
.../jraft/rpc/impl/ActionRequestProcessor.java | 32 +-
.../org/apache/ignite/internal/raft/LozaTest.java | 3 +-
.../apache/ignite/raft/jraft/core/TestCluster.java | 18 +-
modules/replicator/README.md | 6 +
modules/{metrics => replicator}/pom.xml | 45 +-
.../apache/ignite/internal/replicator/Replica.java | 64 ++
.../ignite/internal/replicator/ReplicaManager.java | 342 ++++++
.../ignite/internal/replicator/ReplicaService.java | 139 +++
.../exception/PrimaryReplicaMissException.java | 67 ++
.../ReplicaIsAlreadyStartedException.java | 51 +
.../exception/ReplicaUnavailableException.java | 51 +
.../replicator/exception/ReplicationException.java | 70 ++
.../exception/ReplicationTimeoutException.java | 49 +
.../UnsupportedReplicaRequestException.java | 52 +
.../replicator/listener/ReplicaListener.java} | 23 +-
.../replicator/message/ErrorReplicaResponse.java} | 20 +-
.../ErrorTimestampAwareReplicaResponse.java} | 11 +-
.../replicator/message/ReplicaMessageGroup.java} | 25 +-
.../replicator/message/ReplicaRequest.java} | 18 +-
.../replicator/message/ReplicaResponse.java} | 13 +-
.../replicator/message/TimestampAware.java} | 19 +-
.../message/TimestampAwareReplicaResponse.java} | 11 +-
.../internal/rest/api/metric/MetricSourceDto.java | 69 ++
.../internal/rest/api/metric/NodeMetricApi.java | 72 ++
modules/rest/openapi/openapi.yaml | 85 ++
.../apache/ignite/internal/rest/RestComponent.java | 2 +
.../cluster/management/ItClusterInitTest.java | 2 +-
.../ItDistributedConfigurationPropertiesTest.java | 3 +-
.../ItDistributedConfigurationStorageTest.java | 3 +-
.../storage/ItRebalanceDistributedTest.java | 90 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 1 +
.../runner/app/ItIgniteNodeRestartTest.java | 30 +-
.../internal/runner/app/ItTablesApiTest.java | 4 +-
.../runner/app/PlatformTestNodeRunner.java | 6 +-
.../runner/app/client/ItThinClientComputeTest.java | 10 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 2 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 8 +
.../org/apache/ignite/internal/app/IgniteImpl.java | 77 +-
.../ignite/internal/schema/BitmaskNativeType.java | 2 +-
.../ignite/internal/schema/ByteBufferRow.java | 2 +-
.../ignite/internal/schema/SchemaManager.java | 2 +-
.../internal/schema/BinaryTuplePrefixTest.java | 2 +-
.../ignite/internal/schema/NativeTypeTest.java | 12 +
.../internal/sql/engine/SqlQueryProcessor.java | 2 +-
.../sql/engine/exec/MockedStructuresTest.java | 7 +-
.../internal/storage/MvPartitionStorage.java | 69 +-
.../org/apache/ignite/internal/storage/RowId.java | 29 +-
.../storage/index/BinaryTupleComparator.java | 28 +-
.../storage/index/BinaryTupleComparatorTest.java | 23 +-
.../storage/AbstractMvPartitionStorageTest.java | 64 +-
.../storage/AbstractMvTableStorageTest.java | 20 +-
.../storage/impl/TestMvPartitionStorage.java | 20 +-
.../storage/index/impl/TestSortedIndexStorage.java | 52 +-
.../index/sorted/PageMemorySortedIndexStorage.java | 74 +-
.../index/sorted/io/SortedIndexTreeIo.java | 4 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 21 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 66 +-
.../storage/rocksdb/RocksDbTableStorage.java | 2 +-
.../index/RocksDbBinaryTupleComparator.java | 17 +-
.../rocksdb/index/RocksDbSortedIndexStorage.java | 68 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 33 +-
modules/table/pom.xml | 24 +-
.../distributed/ItInternalTableScanTest.java | 181 +---
.../ignite/distributed/ItTablePersistenceTest.java | 51 +-
.../distributed/ItTxDistributedTestSingleNode.java | 154 ++-
.../ignite/internal/table/ItColocationTest.java | 78 +-
.../ignite/internal/table/InternalTable.java | 8 +
.../internal/table/distributed/TableManager.java | 181 +++-
.../table/distributed/TableMessageGroup.java | 110 ++
.../table/distributed/TableTxManagerImpl.java | 57 -
.../table/distributed/command/CommandUtils.java | 102 +-
.../distributed/command/DeleteAllCommand.java | 42 -
.../table/distributed/command/DeleteCommand.java | 40 -
.../distributed/command/DeleteExactAllCommand.java | 42 -
.../distributed/command/DeleteExactCommand.java | 40 -
.../table/distributed/command/FinishTxCommand.java | 68 +-
.../table/distributed/command/GetAllCommand.java | 41 -
.../distributed/command/GetAndDeleteCommand.java | 41 -
.../distributed/command/GetAndReplaceCommand.java | 41 -
.../distributed/command/GetAndUpsertCommand.java | 41 -
.../table/distributed/command/GetCommand.java | 40 -
.../distributed/command/InsertAllCommand.java | 41 -
.../table/distributed/command/MultiKeyCommand.java | 83 --
.../{InsertCommand.java => PartitionCommand.java} | 24 +-
.../table/distributed/command/ReplaceCommand.java | 69 --
.../distributed/command/ReplaceIfExistCommand.java | 40 -
.../distributed/command/SingleKeyCommand.java | 81 --
.../distributed/command/TxCleanupCommand.java} | 59 +-
.../distributed/command/UpdateAllCommand.java | 101 ++
.../table/distributed/command/UpdateCommand.java | 88 ++
.../distributed/command/UpsertAllCommand.java | 41 -
.../command/response/MultiRowsResponse.java | 10 +-
.../command/response/SingleRowResponse.java | 9 -
.../distributed/command/scan/ScanCloseCommand.java | 47 -
.../distributed/command/scan/ScanInitCommand.java | 64 --
.../command/scan/ScanRetrieveBatchCommand.java | 74 --
.../{ => distributed}/message/HasDataRequest.java | 3 +-
.../{ => distributed}/message/HasDataResponse.java | 3 +-
.../table/distributed/raft/PartitionListener.java | 743 ++++---------
.../raft/snapshot/PartitionSnapshotStorage.java | 103 +-
.../snapshot/PartitionSnapshotStorageFactory.java | 30 +-
.../raft/snapshot/PartitionSnapshotWriter.java | 2 +-
.../distributed/raft/snapshot/SnapshotUri.java | 97 ++
.../snapshot/incoming/IncomingSnapshotCopier.java | 120 +++
.../IncomingSnapshotReader.java} | 62 +-
.../snapshot/message/SnapshotMetaRequest.java} | 12 +-
.../snapshot/message/SnapshotMetaResponse.java} | 18 +-
.../snapshot/message/SnapshotMvDataRequest.java} | 12 +-
.../snapshot/message/SnapshotMvDataResponse.java | 72 ++
.../snapshot/message/SnapshotRequestMessage.java} | 15 +-
.../snapshot/message/SnapshotTxDataRequest.java} | 12 +-
.../snapshot/message/SnapshotTxDataResponse.java} | 39 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 61 ++
.../OutgoingSnapshotReader.java} | 79 +-
.../outgoing/OutgoingSnapshotsManager.java | 148 +++
.../StartupPartitionSnapshotReader.java} | 20 +-
.../request/MultipleRowReplicaRequest.java} | 23 +-
.../request/ReadOnlyReplicaRequest.java} | 32 +-
.../request/ReadWriteMultiRowReplicaRequest.java} | 12 +-
.../request/ReadWriteReplicaRequest.java} | 33 +-
.../request/ReadWriteScanCloseReplicaRequest.java} | 12 +-
.../ReadWriteScanRetrieveBatchReplicaRequest.java} | 12 +-
.../request/ReadWriteSingleRowReplicaRequest.java} | 12 +-
.../request/ReadWriteSwapRowReplicaRequest.java} | 12 +-
.../request/ScanCloseReplicaRequest.java} | 16 +-
.../request/ScanRetrieveBatchReplicaRequest.java} | 31 +-
.../request/SingleRowReplicaRequest.java} | 22 +-
.../request/SwapRowReplicaRequest.java} | 30 +-
.../replicator/PartitionReplicaListener.java | 1054 ++++++++++++++++++
.../replicator/action/RequestType.java} | 52 +-
.../distributed/storage/InternalTableImpl.java | 617 ++++++++---
.../distributed/storage/VersionedRowStore.java | 630 -----------
.../org/apache/ignite/internal/table/Example.java | 12 +-
.../internal/table/InteropOperationsTest.java | 24 +-
.../table/KeyValueBinaryViewOperationsTest.java | 26 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 26 +-
.../internal/table/KeyValueViewOperationsTest.java | 23 +-
.../internal/table/MessagingServiceTestUtils.java | 121 ---
.../table/RecordBinaryViewOperationsTest.java | 26 +-
.../internal/table/RecordViewOperationsTest.java | 23 +-
.../internal/table/SchemaValidationTest.java | 20 +-
.../ignite/internal/table/TxAbstractTest.java | 204 +++-
.../apache/ignite/internal/table/TxLocalTest.java | 64 +-
.../table/distributed/TableManagerTest.java | 14 +-
.../PartitionRaftCommandsSerializationTest.java | 279 +++++
.../raft/PartitionCommandListenerTest.java | 599 ++---------
.../table/impl/DummyInternalTableImpl.java | 229 ++--
modules/transactions/pom.xml | 17 +
.../ignite/internal/tx/InternalTransaction.java | 28 +-
.../tx/{InternalTransaction.java => Lock.java} | 59 +-
.../apache/ignite/internal/tx/LockException.java | 30 +-
.../org/apache/ignite/internal/tx/LockKey.java | 80 ++
.../org/apache/ignite/internal/tx/LockManager.java | 45 +-
.../org/apache/ignite/internal/tx/LockMode.java | 102 ++
.../tx/TransactionInternalCheckedException.java | 127 +++
.../org/apache/ignite/internal/tx/TxManager.java | 95 +-
.../java/org/apache/ignite/internal/tx/TxMeta.java | 34 +
.../java/org/apache/ignite/internal/tx/Waiter.java | 6 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 342 +++---
.../ignite/internal/tx/impl/TransactionImpl.java | 140 +--
.../ignite/internal/tx/impl/TxManagerImpl.java | 354 ++----
...shRequest.java => TxCleanupReplicaRequest.java} | 37 +-
.../tx/message/TxFinishReplicaRequest.java | 80 ++
.../internal/tx/message/TxFinishResponse.java | 3 +-
.../ignite/internal/tx/message/TxMessageGroup.java | 7 +-
.../internal/tx/storage/state/TxStateStorage.java | 66 +-
.../tx/storage/state/TxStateTableStorage.java | 83 ++
.../state/rocksdb/TxStateRocksDbStorage.java | 427 ++++----
.../state/rocksdb/TxStateRocksDbTableStorage.java | 321 ++++++
.../internal/tx/AbstractLockManagerTest.java | 545 ++++++++--
.../ignite/internal/tx/HeapLockManagerTest.java | 2 +
.../apache/ignite/internal/tx/TxManagerTest.java | 62 +-
...geTest.java => TxStateStorageAbstractTest.java} | 90 +-
.../state/rocksdb/TxStateRocksDbStorageTest.java | 67 ++
.../test/TestConcurrentHashMapTxStateStorage.java | 126 +++
.../TestConcurrentHashMapTxStateStorageTest.java} | 16 +-
.../TestConcurrentHashMapTxStateTableStorage.java | 82 ++
parent/pom.xml | 13 +
pom.xml | 1 +
336 files changed, 16514 insertions(+), 8414 deletions(-)
create mode 100644 modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/call/metric/ItMetricCallsTest.java
create mode 100644 modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/metric/ItNodeMetricCommandTest.java
delete mode 100644 modules/cli/src/main/java/org/apache/ignite/internal/cli/call/cluster/topology/TopologyCallOutput.java
copy modules/cli/src/main/java/org/apache/ignite/internal/cli/call/{cluster/topology/LogicalTopologyCall.java => node/metric/NodeMetricEnableCall.java} (54%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/internal/cli/call/node/metric/NodeMetricEnableCallInput.java
copy modules/cli/src/main/java/org/apache/ignite/internal/cli/call/{cluster/topology/PhysicalTopologyCall.java => node/metric/NodeMetricListCall.java} (59%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/metric/MetricSourceMixin.java
copy modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UnmarshalException.java => cli/src/main/java/org/apache/ignite/internal/cli/commands/node/metric/NodeMetricCommand.java} (65%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/node/metric/NodeMetricDisableCommand.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/node/metric/NodeMetricDisableReplCommand.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/node/metric/NodeMetricEnableCommand.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/node/metric/NodeMetricEnableReplCommand.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/node/metric/NodeMetricListCommand.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/node/metric/NodeMetricListReplCommand.java
copy modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UnmarshalException.java => cli/src/main/java/org/apache/ignite/internal/cli/commands/node/metric/NodeMetricReplCommand.java} (64%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/internal/cli/decorators/MetricListDecorator.java
copy modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UnmarshalException.java => metrics/src/main/java/org/apache/ignite/internal/metrics/rest/MetricRestFactory.java} (54%)
create mode 100644 modules/metrics/src/main/java/org/apache/ignite/internal/metrics/rest/NodeMetricController.java
copy modules/{transactions/src/test/java/org/apache/ignite/internal/tx/HeapLockManagerTest.java => metrics/src/main/java/org/apache/ignite/internal/metrics/rest/exception/MetricNotFoundException.java} (72%)
create mode 100644 modules/metrics/src/main/java/org/apache/ignite/internal/metrics/rest/exception/handler/MetricNotFoundExceptionHandler.java
rename modules/{network => network-api}/src/main/java/org/apache/ignite/internal/network/serialization/marshal/MarshalException.java (100%)
rename modules/{network => network-api}/src/main/java/org/apache/ignite/internal/network/serialization/marshal/MarshalledObject.java (100%)
rename modules/{network => network-api}/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UnmarshalException.java (100%)
rename modules/{network => network-api}/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UserObjectMarshaller.java (91%)
create mode 100644 modules/platforms/cpp/.clang-tidy
delete mode 100644 modules/platforms/cpp/schema/BinaryTupleBuilder.cpp
delete mode 100644 modules/platforms/cpp/schema/BinaryTupleParser.cpp
create mode 100644 modules/platforms/cpp/schema/big_decimal.cpp
create mode 100644 modules/platforms/cpp/schema/big_decimal.h
create mode 100644 modules/platforms/cpp/schema/big_integer.cpp
create mode 100644 modules/platforms/cpp/schema/big_integer.h
create mode 100644 modules/platforms/cpp/schema/binary_tuple_builder.cpp
rename modules/platforms/cpp/schema/{BinaryTupleBuilder.h => binary_tuple_builder.h} (54%)
rename modules/platforms/cpp/schema/{BinaryTupleHeader.h => binary_tuple_header.h} (68%)
create mode 100644 modules/platforms/cpp/schema/binary_tuple_parser.cpp
rename modules/platforms/cpp/schema/{BinaryTupleParser.h => binary_tuple_parser.h} (52%)
rename modules/platforms/cpp/schema/{BinaryTupleSchema.h => binary_tuple_schema.h} (66%)
copy modules/platforms/cpp/schema/{ColumnInfo.h => column_info.h} (69%)
create mode 100644 modules/platforms/cpp/schema/ignite_date.h
create mode 100644 modules/platforms/cpp/schema/ignite_date_time.h
create mode 100644 modules/platforms/cpp/schema/ignite_time.h
create mode 100644 modules/platforms/cpp/schema/ignite_timestamp.h
rename modules/platforms/cpp/schema/{DataType.cpp => ignite_type.cpp} (60%)
rename modules/platforms/cpp/schema/{DataType.h => ignite_type.h} (89%)
create mode 100644 modules/platforms/cpp/tests/testDecimal.cpp
create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/ItJraftHlcServerTest.java
create mode 100644 modules/replicator/README.md
copy modules/{metrics => replicator}/pom.xml (75%)
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/Replica.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaManager.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaService.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/PrimaryReplicaMissException.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicaIsAlreadyStartedException.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicaUnavailableException.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicationException.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicationTimeoutException.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/UnsupportedReplicaRequestException.java
rename modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/TransactionalCommand.java => replicator/src/main/java/org/apache/ignite/internal/replicator/listener/ReplicaListener.java} (64%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxFinishResponse.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/ErrorReplicaResponse.java} (58%)
copy modules/{table/src/main/java/org/apache/ignite/internal/table/message/HasDataResponse.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/ErrorTimestampAwareReplicaResponse.java} (70%)
copy modules/{table/src/main/java/org/apache/ignite/internal/table/message/TableMessageGroup.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/ReplicaMessageGroup.java} (52%)
copy modules/{transactions/src/test/java/org/apache/ignite/internal/tx/HeapLockManagerTest.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/ReplicaRequest.java} (72%)
copy modules/{table/src/main/java/org/apache/ignite/internal/table/message/HasDataResponse.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/ReplicaResponse.java} (74%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxFinishResponse.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/TimestampAware.java} (67%)
copy modules/{table/src/main/java/org/apache/ignite/internal/table/message/HasDataResponse.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/TimestampAwareReplicaResponse.java} (70%)
create mode 100644 modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/metric/MetricSourceDto.java
create mode 100644 modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/metric/NodeMetricApi.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableMessageGroup.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableTxManagerImpl.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/DeleteAllCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/DeleteCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/DeleteExactAllCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/DeleteExactCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/GetAllCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/GetAndDeleteCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/GetAndReplaceCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/GetAndUpsertCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/GetCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/InsertAllCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/MultiKeyCommand.java
rename modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/{InsertCommand.java => PartitionCommand.java} (70%)
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/ReplaceCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/ReplaceIfExistCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/SingleKeyCommand.java
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/TxMeta.java => table/src/main/java/org/apache/ignite/internal/table/distributed/command/TxCleanupCommand.java} (52%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpdateAllCommand.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpdateCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpsertAllCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/scan/ScanCloseCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/scan/ScanInitCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/scan/ScanRetrieveBatchCommand.java
copy modules/table/src/main/java/org/apache/ignite/internal/table/{ => distributed}/message/HasDataRequest.java (90%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{ => distributed}/message/HasDataResponse.java (89%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/SnapshotUri.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/incoming/IncomingSnapshotCopier.java
copy modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/{InitPartitionSnapshotReader.java => incoming/IncomingSnapshotReader.java} (59%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/raft/snapshot/message/SnapshotMetaRequest.java} (70%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataRequest.java => distributed/raft/snapshot/message/SnapshotMetaResponse.java} (68%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/raft/snapshot/message/SnapshotMvDataRequest.java} (70%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message/SnapshotMvDataResponse.java
copy modules/{transactions/src/test/java/org/apache/ignite/internal/tx/HeapLockManagerTest.java => table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message/SnapshotRequestMessage.java} (72%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/raft/snapshot/message/SnapshotTxDataRequest.java} (70%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxFinishRequest.java => table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message/SnapshotTxDataResponse.java} (61%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/OutgoingSnapshot.java
copy modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/{InitPartitionSnapshotReader.java => outgoing/OutgoingSnapshotReader.java} (50%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/OutgoingSnapshotsManager.java
rename modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/{InitPartitionSnapshotReader.java => startup/StartupPartitionSnapshotReader.java} (79%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataRequest.java => distributed/replication/request/MultipleRowReplicaRequest.java} (58%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/Waiter.java => table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/ReadOnlyReplicaRequest.java} (65%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/replication/request/ReadWriteMultiRowReplicaRequest.java} (70%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/Waiter.java => table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/ReadWriteReplicaRequest.java} (57%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/replication/request/ReadWriteScanCloseReplicaRequest.java} (70%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/replication/request/ReadWriteScanRetrieveBatchReplicaRequest.java} (69%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/replication/request/ReadWriteSingleRowReplicaRequest.java} (70%)
rename modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/replication/request/ReadWriteSwapRowReplicaRequest.java} (70%)
rename modules/table/src/main/java/org/apache/ignite/internal/table/{message/TableMessageGroup.java => distributed/replication/request/ScanCloseReplicaRequest.java} (67%)
rename modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{command/UpsertCommand.java => replication/request/ScanRetrieveBatchReplicaRequest.java} (55%)
rename modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataRequest.java => distributed/replication/request/SingleRowReplicaRequest.java} (60%)
rename modules/{platforms/cpp/schema/ColumnInfo.h => table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/SwapRowReplicaRequest.java} (58%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
rename modules/{platforms/cpp/common/platform.h => table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/action/RequestType.java} (62%)
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/storage/VersionedRowStore.java
delete mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/MessagingServiceTestUtils.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/command/PartitionRaftCommandsSerializationTest.java
copy modules/transactions/src/main/java/org/apache/ignite/internal/tx/{InternalTransaction.java => Lock.java} (53%)
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/LockKey.java
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/LockMode.java
create mode 100755 modules/transactions/src/main/java/org/apache/ignite/internal/tx/TransactionInternalCheckedException.java
rename modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/{TxFinishRequest.java => TxCleanupReplicaRequest.java} (53%)
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/TxFinishReplicaRequest.java
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/storage/state/TxStateTableStorage.java
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/storage/state/rocksdb/TxStateRocksDbTableStorage.java
rename modules/transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/{TxStateStorageTest.java => TxStateStorageAbstractTest.java} (60%)
create mode 100644 modules/transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/rocksdb/TxStateRocksDbStorageTest.java
create mode 100644 modules/transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/test/TestConcurrentHashMapTxStateStorage.java
copy modules/transactions/src/test/java/org/apache/ignite/internal/tx/{HeapLockManagerTest.java => storage/state/test/TestConcurrentHashMapTxStateStorageTest.java} (58%)
create mode 100644 modules/transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/test/TestConcurrentHashMapTxStateTableStorage.java