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/03 14:58:28 UTC
[ignite-3] branch ignite-17655 updated (f2e8d6f311 -> 9ba7ae5357)
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 f2e8d6f311 WIP. Styles.
add 01ccc036f7 IGNITE-17493 Add 'isLeader' check to CMG topology listener (#1120)
add 16c407504e IGNITE-17687 Get rid of using deprecated exception constructors in the sql-engine module (#1114)
add 533fa65f86 IGNITE-17464 Minor fixes in NetworkMessage annotation processor (#1122)
add 3d017c4b7f IGNITE-17673 Extended MV partition storage API with methods to help cleaning SQL indices (#1121)
add ba7369613c IGNITE-17770 Muted ItIgniteNodeRestartTest.testCfgGap
add 4f8c4303c9 IGNITE-17769 Fix modules/rest/openapi/openapi.yaml after change IgniteProductVersion (#1125)
add a5cb1a691a IGNITE-17495 Form zip layout and add start script (#1106)
add 3e689e86ee IGNITE-17711 Append element count to the end of BinaryTuplePrefix (#1126)
add c685b099ef IGNITE-17424 Basic C++ client (#1085)
add d8c4bce94b IGNITE-17778 Fix C++ files licenses (#1133)
add 2240ca187a IGNITE-15431 .NET: Add support for all native data types (#1132)
add cd32ecc99f IGNITE-17755 Add a common interface for all index storages (#1127)
add 9d4b8a7e18 IGNITE-17118 Replace CompletionStage with CompletableFuture in public APIs (#1141)
add 76ee116dda IGNITE-16994 .NET: Upgrade to SDK 6.0 (#1139)
add 6aba85c0e5 IGNITE-17763 Use retry policy when connecting default channel (#1135)
add 2449ad8c60 IGNITE-17696 Provide initial C++ style guide and clang-format (#1088)
add 5227513b0b IGNITE-17720 Extend MvPartitionStorage scan API with write intent resolution capabilities (#1124)
add 5009b4d4f0 IGNITE-17788 Specified comparison order introduced for RowId (#1143)
add fcc79e88a5 IGNITE-17790 Remove IgniteCursor class (#1144)
add c6b73457fa IGNITE-17794 .NET: Fix source generators performance (#1148)
add ccc8948a8c IGNITE-17795 Need to stop the checkpoint manager before the data regions stop (#1149)
add abe1ada882 IGNITE-17358 Metric exporters' configurations. Fixes #1098
add e7df5e28ec IGNITE-17686 Revisit and fix exception handling in futures chains in sql-engine module (#1118)
add bfa0e51248 Merge branch 'main' into ignite-17655
add 9ba7ae5357 WIP. Styles.
No new revisions were added by this update.
Summary of changes:
.gitignore | 2 +
assembly/README.md | 26 +-
deliveries/deb/build.sh | 33 -
.../apache/ignite/sql/async/AsyncResultSet.java | 6 +-
.../internal/binarytuple/BinaryTupleBuilder.java | 11 +-
.../internal/binarytuple/BinaryTupleParser.java | 11 +-
.../binarytuple/BinaryTuplePrefixBuilder.java | 44 +-
modules/cli/build.gradle | 37 +-
.../internal/client/proto/ClientDataType.java | 5 +-
.../internal/client/proto/ClientMessagePacker.java | 5 +-
.../client/proto/ClientMessageUnpacker.java | 4 -
.../handler/requests/jdbc/JdbcQueryCursor.java | 3 +-
.../apache/ignite/client/ClientOperationType.java | 5 +
.../org/apache/ignite/client/RetryReadPolicy.java | 1 +
.../ignite/internal/client/ReliableChannel.java | 15 +-
.../internal/client/sql/ClientAsyncResultSet.java | 5 +-
.../apache/ignite/client/AbstractClientTest.java | 2 +-
.../apache/ignite/client/ClientComputeTest.java | 3 +-
.../apache/ignite/client/ClientLoggingTest.java | 7 +-
.../ignite/client/PartitionAwarenessTest.java | 6 +-
.../org/apache/ignite/client/ReconnectTest.java | 2 +-
.../ignite/client/fakes/FakeAsyncResultSet.java | 5 +-
.../org/apache/ignite/client/fakes/FakeCursor.java | 3 +-
.../management/ClusterManagementGroupManager.java | 30 +-
.../cluster/management/raft/CmgRaftService.java | 1 -
.../apache/ignite/internal/util}/CursorUtils.java | 28 +-
.../apache/ignite/internal/util/IgniteCursor.java | 67 --
.../java/org/apache/ignite/lang/ErrorGroups.java | 71 +-
.../ignite/internal/util}/CursorUtilsTest.java | 11 +-
modules/metrics/build.gradle | 3 +
modules/metrics/pom.xml | 48 ++
...Test.java => ItMetricExportersLoadingTest.java} | 21 +-
.../metrics/exporters/TestPullMetricExporter.java | 9 +-
...estPullMetricsExporterConfigurationSchema.java} | 16 +-
.../metrics/exporters/TestPushMetricExporter.java | 24 +-
...estPushMetricsExporterConfigurationSchema.java} | 16 +-
.../ignite/internal/metrics/MetricManager.java | 121 +++-
.../configuration/MetricConfigurationModule.java} | 28 +-
.../configuration/MetricConfigurationSchema.java} | 19 +-
.../metrics/exporters/BasicMetricExporter.java | 15 +-
.../internal/metrics/exporters/MetricExporter.java | 16 +-
.../metrics/exporters/PushMetricExporter.java | 42 +-
.../ExporterConfigurationSchema.java} | 23 +-
.../JmxExporterConfigurationSchema.java} | 15 +-
...ite.internal.configuration.ConfigurationModule} | 6 +-
.../internal/metrics/MetricConfigurationTest.java | 111 +++
.../internal/metrics/exporters/TestExporter.java} | 56 +-
.../TestExporterConfigurationSchema.java} | 17 +-
.../internal/network/processor/MessageClass.java | 12 +-
.../network/netty/ItConnectionManagerTest.java | 6 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 6 +-
.../internal/network/AllTypesMessageGenerator.java | 5 +-
.../internal/network/AllTypesMessageTest.java | 1 +
.../network/SerializationMicroBenchmark.java | 1 +
.../network/{ => messages}/AllTypesMessage.java | 3 +-
.../{processor => messages}/EmptyMessage.java | 3 +-
.../{processor => messages}/InheritedMessage.java | 3 +-
.../MessageWithMarshallable.java | 4 +-
.../{ => messages}/NestedMessageMessage.java | 3 +-
.../{processor => messages}/NetworkMessage1.java | 2 +-
.../{processor => messages}/NetworkMessage2.java | 2 +-
.../SerializationOrderMessage.java | 3 +-
.../network/messages}/TestMessage.java | 3 +-
.../network/messages}/TestMessageTypes.java | 5 +-
.../internal/network/netty/InboundDecoderTest.java | 14 +-
.../network/netty/RecoveryHandshakeTest.java | 6 +-
.../network/processor/EmptyMessageTest.java | 4 +-
.../network/processor/InMemoryJavaFileManager.java | 0
.../network/processor/InheritedMessageTest.java | 4 +-
.../network/processor/SerializationOrderTest.java | 4 +-
...ransferableObjectProcessorIncrementalTest.java} | 46 +-
.../TransferableObjectProcessorTest.java} | 31 +-
.../network/serialization/MarshallableTest.java | 5 +-
.../network/AbstractMessagingServiceTest.java | 1 +
.../MessageSerializationRegistryImplTest.java | 9 +-
.../TestMessageSerializationRegistryImpl.java | 5 +-
.../network/processor/AllTypesMessage.java | 54 +-
.../network/processor/ConflictingTypeMessage.java | 1 +
.../network/processor/InheritedMessageClash.java | 0
.../processor/InvalidAnnotatedTypeMessage.java | 0
.../processor/InvalidParameterGetterMessage.java | 0
.../processor/InvalidReturnTypeGetterMessage.java | 0
.../internal/network/processor/SecondGroup.java | 0
.../network/processor/TestMessageGroup.java} | 2 +-
.../network/processor/TransitiveMessage.java | 0
.../processor/UnmarshallableTypeMessage.java | 0
.../UnmarshallableTypeNonSerializableMessage.java | 0
.../tree/AbstractBplusTreePageMemoryTest.java | 86 ++-
.../pagememory/freelist/AbstractFreeList.java | 54 +-
.../ignite/internal/pagememory/tree/BplusTree.java | 144 ++--
.../internal/pagememory/tree/IgniteTree.java | 6 +-
.../cpp/{common/CMakeLists.txt => .clang-format} | 32 +-
modules/platforms/cpp/CMakeLists.txt | 92 ++-
modules/platforms/cpp/DEVNOTES.md | 64 ++
modules/platforms/cpp/StyleGuide.md | 145 ++++
.../cpp/{common => client-test}/CMakeLists.txt | 22 +-
.../platforms/cpp/client-test/src/gtest_logger.h | 90 +++
.../cpp/client-test/src/ignite_client_test.cpp | 154 ++++
modules/platforms/cpp/client-test/src/main.cpp | 61 ++
modules/platforms/cpp/client/CMakeLists.txt | 55 ++
.../cpp/client/include/ignite/ignite_client.h | 124 ++++
.../include/ignite/ignite_client_configuration.h | 129 ++++
.../cpp/client/include/ignite/ignite_logger.h | 70 ++
.../cpp/client/include/ignite/table/table.h | 84 +++
.../cpp/client/include/ignite/table/tables.h | 92 +++
.../cpp/client/src/client_operation.h} | 32 +-
.../cpp/client/src/cluster_connection.cpp | 179 +++++
.../platforms/cpp/client/src/cluster_connection.h | 218 ++++++
modules/platforms/cpp/client/src/ignite_client.cpp | 79 +++
.../platforms/cpp/client/src/ignite_client_impl.h | 96 +++
.../platforms/cpp/client/src/node_connection.cpp | 149 ++++
modules/platforms/cpp/client/src/node_connection.h | 188 +++++
.../cpp/client/src/protocol_context.h} | 39 +-
.../platforms/cpp/client/src/protocol_version.h | 170 +++++
.../platforms/cpp/client/src/response_handler.h | 133 ++++
.../cpp/client/src/table/table.cpp} | 21 +-
.../platforms/cpp/client/src/table/table_impl.h | 68 ++
.../cpp/client/src/table/tables.cpp} | 28 +-
.../platforms/cpp/client/src/table/tables_impl.cpp | 44 ++
.../platforms/cpp/client/src/table/tables_impl.h | 59 ++
modules/platforms/cpp/common/CMakeLists.txt | 11 +-
modules/platforms/cpp/common/{Bits.h => bits.h} | 42 +-
modules/platforms/cpp/common/{Bytes.h => bytes.h} | 70 +-
.../platforms/cpp/common/{Config.h => config.h} | 9 +
.../cpp/common/factory.h} | 33 +-
modules/platforms/cpp/common/guid.h | 239 +++++++
modules/platforms/cpp/common/ignite_error.h | 117 ++++
modules/platforms/cpp/common/ignite_result.h | 318 +++++++++
.../cpp/common/platform.h} | 27 +-
modules/platforms/cpp/common/{Types.h => types.h} | 16 +-
modules/platforms/cpp/common/{Config.h => utils.h} | 70 +-
modules/platforms/cpp/common/{Uuid.h => uuid.h} | 26 +-
.../cpp/conanfile.txt} | 15 +-
modules/platforms/cpp/network/CMakeLists.txt | 68 ++
.../include/ignite/network/async_client_pool.h | 64 ++
.../network/include/ignite/network/async_handler.h | 78 +++
.../cpp/network/include/ignite/network/codec.h} | 45 +-
.../include/ignite/network/codec_data_filter.h | 97 +++
.../network/include/ignite/network/data_buffer.h | 207 ++++++
.../network/include/ignite/network/data_filter.h | 75 ++
.../include/ignite/network/data_filter_adapter.h | 121 ++++
.../cpp/network/include/ignite/network/data_sink.h | 54 ++
.../cpp/network/include/ignite/network/end_point.h | 139 ++++
.../include/ignite/network/length_prefix_codec.h | 105 +++
.../cpp/network/include/ignite/network/network.h} | 17 +-
.../cpp/network/include/ignite/network/tcp_range.h | 156 +++++
.../os/linux/src/network/connecting_context.cpp | 95 +++
.../os/linux/src/network/connecting_context.h | 92 +++
.../os/linux/src/network/linux_async_client.cpp | 171 +++++
.../os/linux/src/network/linux_async_client.h | 217 ++++++
.../linux/src/network/linux_async_client_pool.cpp | 186 +++++
.../os/linux/src/network/linux_async_client_pool.h | 186 +++++
.../src/network/linux_async_worker_thread.cpp | 318 +++++++++
.../linux/src/network/linux_async_worker_thread.h | 159 +++++
.../cpp/network/os/linux/src/network/sockets.cpp | 105 +++
.../cpp/network/os/linux/src/network/sockets.h | 59 ++
.../cpp/network/os/linux/src/network/utils.cpp} | 27 +-
.../cpp/network/os/win/src/network/sockets.cpp | 144 ++++
.../cpp/network/os/win/src/network/sockets.h | 65 ++
.../network/os/win/src/network/utils.cpp} | 42 +-
.../os/win/src/network/win_async_client.cpp | 166 +++++
.../network/os/win/src/network/win_async_client.h | 241 +++++++
.../os/win/src/network/win_async_client_pool.cpp | 218 ++++++
.../os/win/src/network/win_async_client_pool.h | 200 ++++++
.../src/network/win_async_connecting_thread.cpp | 236 +++++++
.../win/src/network/win_async_connecting_thread.h | 127 ++++
.../os/win/src/network/win_async_worker_thread.cpp | 131 ++++
.../os/win/src/network/win_async_worker_thread.h | 72 ++
.../src/network/async_client_pool_adapter.cpp | 61 ++
.../src/network/async_client_pool_adapter.h | 96 +++
.../cpp/network/src/network/codec_data_filter.cpp | 94 +++
.../network/src/network/error_handling_filter.cpp | 66 ++
.../network/src/network/error_handling_filter.h | 83 +++
.../network/src/network/length_prefix_codec.cpp | 83 +++
.../cpp/network/src/network/network.cpp} | 28 +-
.../cpp/network/src/network/tcp_range.cpp | 131 ++++
modules/platforms/cpp/network/src/network/utils.h | 106 +++
modules/platforms/cpp/pom.xml | 4 +-
.../cpp/{common => protocol}/CMakeLists.txt | 23 +-
.../include/ignite/protocol/buffer_adapter.h | 80 +++
.../include/ignite/protocol/extension_types.h} | 37 +-
.../cpp/protocol/include/ignite/protocol/reader.h | 132 ++++
.../cpp/protocol/include/ignite/protocol/utils.h | 205 ++++++
.../cpp/protocol/include/ignite/protocol/writer.h | 129 ++++
.../cpp/protocol/src/buffer_adapter.cpp} | 22 +-
modules/platforms/cpp/protocol/src/reader.cpp | 117 ++++
modules/platforms/cpp/protocol/src/utils.cpp | 54 ++
.../cpp/protocol/src/writer.cpp} | 33 +-
.../platforms/cpp/schema/BinaryTupleBuilder.cpp | 43 +-
modules/platforms/cpp/schema/BinaryTupleBuilder.h | 42 +-
modules/platforms/cpp/schema/BinaryTupleHeader.h | 12 +-
modules/platforms/cpp/schema/BinaryTupleParser.cpp | 38 +-
modules/platforms/cpp/schema/BinaryTupleParser.h | 28 +-
modules/platforms/cpp/schema/BinaryTupleSchema.h | 12 +-
modules/platforms/cpp/schema/DataType.cpp | 1 +
modules/platforms/cpp/schema/DataType.h | 2 +-
.../cpp/{common => test-common}/CMakeLists.txt | 20 +-
.../cpp/test-common/include/cmd_process.h | 71 ++
.../cpp/test-common/include/ignite_runner.h} | 44 +-
.../cpp/test-common/include/test_utils.h} | 34 +-
.../cpp/test-common/src/ignite_runner.cpp | 79 +++
.../cpp/test-common/src/linux/linux_process.h | 139 ++++
.../cpp/test-common/src/process.cpp} | 41 +-
.../platforms/cpp/test-common/src/test_utils.cpp | 89 +++
.../cpp/test-common/src/win/win_process.h | 183 +++++
modules/platforms/cpp/tests/CMakeLists.txt | 13 +-
modules/platforms/cpp/tests/testBits.cpp | 772 ++++++++++-----------
modules/platforms/cpp/tests/testBytes.cpp | 80 +--
modules/platforms/cpp/tests/testUuid.cpp | 12 +-
.../Apache.Ignite.Benchmarks.csproj | 3 +-
.../Serialization/ObjectSerializerHandlerOld.cs | 142 ----
.../SerializerHandlerBenchmarksBase.cs | 8 +-
.../SerializerHandlerWriteBenchmarks.cs | 12 -
.../ErrorGroupsGenerator.cs | 13 +-
.../ExceptionsGenerator.cs | 18 +-
.../JavaToCsharpGeneratorBase.cs | 59 ++
.../Apache.Ignite.Tests/Apache.Ignite.Tests.csproj | 2 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 2 +-
.../dotnet/Apache.Ignite.Tests/ExceptionsTests.cs | 17 +-
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 4 +-
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 2 +
.../Proto/BinaryTuple/BinaryTupleTests.cs | 182 +++++
.../Apache.Ignite.Tests/Table/PocoAllColumns.cs | 49 ++
.../Table/RecordViewBinaryTests.cs | 54 +-
.../Table/RecordViewPocoTests.cs | 64 ++
.../Serialization/ObjectSerializerHandlerTests.cs | 4 +-
.../Apache.Ignite.Tests/Table/TablesTests.cs | 8 +-
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 6 +-
.../dotnet/Apache.Ignite/IgniteException.cs | 2 +-
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 4 +-
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 4 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 2 +-
.../Apache.Ignite/Internal/ConnectionContext.cs | 3 -
.../Proto/BinaryTuple/BinaryTupleBuilder.cs | 232 ++++++-
.../Proto/BinaryTuple/BinaryTupleReader.cs | 180 ++++-
.../Apache.Ignite/Internal/Proto/ClientDataType.cs | 59 +-
.../Internal/Proto/ClientDataTypeExtensions.cs | 38 +-
.../Internal/Proto/MessagePackWriterExtensions.cs | 72 +-
.../dotnet/Apache.Ignite/Internal/Sql/ResultSet.cs | 2 +-
.../dotnet/Apache.Ignite/Internal/Table/Column.cs | 2 +-
.../dotnet/Apache.Ignite/Internal/Table/Schema.cs | 3 -
.../Table/Serialization/BinaryTupleMethods.cs | 47 +-
.../Table/Serialization/ObjectSerializerHandler.cs | 22 +-
.../Table/Serialization/TupleSerializerHandler.cs | 6 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 9 +-
.../dotnet/Apache.Ignite/Table/IgniteTuple.cs | 2 +-
modules/platforms/dotnet/DEVNOTES.md | 8 -
modules/platforms/dotnet/Directory.Build.props | 4 +-
modules/rest/openapi/openapi.yaml | 20 +-
.../runner/app/ItIgniteNodeRestartTest.java | 1 +
.../runner/app/PlatformTestNodeRunner.java | 55 +-
.../app/client/ItAbstractThinClientTest.java | 4 +-
.../runner/app/client/ItThinClientComputeTest.java | 1 -
.../org/apache/ignite/internal/app/IgniteImpl.java | 5 +-
.../apache/ignite/internal/schema/BinaryTuple.java | 9 +
.../ignite/internal/schema/BinaryTuplePrefix.java | 32 +-
.../internal/schema/BinaryTuplePrefixTest.java | 24 +-
.../internal/sql/api/AsyncResultSetImpl.java | 5 +-
.../ignite/internal/sql/api/SessionImpl.java | 12 +-
.../ignite/internal/sql/engine/AsyncCursor.java | 3 +-
.../internal/sql/engine/AsyncSqlCursorImpl.java | 3 +-
.../ignite/internal/sql/engine/QueryCancel.java | 5 +-
.../sql/engine/QueryCancelledException.java | 4 +-
.../internal/sql/engine/SqlQueryProcessor.java | 18 +-
.../internal/sql/engine/exec/AsyncWrapper.java | 3 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 5 +-
.../engine/exec/ExecutionCancelledException.java | 8 +
.../internal/sql/engine/exec/ExecutionContext.java | 5 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 21 +-
.../sql/engine/exec/QueryValidationException.java | 6 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 12 +-
.../internal/sql/engine/exec/rel/AbstractNode.java | 3 +-
.../sql/engine/exec/rel/AsyncRootNode.java | 3 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 3 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 5 +-
.../internal/sql/engine/exec/rel/RootNode.java | 6 +-
.../internal/sql/engine/externalize/RelJson.java | 8 +-
.../sql/engine/externalize/RelJsonReader.java | 6 +-
.../sql/engine/externalize/RelJsonWriter.java | 6 +-
.../sql/engine/message/MessageServiceImpl.java | 7 +-
.../internal/sql/engine/prepare/IgnitePlanner.java | 4 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 6 +-
.../internal/sql/engine/prepare/QueryTemplate.java | 5 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 20 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 40 +-
.../ignite/internal/sql/engine/util/Commons.java | 4 +-
.../internal/sql/engine/IgniteSqlApiTest.java | 5 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 5 +-
.../sql/engine/exec/MockedStructuresTest.java | 18 +-
.../exec/rel/IndexScanNodeExecutionTest.java | 3 +-
modules/storage-api/README.md | 2 +-
modules/storage-api/build.gradle | 1 +
.../internal/storage/MvPartitionStorage.java | 18 +-
.../internal/storage/PartitionTimestampCursor.java | 51 ++
.../apache/ignite/internal/storage/ReadResult.java | 8 +
.../org/apache/ignite/internal/storage/RowId.java | 13 +-
.../internal/storage/engine/MvTableStorage.java | 51 +-
.../internal/storage/index/HashIndexStorage.java | 33 +-
.../{HashIndexStorage.java => IndexStorage.java} | 31 +-
.../internal/storage/index/SortedIndexStorage.java | 14 +-
.../storage/TestMvPartitionStorageTest.java | 6 +-
...torageTest.java => TestMvTableStorageTest.java} | 18 +-
.../storage/index/TestHashIndexStorageTest.java | 12 +-
.../storage/index/TestSortedIndexStorageTest.java | 12 +-
...nite.internal.configuration.ConfigurationModule | 2 +-
...pache.ignite.internal.storage.DataStorageModule | 2 +-
.../storage/AbstractMvPartitionStorageTest.java | 235 ++++++-
.../storage/AbstractMvTableStorageTest.java | 21 +-
.../internal/storage/BaseMvStoragesTest.java | 7 +
.../TestDataStorageModule.java} | 10 +-
.../TestMvPartitionStorage.java} | 114 ++-
.../TestMvTableStorage.java} | 13 +-
.../TestStorageEngine.java} | 12 +-
...orageEngineDistributedConfigurationModule.java} | 10 +-
.../TestDataStorageConfigurationSchema.java} | 10 +-
.../index/AbstractSortedIndexStorageTest.java | 72 +-
.../internal/storage/index/impl/TestIndexRow.java | 20 -
.../storage/index/impl/TestSortedIndexStorage.java | 8 +
.../pagememory/AbstractPageMemoryTableStorage.java | 23 +-
.../PersistentPageMemoryStorageEngine.java | 5 +-
.../index/hash/PageMemoryHashIndexStorage.java | 9 +-
.../index/sorted/PageMemorySortedIndexStorage.java | 25 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 254 +++++--
.../storage/pagememory/util/TreeCursorAdapter.java | 77 --
.../PersistentPageMemoryMvTableStorageTest.java | 101 +++
.../VolatilePageMemoryMvTableStorageTest.java} | 57 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 344 ++++++---
.../storage/rocksdb/RocksDbTableStorage.java | 5 +
.../rocksdb/index/RocksDbSortedIndexStorage.java | 85 ++-
.../distributed/ItInternalTableScanTest.java | 12 +-
.../ignite/distributed/ItTablePersistenceTest.java | 4 +-
.../distributed/ItTxDistributedTestSingleNode.java | 4 +-
.../distributed/storage/VersionedRowStore.java | 5 +-
.../org/apache/ignite/internal/table/Example.java | 4 +-
.../internal/table/InteropOperationsTest.java | 4 +-
.../table/KeyValueBinaryViewOperationsTest.java | 4 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 4 +-
.../internal/table/KeyValueViewOperationsTest.java | 4 +-
.../table/RecordBinaryViewOperationsTest.java | 4 +-
.../internal/table/RecordViewOperationsTest.java | 4 +-
.../internal/table/SchemaValidationTest.java | 4 +-
.../apache/ignite/internal/table/TxLocalTest.java | 6 +-
.../raft/PartitionCommandListenerTest.java | 4 +-
.../state/rocksdb/TxStateRocksDbStorage.java | 5 +-
packaging/build.gradle | 120 ++++
{examples => packaging}/config/ignite-config.conf | 0
.../config/ignite.java.util.logging.properties | 45 ++
.../CMakeLists.txt => packaging/deb/build.sh | 22 +-
{deliveries => packaging}/deb/changelog | 0
{deliveries => packaging}/deb/control | 0
{deliveries => packaging}/deb/copyright | 0
{deliveries => packaging}/deb/rules | 0
{deliveries => packaging}/rpm/.gitignore | 0
{deliveries => packaging}/rpm/Dockerfile | 0
{deliveries => packaging}/rpm/README.md | 0
{deliveries => packaging}/rpm/apache-ignite.spec | 0
{deliveries => packaging}/rpm/build.sh | 31 +-
packaging/scripts/bootstrap-config | 10 +
packaging/scripts/ignite3-db.sh | 78 +++
parent/pom.xml | 37 +-
settings.gradle | 2 +
361 files changed, 14537 insertions(+), 2564 deletions(-)
delete mode 100644 deliveries/deb/build.sh
rename modules/{storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index => core/src/main/java/org/apache/ignite/internal/util}/CursorUtils.java (90%)
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/IgniteCursor.java
rename modules/{storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/index => core/src/test/java/org/apache/ignite/internal/util}/CursorUtilsTest.java (86%)
rename modules/metrics/src/integrationTest/java/org/apache/ignite/internal/metrics/exporters/{MetricExportersLoadingTest.java => ItMetricExportersLoadingTest.java} (74%)
copy modules/{storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/chm/schema/TestConcurrentHashMapDataStorageConfigurationSchema.java => metrics/src/integrationTest/java/org/apache/ignite/internal/metrics/exporters/TestPullMetricsExporterConfigurationSchema.java} (61%)
copy modules/{storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/chm/schema/TestConcurrentHashMapDataStorageConfigurationSchema.java => metrics/src/integrationTest/java/org/apache/ignite/internal/metrics/exporters/TestPushMetricsExporterConfigurationSchema.java} (61%)
copy modules/{storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/chm/TestConcurrentHashMapStorageEngineDistributedConfigurationModule.java => metrics/src/main/java/org/apache/ignite/internal/metrics/configuration/MetricConfigurationModule.java} (58%)
copy modules/{network/src/test/java/org/apache/ignite/internal/network/NestedMessageMessage.java => metrics/src/main/java/org/apache/ignite/internal/metrics/configuration/MetricConfigurationSchema.java} (56%)
copy modules/{storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/chm/schema/TestConcurrentHashMapDataStorageConfigurationSchema.java => metrics/src/main/java/org/apache/ignite/internal/metrics/exporters/configuration/ExporterConfigurationSchema.java} (54%)
copy modules/{network/src/test/java/org/apache/ignite/internal/network/NestedMessageMessage.java => metrics/src/main/java/org/apache/ignite/internal/metrics/exporters/configuration/JmxExporterConfigurationSchema.java} (64%)
copy modules/{storage-api/src/test/resources/META-INF/services/org.apache.ignite.internal.storage.DataStorageModule => metrics/src/main/resources/META-INF/services/org.apache.ignite.internal.configuration.ConfigurationModule} (76%)
create mode 100644 modules/metrics/src/test/java/org/apache/ignite/internal/metrics/MetricConfigurationTest.java
copy modules/metrics/src/{main/java/org/apache/ignite/internal/metrics/exporters/BasicMetricExporter.java => test/java/org/apache/ignite/internal/metrics/exporters/TestExporter.java} (51%)
copy modules/{network/src/test/java/org/apache/ignite/internal/network/NestedMessageMessage.java => metrics/src/test/java/org/apache/ignite/internal/metrics/exporters/TestExporterConfigurationSchema.java} (62%)
rename modules/network/src/test/java/org/apache/ignite/internal/network/{ => messages}/AllTypesMessage.java (95%)
rename modules/network/src/test/java/org/apache/ignite/internal/network/{processor => messages}/EmptyMessage.java (91%)
rename modules/network/src/test/java/org/apache/ignite/internal/network/{processor => messages}/InheritedMessage.java (91%)
rename modules/network/src/test/java/org/apache/ignite/internal/network/{serialization => messages}/MessageWithMarshallable.java (90%)
rename modules/network/src/test/java/org/apache/ignite/internal/network/{ => messages}/NestedMessageMessage.java (92%)
copy modules/network/src/test/java/org/apache/ignite/internal/network/{processor => messages}/NetworkMessage1.java (94%)
copy modules/network/src/test/java/org/apache/ignite/internal/network/{processor => messages}/NetworkMessage2.java (94%)
copy modules/network/src/test/java/org/apache/ignite/internal/network/{processor => messages}/SerializationOrderMessage.java (91%)
copy modules/network/src/test/java/org/apache/ignite/{network => internal/network/messages}/TestMessage.java (91%)
rename modules/network/src/test/java/org/apache/ignite/{network => internal/network/messages}/TestMessageTypes.java (85%)
rename modules/network/src/{integrationTest => test}/java/org/apache/ignite/internal/network/processor/InMemoryJavaFileManager.java (100%)
rename modules/network/src/{integrationTest/java/org/apache/ignite/internal/network/processor/ItTransferableObjectProcessorIncrementalTest.java => test/java/org/apache/ignite/internal/network/processor/TransferableObjectProcessorIncrementalTest.java} (90%)
rename modules/network/src/{integrationTest/java/org/apache/ignite/internal/network/processor/ItTransferableObjectProcessorTest.java => test/java/org/apache/ignite/internal/network/processor/TransferableObjectProcessorTest.java} (87%)
rename modules/network/src/test/java/org/apache/ignite/network/{ => serialization}/MessageSerializationRegistryImplTest.java (94%)
rename modules/network/src/test/java/org/apache/ignite/network/{ => serialization}/TestMessageSerializationRegistryImpl.java (84%)
rename modules/network/src/{integrationTest => test}/resources/org/apache/ignite/internal/network/processor/AllTypesMessage.java (60%)
rename modules/network/src/{integrationTest => test}/resources/org/apache/ignite/internal/network/processor/ConflictingTypeMessage.java (97%)
copy modules/network/src/{integrationTest => test}/resources/org/apache/ignite/internal/network/processor/InheritedMessageClash.java (100%)
rename modules/network/src/{integrationTest => test}/resources/org/apache/ignite/internal/network/processor/InvalidAnnotatedTypeMessage.java (100%)
rename modules/network/src/{integrationTest => test}/resources/org/apache/ignite/internal/network/processor/InvalidParameterGetterMessage.java (100%)
rename modules/network/src/{integrationTest => test}/resources/org/apache/ignite/internal/network/processor/InvalidReturnTypeGetterMessage.java (100%)
rename modules/network/src/{integrationTest => test}/resources/org/apache/ignite/internal/network/processor/SecondGroup.java (100%)
rename modules/network/src/{integrationTest/resources/org/apache/ignite/internal/network/processor/ItTestMessageGroup.java => test/resources/org/apache/ignite/internal/network/processor/TestMessageGroup.java} (96%)
copy modules/network/src/{integrationTest => test}/resources/org/apache/ignite/internal/network/processor/TransitiveMessage.java (100%)
rename modules/network/src/{integrationTest => test}/resources/org/apache/ignite/internal/network/processor/UnmarshallableTypeMessage.java (100%)
rename modules/network/src/{integrationTest => test}/resources/org/apache/ignite/internal/network/processor/UnmarshallableTypeNonSerializableMessage.java (100%)
copy modules/platforms/cpp/{common/CMakeLists.txt => .clang-format} (60%)
create mode 100644 modules/platforms/cpp/DEVNOTES.md
create mode 100644 modules/platforms/cpp/StyleGuide.md
copy modules/platforms/cpp/{common => client-test}/CMakeLists.txt (67%)
create mode 100644 modules/platforms/cpp/client-test/src/gtest_logger.h
create mode 100644 modules/platforms/cpp/client-test/src/ignite_client_test.cpp
create mode 100644 modules/platforms/cpp/client-test/src/main.cpp
create mode 100644 modules/platforms/cpp/client/CMakeLists.txt
create mode 100644 modules/platforms/cpp/client/include/ignite/ignite_client.h
create mode 100644 modules/platforms/cpp/client/include/ignite/ignite_client_configuration.h
create mode 100644 modules/platforms/cpp/client/include/ignite/ignite_logger.h
create mode 100644 modules/platforms/cpp/client/include/ignite/table/table.h
create mode 100644 modules/platforms/cpp/client/include/ignite/table/tables.h
rename modules/{network/src/test/java/org/apache/ignite/internal/network/processor/NetworkMessage2.java => platforms/cpp/client/src/client_operation.h} (66%)
create mode 100644 modules/platforms/cpp/client/src/cluster_connection.cpp
create mode 100644 modules/platforms/cpp/client/src/cluster_connection.h
create mode 100644 modules/platforms/cpp/client/src/ignite_client.cpp
create mode 100644 modules/platforms/cpp/client/src/ignite_client_impl.h
create mode 100644 modules/platforms/cpp/client/src/node_connection.cpp
create mode 100644 modules/platforms/cpp/client/src/node_connection.h
copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/QueryValidationException.java => platforms/cpp/client/src/protocol_context.h} (53%)
create mode 100644 modules/platforms/cpp/client/src/protocol_version.h
create mode 100644 modules/platforms/cpp/client/src/response_handler.h
copy modules/{network/src/integrationTest/resources/org/apache/ignite/internal/network/processor/InheritedMessageClash.java => platforms/cpp/client/src/table/table.cpp} (66%)
create mode 100644 modules/platforms/cpp/client/src/table/table_impl.h
copy modules/{network/src/integrationTest/resources/org/apache/ignite/internal/network/processor/TransitiveMessage.java => platforms/cpp/client/src/table/tables.cpp} (58%)
create mode 100644 modules/platforms/cpp/client/src/table/tables_impl.cpp
create mode 100644 modules/platforms/cpp/client/src/table/tables_impl.h
rename modules/platforms/cpp/common/{Bits.h => bits.h} (81%)
rename modules/platforms/cpp/common/{Bytes.h => bytes.h} (85%)
copy modules/platforms/cpp/common/{Config.h => config.h} (88%)
rename modules/{network/src/test/java/org/apache/ignite/network/TestMessage.java => platforms/cpp/common/factory.h} (67%)
create mode 100644 modules/platforms/cpp/common/guid.h
create mode 100644 modules/platforms/cpp/common/ignite_error.h
create mode 100644 modules/platforms/cpp/common/ignite_result.h
copy modules/{network/src/test/java/org/apache/ignite/internal/network/processor/SerializationOrderMessage.java => platforms/cpp/common/platform.h} (63%)
rename modules/platforms/cpp/common/{Types.h => types.h} (76%)
rename modules/platforms/cpp/common/{Config.h => utils.h} (51%)
rename modules/platforms/cpp/common/{Uuid.h => uuid.h} (90%)
copy modules/{storage-api/src/test/resources/META-INF/services/org.apache.ignite.internal.storage.DataStorageModule => platforms/cpp/conanfile.txt} (74%)
create mode 100644 modules/platforms/cpp/network/CMakeLists.txt
create mode 100644 modules/platforms/cpp/network/include/ignite/network/async_client_pool.h
create mode 100644 modules/platforms/cpp/network/include/ignite/network/async_handler.h
copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/QueryValidationException.java => platforms/cpp/network/include/ignite/network/codec.h} (51%)
create mode 100644 modules/platforms/cpp/network/include/ignite/network/codec_data_filter.h
create mode 100644 modules/platforms/cpp/network/include/ignite/network/data_buffer.h
create mode 100644 modules/platforms/cpp/network/include/ignite/network/data_filter.h
create mode 100644 modules/platforms/cpp/network/include/ignite/network/data_filter_adapter.h
create mode 100644 modules/platforms/cpp/network/include/ignite/network/data_sink.h
create mode 100644 modules/platforms/cpp/network/include/ignite/network/end_point.h
create mode 100644 modules/platforms/cpp/network/include/ignite/network/length_prefix_codec.h
rename modules/{network/src/test/java/org/apache/ignite/internal/network/processor/NetworkMessage1.java => platforms/cpp/network/include/ignite/network/network.h} (72%)
create mode 100644 modules/platforms/cpp/network/include/ignite/network/tcp_range.h
create mode 100644 modules/platforms/cpp/network/os/linux/src/network/connecting_context.cpp
create mode 100644 modules/platforms/cpp/network/os/linux/src/network/connecting_context.h
create mode 100644 modules/platforms/cpp/network/os/linux/src/network/linux_async_client.cpp
create mode 100644 modules/platforms/cpp/network/os/linux/src/network/linux_async_client.h
create mode 100644 modules/platforms/cpp/network/os/linux/src/network/linux_async_client_pool.cpp
create mode 100644 modules/platforms/cpp/network/os/linux/src/network/linux_async_client_pool.h
create mode 100644 modules/platforms/cpp/network/os/linux/src/network/linux_async_worker_thread.cpp
create mode 100644 modules/platforms/cpp/network/os/linux/src/network/linux_async_worker_thread.h
create mode 100644 modules/platforms/cpp/network/os/linux/src/network/sockets.cpp
create mode 100644 modules/platforms/cpp/network/os/linux/src/network/sockets.h
copy modules/{network/src/integrationTest/resources/org/apache/ignite/internal/network/processor/InheritedMessageClash.java => platforms/cpp/network/os/linux/src/network/utils.cpp} (65%)
create mode 100644 modules/platforms/cpp/network/os/win/src/network/sockets.cpp
create mode 100644 modules/platforms/cpp/network/os/win/src/network/sockets.h
rename modules/platforms/{dotnet/Apache.Ignite/Internal/Common/ThreadLocalRandom.cs => cpp/network/os/win/src/network/utils.cpp} (55%)
create mode 100644 modules/platforms/cpp/network/os/win/src/network/win_async_client.cpp
create mode 100644 modules/platforms/cpp/network/os/win/src/network/win_async_client.h
create mode 100644 modules/platforms/cpp/network/os/win/src/network/win_async_client_pool.cpp
create mode 100644 modules/platforms/cpp/network/os/win/src/network/win_async_client_pool.h
create mode 100644 modules/platforms/cpp/network/os/win/src/network/win_async_connecting_thread.cpp
create mode 100644 modules/platforms/cpp/network/os/win/src/network/win_async_connecting_thread.h
create mode 100644 modules/platforms/cpp/network/os/win/src/network/win_async_worker_thread.cpp
create mode 100644 modules/platforms/cpp/network/os/win/src/network/win_async_worker_thread.h
create mode 100644 modules/platforms/cpp/network/src/network/async_client_pool_adapter.cpp
create mode 100644 modules/platforms/cpp/network/src/network/async_client_pool_adapter.h
create mode 100644 modules/platforms/cpp/network/src/network/codec_data_filter.cpp
create mode 100644 modules/platforms/cpp/network/src/network/error_handling_filter.cpp
create mode 100644 modules/platforms/cpp/network/src/network/error_handling_filter.h
create mode 100644 modules/platforms/cpp/network/src/network/length_prefix_codec.cpp
copy modules/{network/src/integrationTest/resources/org/apache/ignite/internal/network/processor/TransitiveMessage.java => platforms/cpp/network/src/network/network.cpp} (58%)
create mode 100644 modules/platforms/cpp/network/src/network/tcp_range.cpp
create mode 100644 modules/platforms/cpp/network/src/network/utils.h
copy modules/platforms/cpp/{common => protocol}/CMakeLists.txt (63%)
create mode 100644 modules/platforms/cpp/protocol/include/ignite/protocol/buffer_adapter.h
copy modules/{network/src/integrationTest/resources/org/apache/ignite/internal/network/processor/InheritedMessageClash.java => platforms/cpp/protocol/include/ignite/protocol/extension_types.h} (73%)
create mode 100644 modules/platforms/cpp/protocol/include/ignite/protocol/reader.h
create mode 100644 modules/platforms/cpp/protocol/include/ignite/protocol/utils.h
create mode 100644 modules/platforms/cpp/protocol/include/ignite/protocol/writer.h
copy modules/{network/src/integrationTest/resources/org/apache/ignite/internal/network/processor/InheritedMessageClash.java => platforms/cpp/protocol/src/buffer_adapter.cpp} (61%)
create mode 100644 modules/platforms/cpp/protocol/src/reader.cpp
create mode 100644 modules/platforms/cpp/protocol/src/utils.cpp
rename modules/{network/src/integrationTest/resources/org/apache/ignite/internal/network/processor/InheritedMessageClash.java => platforms/cpp/protocol/src/writer.cpp} (53%)
copy modules/platforms/cpp/{common => test-common}/CMakeLists.txt (65%)
create mode 100644 modules/platforms/cpp/test-common/include/cmd_process.h
copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/QueryValidationException.java => platforms/cpp/test-common/include/ignite_runner.h} (52%)
rename modules/{network/src/test/java/org/apache/ignite/internal/network/processor/SerializationOrderMessage.java => platforms/cpp/test-common/include/test_utils.h} (54%)
create mode 100644 modules/platforms/cpp/test-common/src/ignite_runner.cpp
create mode 100644 modules/platforms/cpp/test-common/src/linux/linux_process.h
rename modules/{network/src/integrationTest/resources/org/apache/ignite/internal/network/processor/TransitiveMessage.java => platforms/cpp/test-common/src/process.cpp} (57%)
create mode 100644 modules/platforms/cpp/test-common/src/test_utils.cpp
create mode 100644 modules/platforms/cpp/test-common/src/win/win_process.h
delete mode 100644 modules/platforms/dotnet/Apache.Ignite.Benchmarks/Table/Serialization/ObjectSerializerHandlerOld.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Internal.Generators/JavaToCsharpGeneratorBase.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/Table/PocoAllColumns.cs
create mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/PartitionTimestampCursor.java
copy modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/{HashIndexStorage.java => IndexStorage.java} (58%)
copy modules/storage-api/src/test/java/org/apache/ignite/internal/storage/{ConcurrentHashMapMvTableStorageTest.java => TestMvTableStorageTest.java} (77%)
rename modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/{chm/TestConcurrentHashMapDataStorageModule.java => impl/TestDataStorageModule.java} (81%)
rename modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/{chm/TestConcurrentHashMapMvPartitionStorage.java => impl/TestMvPartitionStorage.java} (76%)
rename modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/{chm/TestConcurrentHashMapMvTableStorage.java => impl/TestMvTableStorage.java} (93%)
rename modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/{chm/TestConcurrentHashMapStorageEngine.java => impl/TestStorageEngine.java} (84%)
rename modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/{chm/TestConcurrentHashMapStorageEngineDistributedConfigurationModule.java => impl/TestStorageEngineDistributedConfigurationModule.java} (75%)
rename modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/{chm/schema/TestConcurrentHashMapDataStorageConfigurationSchema.java => impl/schema/TestDataStorageConfigurationSchema.java} (70%)
rename modules/storage-api/src/{test => testFixtures}/java/org/apache/ignite/internal/storage/index/AbstractSortedIndexStorageTest.java (90%)
rename modules/storage-api/src/{test => testFixtures}/java/org/apache/ignite/internal/storage/index/impl/TestIndexRow.java (91%)
delete mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/util/TreeCursorAdapter.java
create mode 100644 modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/PersistentPageMemoryMvTableStorageTest.java
rename modules/{storage-api/src/test/java/org/apache/ignite/internal/storage/ConcurrentHashMapMvTableStorageTest.java => storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/VolatilePageMemoryMvTableStorageTest.java} (52%)
create mode 100644 packaging/build.gradle
copy {examples => packaging}/config/ignite-config.conf (100%)
create mode 100644 packaging/config/ignite.java.util.logging.properties
copy modules/platforms/cpp/common/CMakeLists.txt => packaging/deb/build.sh (64%)
rename {deliveries => packaging}/deb/changelog (100%)
rename {deliveries => packaging}/deb/control (100%)
rename {deliveries => packaging}/deb/copyright (100%)
rename {deliveries => packaging}/deb/rules (100%)
rename {deliveries => packaging}/rpm/.gitignore (100%)
rename {deliveries => packaging}/rpm/Dockerfile (100%)
rename {deliveries => packaging}/rpm/README.md (100%)
rename {deliveries => packaging}/rpm/apache-ignite.spec (100%)
rename {deliveries => packaging}/rpm/build.sh (52%)
create mode 100644 packaging/scripts/bootstrap-config
create mode 100755 packaging/scripts/ignite3-db.sh