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:47:46 UTC
[ignite-3] branch ignite-17655 updated (272ebc7da3 -> 194a1ee511)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-17655
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 272ebc7da3 Minors after review.
add 1134c40142 IGNITE-17801 Add support for Duration and Period types in BinaryTuple (#1152)
add 96139067d6 IGNITE-17426 C++ 3.0: Implement table API (#1154)
add 824459ac58 IGNITE-17812 Fix RetryPolicy exception handling, propagate exceptions to API caller (#1156)
add d4d5e473a6 IGNITE-17677 Refactoring of usage IgniteObjectName utility class (#1142)
add 45f3728364 IGNITE-17792 Automatically load all configuration extensions for tests (#1146)
add acfb76538b IGNITE-17823 Use static test sorted index name (#1159)
add ab8d55f833 IGNITE-17810 SQL: Upgrade Apache Calcite dependency to 1.32.0 (#1153)
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 194a1ee511 Merge branch 'main' into ignite-17655
No new revisions were added by this update.
Summary of changes:
docs/_docs/handling-exceptions.adoc | 119 ++-
.../ignite/example/table/KeyValueViewExample.java | 2 +-
.../example/table/KeyValueViewPojoExample.java | 2 +-
.../ignite/example/table/RecordViewExample.java | 2 +-
.../example/table/RecordViewPojoExample.java | 2 +-
.../ignite/example/tx/TransactionsExample.java | 2 +-
gradle/libs.versions.toml | 5 +-
.../schemas/table/TableConfigurationSchema.java | 6 -
.../ignite/lang/ColumnAlreadyExistsException.java | 3 +-
.../ignite/lang/ColumnNotFoundException.java | 15 +-
.../ignite/lang/IndexAlreadyExistsException.java | 11 +-
.../apache/ignite/lang/IndexNotFoundException.java | 10 +-
.../ignite/lang/TableAlreadyExistsException.java | 8 +-
.../apache/ignite/lang/TableNotFoundException.java | 8 +-
.../java/org/apache/ignite/table/TupleImpl.java | 6 +-
.../apache/ignite/table/manager/IgniteTables.java | 99 --
.../apache/ignite/table/mapper/MapperBuilder.java | 8 +-
.../ignite/table/mapper/OneColumnMapperImpl.java | 4 +-
.../org/apache/ignite/tx/TransactionException.java | 34 +
.../internal/binarytuple/BinaryTupleBuilder.java | 74 ++
.../internal/binarytuple/BinaryTupleCommon.java | 34 +-
.../internal/binarytuple/BinaryTupleParser.java | 46 +
.../internal/binarytuple/BinaryTupleReader.java | 24 +
.../internal/binarytuple/BinaryTupleTest.java | 46 +
.../ignite/internal/cli/IntegrationTestBase.java | 147 +--
.../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 -
.../ClientHandlerConfigurationModule.java} | 21 +-
.../ClientComputeExecuteColocatedRequest.java | 2 +-
.../compute/ClientComputeExecuteRequest.java | 21 +-
.../handler/requests/jdbc/JdbcMetadataCatalog.java | 56 +-
.../handler/requests/sql/ClientSqlCommon.java | 66 +-
.../requests/sql/ClientSqlExecuteRequest.java | 30 +-
.../handler/requests/table/ClientTableCommon.java | 9 +-
...nite.internal.configuration.ConfigurationModule | 6 +-
.../org/apache/ignite/client/RetryReadPolicy.java | 2 +
.../ignite/internal/client/ReliableChannel.java | 19 +-
.../internal/client/compute/ClientCompute.java | 16 +-
.../internal/client/sql/ClientAsyncResultSet.java | 54 +-
.../ignite/internal/client/sql/ClientSession.java | 25 +-
.../ignite/internal/client/table/ClientTables.java | 46 -
.../ignite/internal/client/table/ClientTuple.java | 10 +-
.../ignite/client/AbstractClientTableTest.java | 9 +-
.../apache/ignite/client/AbstractClientTest.java | 3 +-
.../apache/ignite/client/ClientComputeTest.java | 11 +-
.../apache/ignite/client/ClientLoggingTest.java | 5 +-
.../org/apache/ignite/client/ClientSqlTest.java | 3 +-
.../org/apache/ignite/client/ClientTableTest.java | 5 +-
.../org/apache/ignite/client/ClientTablesTest.java | 15 +-
.../org/apache/ignite/client/ClientTupleTest.java | 4 +-
.../java/org/apache/ignite/client/CustomTuple.java | 6 +-
.../org/apache/ignite/client/ReconnectTest.java | 7 +-
.../org/apache/ignite/client/RetryPolicyTest.java | 32 +-
.../org/apache/ignite/client/TestRetryPolicy.java | 7 +
.../org/apache/ignite/client/fakes/FakeIgnite.java | 14 +-
.../ignite/client/fakes/FakeIgniteTables.java | 43 +-
.../ignite/client/fakes/FakeInternalTable.java | 6 +
modules/cluster-management/build.gradle | 1 +
modules/cluster-management/pom.xml | 5 +
.../cluster/management/ItClusterManagerTest.java | 78 +-
.../internal/cluster/management/MockNode.java | 3 +-
.../management/raft/ItCmgRaftServiceTest.java | 10 +-
.../management/ClusterManagementGroupManager.java | 155 ++-
.../management/raft/CmgRaftGroupListener.java | 7 -
modules/compute/build.gradle | 2 +
modules/compute/pom.xml | 5 +
.../internal/compute/ComputeComponentImpl.java | 2 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 9 +-
.../configuration/ComputeConfigurationModule.java} | 33 +-
...nite.internal.configuration.ConfigurationModule | 6 +-
.../internal/compute/IgniteComputeImplTest.java | 8 +-
modules/configuration/pom.xml | 1 -
.../testframework/ConfigurationExtension.java | 111 +-
.../org/apache/ignite/hlc/HybridTimestamp.java | 2 +-
.../apache/ignite/internal/util/CursorUtils.java | 187 ----
.../ignite/internal/util/IgniteNameUtils.java | 177 +++
.../ignite/internal/util/IgniteObjectName.java | 137 ---
.../java/org/apache/ignite/lang/ErrorGroups.java | 96 +-
.../ignite/internal/util/CursorUtilsTest.java | 43 -
.../ignite/internal/util/IgniteNameUtilsTest.java | 58 +
.../internal/testframework/IgniteTestUtils.java | 19 +-
modules/index/build.gradle | 2 +-
modules/index/pom.xml | 7 +-
.../apache/ignite/internal/index/IndexManager.java | 38 +-
.../configuration/IndexConfigurationModule.java} | 26 +-
...nite.internal.configuration.ConfigurationModule | 6 +-
.../ignite/internal/index/IndexManagerTest.java | 41 +-
.../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 +-
.../configuration/NetworkConfigurationModule.java} | 33 +-
...nite.internal.configuration.ConfigurationModule | 6 +-
.../network/serialization/MarshallableTest.java | 3 +-
.../tree/ItBplusTreeReplaceRemoveRaceTest.java | 3 +-
...ItBplusTreeReuseListVolatilePageMemoryTest.java | 3 +-
.../ItBplusTreeVolatilePageMemoryTest.java | 3 +-
.../ItBplusTreePersistentPageMemoryTest.java | 3 +-
...BplusTreeReuseListPersistentPageMemoryTest.java | 3 +-
.../PageMemoryDistributedConfigurationModule.java} | 35 +-
.../ignite/internal/pagememory/tree/BplusTree.java | 6 +-
...nite.internal.configuration.ConfigurationModule | 6 +-
.../pagememory/freelist/AbstractFreeListTest.java | 3 +-
.../inmemory/VolatilePageMemoryNoLoadSelfTest.java | 3 +-
.../PersistentPageMemoryNoLoadTest.java | 3 +-
modules/platforms/cpp/.clang-tidy | 163 +++
modules/platforms/cpp/client-test/CMakeLists.txt | 1 +
.../platforms/cpp/client-test/src/gtest_logger.h | 20 +-
.../cpp/client-test/src/ignite_client_test.cpp | 123 +--
.../src/ignite_runner_suite.h} | 27 +-
modules/platforms/cpp/client-test/src/main.cpp | 13 +-
.../{ignite_client_test.cpp => tables_test.cpp} | 81 +-
.../cpp/client/include/ignite/table/tables.h | 15 +-
.../platforms/cpp/client/src/client_operation.h | 3 +
.../platforms/cpp/client/src/cluster_connection.h | 22 +-
modules/platforms/cpp/client/src/ignite_client.cpp | 3 +-
.../platforms/cpp/client/src/node_connection.cpp | 36 +-
modules/platforms/cpp/client/src/node_connection.h | 12 +-
.../platforms/cpp/client/src/response_handler.h | 14 +-
.../platforms/cpp/client/src/table/table_impl.h | 6 +-
modules/platforms/cpp/client/src/table/tables.cpp | 4 +
.../platforms/cpp/client/src/table/tables_impl.cpp | 35 +-
.../platforms/cpp/client/src/table/tables_impl.h | 21 +-
modules/platforms/cpp/common/CMakeLists.txt | 1 -
modules/platforms/cpp/common/factory.h | 22 +
modules/platforms/cpp/common/guid.h | 239 -----
modules/platforms/cpp/common/ignite_result.h | 190 ++--
modules/platforms/cpp/common/uuid.h | 30 +-
.../include/ignite/network/length_prefix_codec.h | 17 +-
.../network/src/network/length_prefix_codec.cpp | 7 +-
.../include/ignite/protocol/buffer_adapter.h | 30 +-
.../include/ignite/protocol/extension_types.h | 4 +-
.../cpp/protocol/include/ignite/protocol/reader.h | 132 ++-
.../cpp/protocol/include/ignite/protocol/utils.h | 193 +---
.../cpp/protocol/include/ignite/protocol/writer.h | 67 +-
.../platforms/cpp/protocol/src/buffer_adapter.cpp | 13 +-
modules/platforms/cpp/protocol/src/reader.cpp | 84 +-
modules/platforms/cpp/protocol/src/utils.cpp | 84 +-
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 | 47 +-
.../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 | 6 +-
.../Proto/BinaryTuple/BinaryTupleTests.cs | 221 ++++
.../Proto/MessagePackExtensionsTest.cs | 31 -
.../dotnet/Apache.Ignite.Tests/RetryPolicyTests.cs | 27 +
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 8 +-
.../Table/RecordViewPocoTests.cs | 2 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 8 +-
.../Proto/BinaryTuple/BinaryTupleBuilder.cs | 268 ++++-
.../Proto/BinaryTuple/BinaryTupleReader.cs | 60 +-
.../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 -
modules/raft/build.gradle | 4 +
modules/raft/pom.xml | 15 +
.../apache/ignite/internal/raft/ItLozaTest.java | 10 +-
.../internal/raft/ItRaftGroupServiceTest.java | 10 +-
.../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 | 71 +-
.../configuration/RaftConfigurationModule.java} | 34 +-
.../configuration/RaftConfigurationSchema.java} | 43 +-
.../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 +-
...nite.internal.configuration.ConfigurationModule | 6 +-
....ignite.raft.jraft.core.LogStorageBudgetsModule | 16 +
.../org/apache/ignite/internal/raft/LozaTest.java | 9 +-
.../apache/ignite/raft/jraft/core/TestCluster.java | 18 +-
modules/replicator/README.md | 6 +
modules/{compute => replicator}/pom.xml | 35 +-
.../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} | 29 +-
.../UnsupportedReplicaRequestException.java | 52 +
.../replicator/listener/ReplicaListener.java} | 23 +-
.../replicator/message/ErrorReplicaResponse.java} | 20 +-
.../ErrorTimestampAwareReplicaResponse.java} | 11 +-
.../replicator/message/ReplicaMessageGroup.java} | 29 +-
.../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/build.gradle | 1 +
modules/rest/openapi/openapi.yaml | 85 ++
modules/rest/pom.xml | 5 +
.../apache/ignite/internal/rest/RestComponent.java | 2 +
.../configuration/RestConfigurationModule.java} | 33 +-
...nite.internal.configuration.ConfigurationModule | 6 +-
modules/runner/build.gradle | 1 +
.../ignite/internal/ItNoSyncMetadataTest.java | 16 +-
.../cluster/management/ItClusterInitTest.java | 2 +-
.../ignite/internal/compute/ItComputeTest.java | 12 +-
.../ItDistributedConfigurationPropertiesTest.java | 19 +-
.../ItDistributedConfigurationStorageTest.java | 10 +-
.../storage/ItRebalanceDistributedTest.java | 170 ++-
.../ignite/internal/index/ItIndexManagerTest.java | 24 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 19 +-
.../runner/app/AbstractSchemaChangeTest.java | 60 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 55 +-
.../runner/app/ItDynamicTableCreationTest.java | 352 ------
.../app/ItIgniteInMemoryNodeRestartTest.java | 50 +-
.../runner/app/ItIgniteNodeRestartTest.java | 89 +-
.../internal/runner/app/ItNoThreadsLeftTest.java | 30 +-
.../runner/app/ItSchemaChangeKvViewTest.java | 18 +-
.../runner/app/ItSchemaChangeTableViewTest.java | 21 +-
.../runner/app/ItTableApiContractTest.java | 108 +-
.../internal/runner/app/ItTablesApiTest.java | 163 ++-
.../runner/app/PlatformTestNodeRunner.java | 38 +-
.../app/client/ItAbstractThinClientTest.java | 21 +-
.../runner/app/client/ItThinClientComputeTest.java | 12 +-
.../app/client/ItThinClientConnectionTest.java | 2 +-
.../app/jdbc/ItJdbcDeleteStatementSelfTest.java | 4 +-
.../app/jdbc/ItJdbcSelectAfterAlterTable.java | 5 +-
.../app/jdbc/ItJdbcUpdateStatementSelfTest.java | 2 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 18 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 24 +-
.../sql/engine/AbstractBasicIntegrationTest.java | 74 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 6 +-
.../internal/sql/engine/ItDataTypesTest.java | 12 +-
.../internal/sql/engine/ItHashSpoolTest.java | 6 +-
.../internal/sql/engine/ItIndexSpoolTest.java | 8 +-
.../ignite/internal/sql/engine/ItJoinTest.java | 26 +-
.../internal/sql/engine/ItMixedQueriesTest.java | 5 +-
.../internal/sql/engine/ItOrToUnionRuleTest.java | 44 +-
.../sql/engine/ItProjectScanMergeRuleTest.java | 5 +-
.../internal/sql/engine/ItSecondaryIndexTest.java | 5 +-
.../ignite/internal/sql/engine/ItSetOpTest.java | 5 +-
.../internal/table/ItPublicApiColocationTest.java | 12 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 78 +-
...nite.internal.configuration.ConfigurationModule | 6 +-
.../CoreDistributedConfigurationModuleTest.java | 82 --
.../CoreLocalConfigurationModuleTest.java | 92 --
...nite.internal.configuration.ConfigurationModule | 4 +-
.../ignite/internal/schema/BitmaskNativeType.java | 2 +-
.../ignite/internal/schema/ByteBufferRow.java | 2 +-
.../ignite/internal/schema/SchemaManager.java | 2 +-
.../apache/ignite/internal/schema/SchemaUtils.java | 21 -
.../SchemaDistributedConfigurationModule.java | 11 +
...nite.internal.configuration.ConfigurationModule | 4 +-
.../internal/schema/BinaryTuplePrefixTest.java | 2 +-
.../ignite/internal/schema/NativeTypeTest.java | 12 +
.../internal/schema/SchemaConfigurationTest.java | 116 --
.../schema/builder/TableDefinitionBuilderTest.java | 1 -
.../AbstractTableIndexValidatorTest.java | 14 -
...nfigurationToSchemaDescriptorConverterTest.java | 8 -
.../KnownDataStorageValidatorTest.java | 5 +-
.../SchemaDistributedConfigurationModuleTest.java | 5 -
.../testutils/SchemaConfigurationConverter.java | 4 +-
.../testutils/builder/AbstractIndexBuilder.java | 4 +-
.../builder/ColumnDefinitionBuilderImpl.java | 4 +-
.../builder/HashIndexDefinitionBuilderImpl.java | 6 +-
.../builder/PrimaryKeyDefinitionBuilderImpl.java | 10 +-
.../schema/testutils/builder/SchemaBuilders.java | 3 +-
.../builder/SortedIndexDefinitionBuilderImpl.java | 4 +-
.../builder/TableDefinitionBuilderImpl.java | 8 +-
.../schema/testutils/definition/SchemaObject.java | 9 -
.../testutils/definition/TableDefinitionImpl.java | 7 -
modules/sql-engine/build.gradle | 1 -
modules/sql-engine/pom.xml | 5 -
.../internal/sql/engine/SqlQueryProcessor.java | 21 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 83 +-
.../internal/sql/engine/exec/exp/RexImpTable.java | 2 +-
.../sql/engine/exec/exp/RexToLixTranslator.java | 7 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 27 +-
.../internal/sql/engine/session/Session.java | 23 +-
.../sql/engine/type/IgniteTypeFactory.java | 5 +-
.../internal/sql/engine/StopCalciteModuleTest.java | 19 +-
.../sql/engine/exec/MockedStructuresTest.java | 38 +-
.../engine/exec/schema/SqlSchemaManagerTest.java | 54 +-
modules/storage-api/build.gradle | 1 +
modules/storage-api/pom.xml | 6 +
.../internal/storage/MvPartitionStorage.java | 69 +-
.../org/apache/ignite/internal/storage/RowId.java | 29 +-
.../storage/index/BinaryTupleComparator.java | 28 +-
...nite.internal.configuration.ConfigurationModule | 4 +-
.../internal/storage/DataStorageManagerTest.java | 20 +-
.../internal/storage/TestMvTableStorageTest.java | 14 -
.../storage/index/BinaryTupleComparatorTest.java | 23 +-
.../storage/index/TestHashIndexStorageTest.java | 12 -
.../storage/index/TestSortedIndexStorageTest.java | 12 -
...nite.internal.configuration.ConfigurationModule | 4 +-
.../storage/AbstractMvPartitionStorageTest.java | 64 +-
.../storage/AbstractMvTableStorageTest.java | 20 +-
.../storage/impl/TestMvPartitionStorage.java | 20 +-
.../index/AbstractSortedIndexStorageTest.java | 2 +-
.../storage/index/impl/TestSortedIndexStorage.java | 52 +-
modules/storage-page-memory/build.gradle | 1 +
modules/storage-page-memory/pom.xml | 6 +
...torageEngineDistributedConfigurationModule.java | 4 +-
.../index/sorted/PageMemorySortedIndexStorage.java | 74 +-
.../index/sorted/io/SortedIndexTreeIo.java | 4 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 21 +-
...nite.internal.configuration.ConfigurationModule | 4 +-
.../PersistentPageMemoryDataRegionTest.java | 3 +-
.../PersistentPageMemoryMvTableStorageTest.java | 17 +-
.../VolatilePageMemoryMvTableStorageTest.java | 17 +-
.../PageMemoryDataRegionValidatorImplTest.java | 5 +-
.../PersistentPageMemoryHashIndexStorageTest.java | 15 +-
...PersistentPageMemorySortedIndexStorageTest.java | 15 +-
.../VolatilePageMemoryHashIndexStorageTest.java | 15 +-
.../VolatilePageMemorySortedIndexStorageTest.java | 15 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 18 +-
.../VolatilePageMemoryMvPartitionStorageTest.java | 15 +-
modules/storage-rocksdb/build.gradle | 1 +
modules/storage-rocksdb/pom.xml | 6 +
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 66 +-
.../storage/rocksdb/RocksDbTableStorage.java | 2 +-
.../index/RocksDbBinaryTupleComparator.java | 17 +-
.../rocksdb/index/RocksDbSortedIndexStorage.java | 68 +-
...nite.internal.configuration.ConfigurationModule | 4 +-
.../rocksdb/RocksDbMvPartitionStorageTest.java | 12 -
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 47 +-
.../storage/rocksdb/RocksDbStorageEngineTest.java | 19 -
.../rocksdb/index/RocksDbHashIndexStorageTest.java | 12 -
.../index/RocksDbSortedIndexStorageTest.java | 12 -
modules/table/build.gradle | 2 +
modules/table/pom.xml | 20 +-
.../distributed/ItInternalTableScanTest.java | 181 +---
.../ignite/distributed/ItTablePersistenceTest.java | 51 +-
.../distributed/ItTxDistributedTestSingleNode.java | 162 ++-
.../ignite/internal/table/ItColocationTest.java | 78 +-
.../internal/table/AbstractRowTupleAdapter.java | 8 +-
.../ignite/internal/table/InternalTable.java | 8 +
.../internal/table/distributed/TableManager.java | 309 ++++--
.../table/distributed/TableMessageGroup.java | 110 ++
.../table/distributed/TableTxManagerImpl.java | 57 -
.../table/distributed/command/CommandUtils.java | 102 +-
.../table/distributed/command/DeleteCommand.java | 40 -
.../distributed/command/DeleteExactAllCommand.java | 42 -
.../distributed/command/DeleteExactCommand.java | 40 -
.../table/distributed/command/FinishTxCommand.java | 68 +-
.../distributed/command/GetAndDeleteCommand.java | 41 -
.../distributed/command/GetAndReplaceCommand.java | 41 -
.../distributed/command/GetAndUpsertCommand.java | 41 -
.../table/distributed/command/GetCommand.java | 40 -
.../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 ++
.../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 -----------
...nite.internal.configuration.ConfigurationModule | 4 +-
.../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 | 95 +-
.../PartitionRaftCommandsSerializationTest.java | 279 +++++
.../raft/PartitionCommandListenerTest.java | 599 ++---------
.../table/impl/DummyInternalTableImpl.java | 229 ++--
.../internal/table/impl/TestTupleBuilder.java | 8 +-
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} | 23 +-
.../TestConcurrentHashMapTxStateTableStorage.java | 82 ++
parent/pom.xml | 22 +-
pom.xml | 1 +
522 files changed, 18701 insertions(+), 11662 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/LogicalTopologyCall.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/{runner/src/main/java/org/apache/ignite/internal/configuration/CoreLocalConfigurationModule.java => client-handler/src/main/java/org/apache/ignite/client/handler/configuration/ClientHandlerConfigurationModule.java} (66%)
copy modules/{runner/src/test => client-handler/src/main}/resources/META-INF/services/org.apache.ignite.internal.configuration.ConfigurationModule (76%)
rename modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpsertAllCommand.java => compute/src/main/java/org/apache/ignite/internal/compute/configuration/ComputeConfigurationModule.java} (53%)
copy modules/{runner/src/test => compute/src/main}/resources/META-INF/services/org.apache.ignite.internal.configuration.ConfigurationModule (76%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/IgniteNameUtils.java
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/IgniteObjectName.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteNameUtilsTest.java
rename modules/{runner/src/main/java/org/apache/ignite/internal/configuration/CoreLocalConfigurationModule.java => index/src/main/java/org/apache/ignite/internal/index/configuration/IndexConfigurationModule.java} (54%)
copy modules/{runner/src/test => index/src/main}/resources/META-INF/services/org.apache.ignite.internal.configuration.ConfigurationModule (76%)
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%)
rename modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/InsertAllCommand.java => network/src/main/java/org/apache/ignite/network/configuration/NetworkConfigurationModule.java} (53%)
copy modules/{runner/src/test => network/src/main}/resources/META-INF/services/org.apache.ignite.internal.configuration.ConfigurationModule (77%)
rename modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/DeleteAllCommand.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/PageMemoryDistributedConfigurationModule.java} (50%)
copy modules/{storage-api => page-memory}/src/main/resources/META-INF/services/org.apache.ignite.internal.configuration.ConfigurationModule (78%)
create mode 100644 modules/platforms/cpp/.clang-tidy
copy modules/platforms/cpp/{common/factory.h => client-test/src/ignite_runner_suite.h} (65%)
copy modules/platforms/cpp/client-test/src/{ignite_client_test.cpp => tables_test.cpp} (71%)
delete mode 100644 modules/platforms/cpp/common/guid.h
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
rename modules/{runner/src/main/java/org/apache/ignite/internal/configuration/CoreDistributedConfigurationModule.java => raft/src/main/java/org/apache/ignite/internal/raft/configuration/RaftConfigurationModule.java} (51%)
copy modules/{client-common/src/main/java/org/apache/ignite/internal/client/proto/ClientMsgPackType.java => raft/src/main/java/org/apache/ignite/internal/raft/configuration/RaftConfigurationSchema.java} (51%)
copy modules/{runner/src/test => raft/src/main}/resources/META-INF/services/org.apache.ignite.internal.configuration.ConfigurationModule (77%)
create mode 100644 modules/replicator/README.md
copy modules/{compute => replicator}/pom.xml (83%)
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
copy modules/{api/src/main/java/org/apache/ignite/lang/IndexAlreadyExistsException.java => replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicationTimeoutException.java} (50%)
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/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxMessageGroup.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
rename modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/GetAllCommand.java => rest/src/main/java/org/apache/ignite/internal/rest/configuration/RestConfigurationModule.java} (53%)
copy modules/{runner/src/test => rest/src/main}/resources/META-INF/services/org.apache.ignite.internal.configuration.ConfigurationModule (77%)
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItDynamicTableCreationTest.java
delete mode 100644 modules/runner/src/test/java/org/apache/ignite/internal/configuration/CoreDistributedConfigurationModuleTest.java
delete mode 100644 modules/runner/src/test/java/org/apache/ignite/internal/configuration/CoreLocalConfigurationModuleTest.java
delete mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/SchemaConfigurationTest.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/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/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/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/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/{client/src/test/java/org/apache/ignite/client/TestRetryPolicy.java => transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/test/TestConcurrentHashMapTxStateStorageTest.java} (60%)
create mode 100644 modules/transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/test/TestConcurrentHashMapTxStateTableStorage.java