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/01/26 15:57:57 UTC
[ignite-3] branch ignite-15212 updated (4a9b104 -> 50d019e)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15212
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 4a9b104 Merge branch 'main' into ignite-15212
add 807c0ec IGNITE-16227 .NET: Thin 3.0: Add RecordView with POCO mapping (#577)
add f6cae43 IGNITE-16102 Store all partitions in a single column family (#562)
add eccf157 IGNITE-16257 Implement readUnshared()/writeUnshared() for User Object Serialization
add 1136501 IGNITE-16332 Replace Scalecube-based MessagingService
add 028b685 IGNITE-16322 Fix database objects names case inconsisten between SQL and KV API (#563)
add 7746d49 IGNITE-16381 Fix ItNoThreadsLeftTest (#586)
add 8db3c70 IGNITE-16244 - Updated examples based on latest changes (#588)
add 0e2cd84 IGNITE-16382 .NET: Speed up tests by reusing server node (#587)
add 8b342cb IGNITE-16358 Add storage revision listeners in configuration (#583)
add 6fb23bf IGNITE-16378 Fix stale TODOs
add 1eff57b IGNITE-16388 Fix stale TODOs in network module (#590)
add f51281b IGNITE-15705 Implemented election timeout auto-adjusting mechanism. Fixes #481
add e6ea8da IGNITE-16020 Added design doc for rebalance. Fixes #571
add 50d019e Merge branch 'main' into ignite-15212
No new revisions were added by this update.
Summary of changes:
.../ignite/example/rebalance/RebalanceExample.java | 181 +++---
.../ignite/example/sql/jdbc/SqlJdbcExample.java | 334 ++++------
.../ignite/example/table/KeyValueViewExample.java | 146 ++---
.../example/table/KeyValueViewPojoExample.java | 172 ++++++
.../ignite/example/table/RecordViewExample.java | 146 ++---
.../example/table/RecordViewPojoExample.java | 163 +++++
.../ignite/example/tx/TransactionsExample.java | 184 ++++++
.../ignite/example/table/TableExamplesTest.java | 28 +
.../TransactionsExamplesTest.java} | 33 +-
.../network/NetworkConfigurationSchema.java | 17 +
.../main/java/org/apache/ignite/table/Tuple.java | 62 +-
.../java/org/apache/ignite/table/TupleImpl.java | 11 +-
.../apache/ignite/table/manager/IgniteTables.java | 32 +-
.../apache/ignite/table/mapper/MapperBuilder.java | 40 +-
.../ignite/table/mapper/OneColumnMapperImpl.java | 3 +-
.../ignite/internal/client/table/ClientTuple.java | 9 +-
.../client/ClientKeyValueBinaryViewTest.java | 2 +-
.../ignite/client/ClientKeyValueViewTest.java | 4 +-
.../apache/ignite/client/ClientRecordViewTest.java | 4 +-
.../org/apache/ignite/client/ClientTableTest.java | 8 +-
.../org/apache/ignite/client/ClientTupleTest.java | 90 +--
.../java/org/apache/ignite/client/CustomTuple.java | 17 +-
.../ignite/client/fakes/FakeIgniteTables.java | 54 +-
.../configuration/ConfigurationProperty.java | 4 +-
.../notifications/ConfigurationListener.java | 3 +-
.../ConfigurationNamedListListener.java | 17 +-
.../ConfigurationNotificationEvent.java | 7 -
.../configuration/ConfigurationChanger.java | 2 +-
.../configuration/ConfigurationRegistry.java | 51 ++
.../ConfigurationStorageRevisionListener.java} | 15 +-
.../notifications/ConfigurationListenerTest.java | 169 +++--
.../ConfigurationListenerTestUtils.java | 52 +-
.../org/apache/ignite/internal/util/ByteUtils.java | 14 +-
.../ignite/internal/util/IgniteObjectName.java | 137 ++++
.../internal/metastorage/MetaStorageManager.java | 8 -
.../apache/ignite/network/MessagingService.java | 10 +-
.../org/apache/ignite/network/NetworkAddress.java | 33 +-
.../ignite/network/NetworkMessageHandler.java | 7 +-
.../org/apache/ignite/network/TopologyService.java | 12 +-
.../network/netty/ItConnectionManagerTest.java | 8 +-
.../network/recovery/ItRecoveryHandshakeTest.java | 26 +-
.../network/scalecube/ItClusterServiceTest.java | 3 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 18 +-
.../internal/network/NetworkMessageTypes.java | 22 +-
.../network/handshake/HandshakeManager.java | 6 +-
.../network/handshake/HandshakeResult.java | 67 ++
.../network/message/FieldDescriptorMessage.java | 5 +
.../internal/network/message/InvokeRequest.java} | 22 +-
.../internal/network/message/InvokeResponse.java} | 22 +-
.../internal/network/netty/ConnectionManager.java | 29 +-
.../internal/network/netty/HandshakeHandler.java | 29 +-
.../internal/network/netty/MessageHandler.java | 13 +-
.../ignite/internal/network/netty/NettyClient.java | 7 +-
.../ignite/internal/network/netty/NettyServer.java | 8 +-
.../recovery/RecoveryClientHandshakeManager.java | 23 +-
.../recovery/RecoveryServerHandshakeManager.java | 21 +-
.../network/serialization/ClassDescriptor.java | 22 +-
.../serialization/ClassDescriptorFactory.java | 67 +-
.../serialization/{marshal => }/Classes.java | 31 +-
.../network/serialization/FieldDescriptor.java | 33 +-
.../PerSessionSerializationService.java | 8 +-
.../marshal/DefaultUserObjectMarshaller.java | 122 ++--
.../marshal/ExternalizableMarshaller.java | 17 +-
.../serialization/marshal/FlaggedObjectIds.java | 51 ++
.../serialization/marshal/MarshallingContext.java | 47 +-
.../marshal/StructuredObjectMarshaller.java | 15 +-
.../marshal/UnmarshallingContext.java | 15 +-
.../marshal/UosObjectInputStream.java | 25 +-
.../marshal/UosObjectOutputStream.java | 26 +-
.../ignite/network/DefaultMessagingService.java | 348 +++++++++++
.../ignite/network/NettyBootstrapFactory.java | 12 +-
.../scalecube/DelegatingTransportFactory.java | 130 ----
.../scalecube/ScaleCubeClusterServiceFactory.java | 58 +-
.../ScaleCubeDirectMarshallerTransport.java | 4 +-
.../scalecube/ScaleCubeMessagingService.java | 160 -----
.../scalecube/ScaleCubeTopologyService.java | 21 +-
.../internal/network/netty/NettyClientTest.java | 14 +-
.../internal/network/netty/NettyServerTest.java | 9 +-
.../serialization/ClassDescriptorFactoryTest.java | 125 ++++
.../serialization/{marshal => }/ClassesTest.java | 33 +-
...shallerWithSerializableOverrideStreamsTest.java | 159 ++++-
...ltUserObjectMarshallerWithSerializableTest.java | 44 ++
.../marshal/FlaggedObjectIdsTest.java | 74 +++
.../marshal/MarshallingContextTest.java | 49 +-
.../network/serialization/marshal/Throwables.java | 8 +
.../MessageSerializationRegistryImplTest.java | 2 +-
.../Table/TupleGetBenchmarks.cs | 2 +-
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 34 +-
.../dotnet/Apache.Ignite.Tests/JavaServer.cs | 1 +
.../RawSocketConnectionTests.cs | 2 +-
.../Table/CustomTestIgniteTuple.cs | 6 +-
.../Apache.Ignite.Tests/Table/IgniteTupleTests.cs | 49 +-
.../Table/Poco.cs} | 19 +-
.../{TableTests.cs => RecordViewBinaryTests.cs} | 210 +++----
.../Table/RecordViewPocoTests.cs | 523 ++++++++++++++++
.../Apache.Ignite.Tests/Table/TablesTests.cs | 2 +-
.../Transactions/TransactionsTests.cs | 72 +--
.../Internal/Table/RecordBinaryView.cs | 688 ---------------------
.../Apache.Ignite/Internal/Table/RecordView.cs | 303 +++++++++
.../Serialization/IRecordSerializerHandler.cs | 57 ++
.../Table/Serialization/ObjectSerializerHandler.cs | 149 +++++
.../Table/Serialization/RecordSerializer.cs | 241 ++++++++
.../Table/Serialization/TupleSerializerHandler.cs | 118 ++++
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 227 ++++++-
.../dotnet/Apache.Ignite/Internal/Table/Tables.cs | 2 +-
.../TransactionExtensions.cs} | 35 +-
.../dotnet/Apache.Ignite/Table/IRecordView.cs | 2 +-
.../platforms/dotnet/Apache.Ignite/Table/ITable.cs | 12 +-
.../dotnet/Apache.Ignite/Table/IgniteTuple.cs | 21 +-
modules/platforms/dotnet/DEVNOTES.md | 3 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 141 +++--
.../java/org/apache/ignite/internal/raft/Loza.java | 16 +-
.../internal/raft/server/impl/JraftServerImpl.java | 17 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 57 ++
.../ignite/raft/jraft/option/NodeOptions.java | 13 +
.../ignite/raft/jraft/rpc/RpcResponseFactory.java | 2 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 11 +-
.../raft/jraft/rpc/impl/RaftGroupServiceImpl.java | 26 +-
.../util/ExponentialBackoffTimeoutStrategy.java | 79 +++
.../raft/jraft/util/NoopTimeoutStrategy.java} | 13 +-
.../ignite/raft/jraft/util/TimeoutStrategy.java} | 16 +-
.../org/apache/ignite/raft/jraft/util/Utils.java | 2 +-
.../internal/raft/server/impl/RaftServerImpl.java | 10 +-
.../apache/ignite/raft/jraft/core/TestCluster.java | 3 +
.../ExponentialBackoffTimeoutStrategyTest.java | 54 ++
.../ignite/internal/rocksdb/ColumnFamily.java | 11 +
.../runner/app/AbstractSchemaChangeTest.java | 19 +-
.../internal/runner/app/ItNoThreadsLeftTest.java | 1 +
.../runner/app/ItTableApiContractTest.java | 10 +-
.../app/client/ItAbstractThinClientTest.java | 2 +-
.../definition/builder/AbstractIndexBuilder.java | 3 +-
.../builder/ColumnDefinitionBuilderImpl.java | 3 +-
.../builder/HashIndexDefinitionBuilderImpl.java | 9 +-
.../builder/PrimaryKeyDefinitionBuilderImpl.java | 17 +-
.../builder/SortedIndexDefinitionBuilderImpl.java | 3 +-
.../builder/TableDefinitionBuilderImpl.java | 7 +-
.../marshaller/asm/AsmMarshallerGenerator.java | 2 +-
.../marshaller/asm/ColumnAccessCodeGenerator.java | 63 +-
.../asm/ObjectMarshallerCodeGenerator.java | 22 +-
.../builder/HashIndexDefinitionBuilderTest.java | 2 +-
.../SchemaConfigurationConverterTest.java | 2 +-
.../schema/marshaller/KvMarshallerTest.java | 126 ++--
.../internal/schema/marshaller/MapperTest.java | 115 ++--
.../schema/marshaller/RecordMarshallerTest.java | 94 +--
.../RecordMarshallerValidationsTest.java | 20 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 51 +-
.../sql/engine/message/MessageServiceImpl.java | 3 +-
.../storage/AbstractPartitionStorageTest.java | 13 +-
.../storage/rocksdb/ColumnFamilyUtils.java | 34 +-
.../storage/rocksdb/RocksDbMetaStorage.java | 138 +++++
.../storage/rocksdb/RocksDbPartitionStorage.java | 174 ++++--
.../storage/rocksdb/RocksDbTableStorage.java | 105 ++--
...eTest.java => RocksDbPartitionStorageTest.java} | 10 +-
.../storage/rocksdb/RocksDbTableStorageTest.java | 202 ++++++
.../index/RocksDbSortedIndexStorageTest.java | 2 +-
.../internal/table/AbstractRowTupleAdapter.java | 7 +-
.../internal/table/distributed/TableManager.java | 28 +-
.../internal/table/InteropOperationsTest.java | 4 +-
.../table/KeyValueBinaryViewOperationsTest.java | 57 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 4 +-
.../internal/table/KeyValueViewOperationsTest.java | 56 +-
.../internal/table/MutableRowTupleAdapterTest.java | 48 +-
.../table/RecordBinaryViewOperationsTest.java | 48 +-
.../internal/table/RecordViewOperationsTest.java | 54 +-
.../ignite/internal/table/TxAbstractTest.java | 8 +-
.../internal/table/impl/TestTupleBuilder.java | 7 +-
.../org/apache/ignite/table/TupleImplTest.java | 4 +-
modules/table/tech-notes/rebalance.md | 199 ++++++
.../ignite/internal/tx/impl/TxManagerImpl.java | 5 +-
169 files changed, 6498 insertions(+), 2871 deletions(-)
create mode 100644 examples/src/main/java/org/apache/ignite/example/table/KeyValueViewPojoExample.java
create mode 100644 examples/src/main/java/org/apache/ignite/example/table/RecordViewPojoExample.java
create mode 100644 examples/src/main/java/org/apache/ignite/example/tx/TransactionsExample.java
copy examples/src/test/java/org/apache/ignite/example/{table/TableExamplesTest.java => tx/TransactionsExamplesTest.java} (69%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationListener.java => configuration/src/main/java/org/apache/ignite/internal/configuration/notifications/ConfigurationStorageRevisionListener.java} (67%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/IgniteObjectName.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/handshake/HandshakeResult.java
copy modules/network/src/{test/java/org/apache/ignite/internal/network/processor/SerializationOrderMessage.java => main/java/org/apache/ignite/internal/network/message/InvokeRequest.java} (66%)
copy modules/network/src/{test/java/org/apache/ignite/internal/network/processor/SerializationOrderMessage.java => main/java/org/apache/ignite/internal/network/message/InvokeResponse.java} (66%)
rename modules/network/src/main/java/org/apache/ignite/internal/network/serialization/{marshal => }/Classes.java (58%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/FlaggedObjectIds.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/DefaultMessagingService.java
delete mode 100644 modules/network/src/main/java/org/apache/ignite/network/scalecube/DelegatingTransportFactory.java
delete mode 100644 modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessagingService.java
rename modules/network/src/test/java/org/apache/ignite/internal/network/serialization/{marshal => }/ClassesTest.java (75%)
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/FlaggedObjectIdsTest.java
copy modules/platforms/dotnet/{Apache.Ignite/Internal/Proto/ProtoCommon.cs => Apache.Ignite.Tests/Table/Poco.cs} (75%)
rename modules/platforms/dotnet/Apache.Ignite.Tests/Table/{TableTests.cs => RecordViewBinaryTests.cs} (57%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/Table/RecordViewPocoTests.cs
delete mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/RecordBinaryView.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/RecordView.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/IRecordSerializerHandler.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/ObjectSerializerHandler.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/RecordSerializer.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/TupleSerializerHandler.cs
copy modules/platforms/dotnet/Apache.Ignite/Internal/{Proto/MessagePackUtil.cs => Transactions/TransactionExtensions.cs} (53%)
create mode 100644 modules/raft/src/main/java/org/apache/ignite/raft/jraft/util/ExponentialBackoffTimeoutStrategy.java
copy modules/{network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/EnumWithAnonClassesForMembers.java => raft/src/main/java/org/apache/ignite/raft/jraft/util/NoopTimeoutStrategy.java} (79%)
copy modules/{api/src/main/java/org/apache/ignite/binary/BinaryObject.java => raft/src/main/java/org/apache/ignite/raft/jraft/util/TimeoutStrategy.java} (72%)
create mode 100644 modules/raft/src/test/java/org/apache/ignite/raft/jraft/util/ExponentialBackoffTimeoutStrategyTest.java
create mode 100644 modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/RocksDbMetaStorage.java
rename modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/{RocksDbStorageTest.java => RocksDbPartitionStorageTest.java} (91%)
create mode 100644 modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/RocksDbTableStorageTest.java
create mode 100644 modules/table/tech-notes/rebalance.md