You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2022/01/21 19:01:22 UTC
[ignite-3] branch ignite-16244 updated (8fcad55 -> 7a449cf)
This is an automated email from the ASF dual-hosted git repository.
vkulichenko pushed a change to branch ignite-16244
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 8fcad55 Merge branch 'ignite-3.0.0-alpha4' of github.com:apache/ignite-3 into ignite-16244
add 40841cd IGNITE-16254 - Optimize (un)marshalling of primitives in object fields
add 65ce237 IGNITE-16277 Query failed with assertion (#548)
add 96c0801 IGNITE-16296 Sql. Refactoring of integration with Data layer (#552)
add e3edd29 IGNITE-15257 ITNodeTest.testNodeTaskOverload is flaky (#554)
add e7c86db IGNITE-16309 Fix replicator can recycle bytebuffer before it was sent
add 96e4e7f IGNITE-15359 Add IgniteClientConfiguration.asyncContinuationExecutor (#558)
add c507456 IGNITE-16298 Object identity distinction must be preserved after marshalling+unmarshalling
add 6b67ecc IGNITE-16250 Use direct marshaller and user object serialization for network messaging
add 9464445 IGNITE-16322 fix schema, table and column names (use uppercase for unquoted identifier)
add bb79b08 IGNITE-16322 fix tests
add 0376002 IGNITE-16322 fix class mapper & tuple adapter
add 52bb2ac IGNITE-16322 fix test & mappers
add 335d496 IGNITE-16322 fix test * index builder
add 2521124 IGNITE-16322 fix tables interface
add ec245e8 IGNITE-16322 fix alter table
add ded59ba IGNITE-16295 Getting the actual view in ConfigurationNotificationEvent#oldValue and ConfigurationNotificationEvent#newValue (#551)
add a7d78f9 IGNITE-16240 Support putFields()+writeFields() and readFields() in User Object Serialization
add 783a975 IGNITE-15202 Fixed readCommittedUserLog test to get rid of flakiness. #538
add 4f8f7ae IGNITE-16258 Support Serializable lambdas marshalling in User Object Serialization
add 65b76bd IGNITE-16282 Support (un)marshalling of Proxies in User Object Serialization
add 78e4597 IGNITE-16338 Remove usages of Cluster#isShutdown method (#572)
add a8b1f52 IGNITE-16326 Prepare Documentation for the AI Alpha 4 Release (#570)
add 528543f Merge branch '!main' into ignite-16322
add 2971dbc Fix ItThinClientConnectionTest
add 51a00e2 Merge remote-tracking branch 'gg-ignite-3/ignite-16322' into ignite-16322
add 506f5c2 Remove conversion in ClientColumn, fix tests
add 4321019 fix import
add 5a278f5 fix DDL, wip
add 5d9792d fix drop column
add ef47974 wip
add a046b27 fix test tuple
add 92af559 .NET: Parse quotes and convert names to upper in IgniteTuple
add 84662e0 Fix TestUpsertEmptyTupleThrowsException
add e3260d7 Fix TestGetTables
add 186de01 Fix TableTests
add 7b0c38a Fix IgniteTupleTests
add d1092c8 Merge remote-tracking branch 'gg/ignite-16322' into ignite-16322
add b8887b1 Merge remote-tracking branch 'gg-ignite-3/ignite-16322' into ignite-16322
add 39b82ea fix mapper
add c978168 .NET: TestGetNullOrEmptyNameThrowsException
add f1dd06f .NET: IgniteTupleTests updated
add 9b22c35 Merge remote-tracking branch 'gg/ignite-16322' into ignite-16322
add 153dd99 .NET: cleanup
add 8f4bd10 Merge remote-tracking branch 'gg-ignite-3/ignite-16322' into ignite-16322
add 82165e1 wip
add 907361c wip 2
add f762109 fix test
add 1951669 fix PK definition builder & integration tests
add 53fa831 fix DDL affinity & pk keys
add db2fbaa fix style
add 255319d add mapper tests for quoted column names
new a9ea458 Merge branch 'pr-563' into ignite-16244
add 1728cd1 IGNITE-16286 Fixed error message. Fixes #547
add 87d5132 IGNITE-16285 Fixed converting resource locator to the configuration file. Fixes #550
add 303d076 IGNITE-15352 Thin client: Use varint for decimal scale and IgniteUuid localId (#569)
add 73a2f3c IGNITE-16263 Invoke configuration listeners when components were restored (#568)
add 7355d58 IGNITE-16346 Fix ConfigurationTest#testDirectAsyncContinuationExecutorUsesNettyThread flakiness (#578)
add d87f1e1 IGNITE-16161 Fix memory leak in BaseQueryContext (#553)
new 7a449cf Merge branch 'main' of github.com:apache/ignite-3 into ignite-16244
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/ignite/table/TupleImpl.java | 11 +-
.../apache/ignite/table/mapper/MapperBuilder.java | 19 +-
.../ignite/table/mapper/OneColumnMapperImpl.java | 3 +-
.../internal/client/proto/ClientMessagePacker.java | 55 +-
.../client/proto/ClientMessageUnpacker.java | 20 +-
.../client/proto/ClientMessagePackerTest.java | 16 +
.../client/proto/ClientMessageUnpackerTest.java | 22 +-
modules/client/pom.xml | 6 +
.../org/apache/ignite/client/IgniteClient.java | 31 +-
.../ignite/client/IgniteClientConfiguration.java | 20 +
.../client/IgniteClientConfigurationImpl.java | 28 +-
.../ignite/internal/client/TcpClientChannel.java | 4 +-
.../ignite/internal/client/table/ClientTuple.java | 9 +-
.../apache/ignite/client/AbstractClientTest.java | 4 +-
.../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 +--
.../apache/ignite/client/ConfigurationTest.java | 48 ++
.../org/apache/ignite/client/ConnectionTest.java | 7 +-
.../java/org/apache/ignite/client/CustomTuple.java | 17 +-
.../ignite/client/fakes/FakeIgniteTables.java | 54 +-
.../ignite/client/fakes/FakeSchemaRegistry.java | 6 +
.../ConfigurationNotificationEvent.java | 2 +
.../configuration/ConfigurationChanger.java | 19 +-
.../configuration/ConfigurationRegistry.java | 54 +-
.../configuration/DynamicConfiguration.java | 1 -
.../asm/ConfigurationAsmGenerator.java | 2 +-
.../notifications/ConfigurationContainer.java | 76 ++
.../ConfigurationNotificationContext.java | 85 +++
.../ConfigurationNotificationEventImpl.java | 47 +-
.../ConfigurationNotificationUtils.java | 134 ++++
.../notifications/ConfigurationNotifier.java | 477 ++++++++++++
.../notifications/NamedListChanges.java | 110 +++
.../configuration/util/ConfigurationContainer.java | 50 --
.../util/ConfigurationNotificationsUtil.java | 827 ---------------------
.../configuration/util/ConfigurationUtil.java | 16 +
.../ConfigurationAnyListenerTest.java | 106 ++-
.../notifications/ConfigurationListenerTest.java | 520 ++++++++++---
.../testframework/ConfigurationExtension.java | 14 +-
.../ignite/internal/util/IgniteObjectName.java | 140 ++++
modules/metastorage-client/pom.xml | 6 +
.../serialization/MessageReaderMethodResolver.java | 4 +-
.../RegistryInitializerGenerator.java | 3 +
.../apache/ignite/network/MessagingService.java | 4 +-
...> MessageSerializationRegistryInitializer.java} | 10 +-
modules/network/pom.xml | 6 +
.../network/netty/ItConnectionManagerTest.java | 3 +-
.../network/recovery/ItRecoveryHandshakeTest.java | 6 +-
.../network/scalecube/ItClusterServiceTest.java | 68 ++
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 29 +-
.../ignite/utils/ClusterServiceTestUtils.java | 47 +-
.../stream/DirectByteBufferStreamImplV1.java | 33 +-
.../network/message/ClassDescriptorMessage.java | 13 +-
.../internal/network/message/ScaleCubeMessage.java | 10 +-
.../{BuiltinType.java => BuiltInType.java} | 30 +-
...izedStreamCommands.java => BuiltInTypeIds.java} | 21 +-
.../network/serialization/ClassDescriptor.java | 198 ++++-
.../serialization/ClassDescriptorFactory.java | 63 +-
...ryContext.java => ClassDescriptorRegistry.java} | 39 +-
...ors.java => CompositeIdIndexedDescriptors.java} | 22 +-
.../network/serialization/FieldAccessor.java | 136 +++-
.../network/serialization/FieldAccessorImpl.java | 83 ---
.../network/serialization/FieldDescriptor.java | 35 +-
.../serialization/IdIndexedDescriptors.java | 9 +
.../PerSessionSerializationService.java | 133 ++--
.../internal/network/serialization/Primitives.java | 52 ++
.../network/serialization/Serialization.java | 38 +-
.../{Null.java => SerializationException.java} | 13 +-
.../serialization/SerializationService.java | 102 ++-
.../network/serialization/SerializationType.java | 2 +-
.../SpecialSerializationMethodsImpl.java | 94 ++-
.../network/serialization/UnsafeFieldAccessor.java | 192 +++++
.../UserObjectSerializationContext.java | 53 ++
.../UserObjectSerializationException.java} | 22 +-
.../serialization/UserObjectSerializer.java | 48 --
.../network/serialization/marshal/Bits.java | 103 +++
.../marshal/BuiltInContainerMarshallers.java | 6 +-
.../serialization/marshal/BuiltInMarshalling.java | 70 +-
.../marshal/BuiltInNonContainerMarshallers.java | 5 +-
.../network/serialization/marshal/Classes.java} | 39 +-
.../marshal/DefaultUserObjectMarshaller.java | 187 +++--
.../marshal/ExternalizableMarshaller.java | 26 +-
....java => MarshallingNotSupportedException.java} | 10 +-
.../serialization/marshal/ProxyMarshaller.java | 122 +++
.../marshal/StructuredObjectMarshaller.java | 115 ++-
.../marshal/UnmarshallingContext.java | 8 +-
.../marshal/UosObjectInputStream.java | 131 ++++
.../marshal/UosObjectOutputStream.java | 138 +++-
.../marshal/UserObjectMarshaller.java | 9 +
.../scalecube/ScaleCubeClusterServiceFactory.java | 49 +-
.../ScaleCubeDirectMarshallerTransport.java | 34 +-
.../scalecube/ScaleCubeMessagingService.java | 10 +-
.../internal/network/netty/InboundDecoderTest.java | 8 +-
.../internal/network/netty/NettyServerTest.java | 3 +-
...iptorsTest.java => BuiltInDescriptorsTest.java} | 96 +--
.../serialization/ClassDescriptorFactoryTest.java | 76 +-
.../network/serialization/MarshallableTest.java | 71 +-
.../network/serialization/PrimitivesTest.java | 58 ++
.../network/serialization/marshal/ClassesTest.java | 101 +++
.../marshal/ContextBasedIdIndexedDescriptors.java | 12 +-
.../DefaultUserObjectMarshallerCommonTest.java | 6 +-
...erObjectMarshallerWithArbitraryObjectsTest.java | 304 ++++++--
...efaultUserObjectMarshallerWithBuiltinsTest.java | 122 +--
...UserObjectMarshallerWithExternalizableTest.java | 4 +-
...shallerWithSerializableOverrideStreamsTest.java | 270 ++++++-
...ltUserObjectMarshallerWithSerializableTest.java | 32 +-
.../network/serialization/marshal/IntHolder.java | 29 +
.../marshal/NoArgConstructorInstantiationTest.java | 2 +-
...=> NonSerializableWithoutNoArgConstructor.java} | 4 +-
.../marshal/UnsafeInstantiationTest.java | 4 +-
.../Table/CustomTestIgniteTuple.cs | 6 +-
.../Apache.Ignite.Tests/Table/IgniteTupleTests.cs | 49 +-
.../dotnet/Apache.Ignite.Tests/Table/TableTests.cs | 2 +-
.../Apache.Ignite.Tests/Table/TablesTests.cs | 2 +-
.../Apache.Ignite/Internal/Proto/IgniteUuid.cs | 11 +-
.../Internal/Proto/MessagePackReaderExtensions.cs | 15 +-
.../Internal/Proto/MessagePackWriterExtensions.cs | 4 +-
.../dotnet/Apache.Ignite/Table/IgniteTuple.cs | 21 +-
modules/raft/pom.xml | 6 +
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 21 +-
.../ignite/raft/jraft/core/CliServiceImpl.java | 2 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 12 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 21 +-
.../raft/jraft/entity/LocalFileMetaOutter.java | 6 +-
.../raft/jraft/entity/LocalStorageOutter.java | 12 +-
.../ignite/raft/jraft/entity/RaftOutter.java | 26 +-
.../ignite/raft/jraft/rpc/ActionRequest.java | 5 +-
.../ignite/raft/jraft/rpc/ActionResponse.java | 5 +-
.../apache/ignite/raft/jraft/rpc/CliRequests.java | 70 +-
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 40 +-
.../raft/jraft/rpc/impl/RaftGroupServiceImpl.java | 9 +-
.../ignite/raft/jraft/rpc/AbstractRpcTest.java | 8 +-
modules/runner/pom.xml | 6 +
.../runner/app/AbstractSchemaChangeTest.java | 19 +-
.../internal/runner/app/IgniteCliRunnerTest.java | 6 +-
.../runner/app/ItTableApiContractTest.java | 10 +-
.../app/client/ItAbstractThinClientTest.java | 2 +-
.../sql/engine/ItProjectScanMergeRuleTest.java | 16 +-
.../sql/engine/extension/TestExtension.java | 6 +-
.../sql/engine/extension/TestPhysTableScan.java | 21 +-
.../sql/engine/extension/TestTableImpl.java | 3 +-
...ite.internal.sql.engine.extension.SqlExtension} | 0
.../org/apache/ignite/internal/app/IgniteImpl.java | 25 +-
.../ignite/internal/schema/SchemaRegistry.java | 9 +
.../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 +-
.../schema/registry/SchemaRegistryImpl.java | 6 +
.../schema/registry/UpgradingRowAdapter.java | 8 +
.../org/apache/ignite/internal/schema/row/Row.java | 10 +
.../ignite/internal/schema/row/RowAssembler.java | 16 +-
.../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 +-
modules/sql-engine/pom.xml | 4 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 2 +-
.../sql/engine/exec/LogicalRelImplementor.java | 5 +
.../sql/engine/exec/QueryTaskExecutorImpl.java | 7 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 55 +-
.../internal/sql/engine/exec/rel/AbstractNode.java | 5 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 30 +-
.../sql/engine/exec/rel/TableScanNode.java | 11 +-
.../internal/sql/engine/message/ErrorMessage.java | 4 +-
.../sql/engine/message/QueryBatchMessage.java | 4 +-
.../sql/engine/message/QueryStartRequest.java | 5 +-
.../sql/engine/message/QueryStartResponse.java | 4 +-
.../sql/engine/metadata/RelMetadataQueryEx.java | 30 +-
.../internal/sql/engine/prepare/PlannerHelper.java | 2 +-
.../sql/engine/schema/ColumnDescriptor.java | 6 +-
.../sql/engine/schema/ColumnDescriptorImpl.java | 22 +-
.../sql/engine/schema/IgniteTableImpl.java | 158 +++-
.../sql/engine/schema/InternalIgniteTable.java | 10 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 26 +-
.../sql/engine/schema/TableDescriptorImpl.java | 2 +-
.../ignite/internal/sql/engine/util/TypeUtils.java | 2 +-
.../internal/sql/engine/StopCalciteModuleTest.java | 4 +-
.../sql/engine/planner/AbstractPlannerTest.java | 20 +-
.../index/RocksDbSortedIndexStorageTest.java | 2 +-
modules/table/pom.xml | 6 +
.../internal/table/AbstractRowTupleAdapter.java | 7 +-
.../internal/table/distributed/TableManager.java | 97 ++-
.../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 | 11 +-
.../table/impl/DummySchemaManagerImpl.java | 6 +
.../internal/table/impl/TestTupleBuilder.java | 7 +-
.../org/apache/ignite/table/TupleImplTest.java | 4 +-
.../internal/tx/message/TxFinishRequest.java | 5 +-
.../internal/tx/message/TxFinishResponse.java | 2 +-
parent/pom.xml | 8 +-
206 files changed, 6142 insertions(+), 2765 deletions(-)
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/notifications/ConfigurationContainer.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/notifications/ConfigurationNotificationContext.java
rename modules/configuration/src/main/java/org/apache/ignite/internal/configuration/{util => notifications}/ConfigurationNotificationEventImpl.java (65%)
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/notifications/ConfigurationNotificationUtils.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/notifications/ConfigurationNotifier.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/notifications/NamedListChanges.java
delete mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/util/ConfigurationContainer.java
delete mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/util/ConfigurationNotificationsUtil.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/IgniteObjectName.java
copy modules/network-api/src/main/java/org/apache/ignite/network/serialization/{package-info.java => MessageSerializationRegistryInitializer.java} (80%)
create mode 100644 modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/ItClusterServiceTest.java
rename modules/network/src/main/java/org/apache/ignite/internal/network/serialization/{BuiltinType.java => BuiltInType.java} (86%)
rename modules/network/src/main/java/org/apache/ignite/internal/network/serialization/{SerializedStreamCommands.java => BuiltInTypeIds.java} (61%)
rename modules/network/src/main/java/org/apache/ignite/internal/network/serialization/{ClassDescriptorFactoryContext.java => ClassDescriptorRegistry.java} (81%)
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/{MapBackedIdIndexedDescriptors.java => CompositeIdIndexedDescriptors.java} (58%)
delete mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/FieldAccessorImpl.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/Primitives.java
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/{Null.java => SerializationException.java} (79%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/UnsafeFieldAccessor.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/UserObjectSerializationContext.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkConfigurationException.java => network/src/main/java/org/apache/ignite/internal/network/serialization/UserObjectSerializationException.java} (66%)
delete mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/UserObjectSerializer.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/Bits.java
copy modules/network/src/{test/java/org/apache/ignite/internal/network/serialization/SimpleSerializableObject.java => main/java/org/apache/ignite/internal/network/serialization/marshal/Classes.java} (54%)
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/{MarshalException.java => MarshallingNotSupportedException.java} (74%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/ProxyMarshaller.java
rename modules/network/src/test/java/org/apache/ignite/internal/network/serialization/{DefaultDescriptorsTest.java => BuiltInDescriptorsTest.java} (82%)
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/PrimitivesTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/ClassesTest.java
rename modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/{WithoutNoArgConstructor.java => NonSerializableWithoutNoArgConstructor.java} (89%)
rename modules/runner/src/integrationTest/resources/META-INF/services/{org.apache.ignite.internal.processors.query.calcite.org.apache.ignite.internal.sql.engine.extension.SqlExtension => org.apache.ignite.internal.sql.engine.extension.SqlExtension} (100%)
[ignite-3] 02/02: Merge branch 'main' of github.com:apache/ignite-3 into ignite-16244
Posted by vk...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
vkulichenko pushed a commit to branch ignite-16244
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 7a449cf6fae1d11484036b4813389b61050c27bc
Merge: a9ea458 d87f1e1
Author: Valentin Kulichenko <va...@gmail.com>
AuthorDate: Fri Jan 21 11:00:27 2022 -0800
Merge branch 'main' of github.com:apache/ignite-3 into ignite-16244
.../internal/client/proto/ClientMessagePacker.java | 55 +++-
.../client/proto/ClientMessageUnpacker.java | 20 +-
.../client/proto/ClientMessagePackerTest.java | 16 ++
.../client/proto/ClientMessageUnpackerTest.java | 22 +-
.../apache/ignite/client/ConfigurationTest.java | 5 +-
.../org/apache/ignite/client/ConnectionTest.java | 7 +-
.../ConfigurationNotificationEvent.java | 2 +
.../configuration/ConfigurationChanger.java | 19 +-
.../configuration/ConfigurationRegistry.java | 48 +++-
.../notifications/ConfigurationNotifier.java | 85 +++---
.../notifications/ConfigurationListenerTest.java | 314 +++++++++++++--------
.../Apache.Ignite/Internal/Proto/IgniteUuid.cs | 11 +-
.../Internal/Proto/MessagePackReaderExtensions.cs | 15 +-
.../Internal/Proto/MessagePackWriterExtensions.cs | 4 +-
.../internal/runner/app/IgniteCliRunnerTest.java | 6 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 15 +
.../internal/table/distributed/TableManager.java | 88 +++---
17 files changed, 494 insertions(+), 238 deletions(-)
[ignite-3] 01/02: Merge branch 'pr-563' into ignite-16244
Posted by vk...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
vkulichenko pushed a commit to branch ignite-16244
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit a9ea458c6aaf19712b1ed056b52afa9ec4a2582e
Merge: 8fcad55 255319d
Author: Valentin Kulichenko <va...@gmail.com>
AuthorDate: Fri Jan 21 10:59:07 2022 -0800
Merge branch 'pr-563' into ignite-16244
.../java/org/apache/ignite/table/TupleImpl.java | 11 +-
.../apache/ignite/table/mapper/MapperBuilder.java | 19 +-
.../ignite/table/mapper/OneColumnMapperImpl.java | 3 +-
modules/client/pom.xml | 6 +
.../org/apache/ignite/client/IgniteClient.java | 31 +-
.../ignite/client/IgniteClientConfiguration.java | 20 +
.../client/IgniteClientConfigurationImpl.java | 28 +-
.../ignite/internal/client/TcpClientChannel.java | 4 +-
.../ignite/internal/client/table/ClientTuple.java | 9 +-
.../apache/ignite/client/AbstractClientTest.java | 4 +-
.../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 +--
.../apache/ignite/client/ConfigurationTest.java | 45 ++
.../java/org/apache/ignite/client/CustomTuple.java | 17 +-
.../ignite/client/fakes/FakeIgniteTables.java | 54 +-
.../ignite/client/fakes/FakeSchemaRegistry.java | 6 +
.../configuration/ConfigurationRegistry.java | 8 +-
.../configuration/DynamicConfiguration.java | 1 -
.../asm/ConfigurationAsmGenerator.java | 2 +-
.../notifications/ConfigurationContainer.java | 76 ++
.../ConfigurationNotificationContext.java | 85 +++
.../ConfigurationNotificationEventImpl.java | 47 +-
.../ConfigurationNotificationUtils.java | 134 ++++
.../notifications/ConfigurationNotifier.java | 462 ++++++++++++
.../notifications/NamedListChanges.java | 110 +++
.../configuration/util/ConfigurationContainer.java | 50 --
.../util/ConfigurationNotificationsUtil.java | 827 ---------------------
.../configuration/util/ConfigurationUtil.java | 16 +
.../ConfigurationAnyListenerTest.java | 106 ++-
.../notifications/ConfigurationListenerTest.java | 248 ++++++
.../testframework/ConfigurationExtension.java | 14 +-
.../ignite/internal/util/IgniteObjectName.java | 140 ++++
modules/metastorage-client/pom.xml | 6 +
.../serialization/MessageReaderMethodResolver.java | 4 +-
.../RegistryInitializerGenerator.java | 3 +
.../apache/ignite/network/MessagingService.java | 4 +-
.../MessageSerializationRegistryInitializer.java} | 13 +-
modules/network/pom.xml | 6 +
.../network/netty/ItConnectionManagerTest.java | 3 +-
.../network/recovery/ItRecoveryHandshakeTest.java | 6 +-
.../network/scalecube/ItClusterServiceTest.java | 68 ++
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 29 +-
.../ignite/utils/ClusterServiceTestUtils.java | 47 +-
.../stream/DirectByteBufferStreamImplV1.java | 33 +-
.../network/message/ClassDescriptorMessage.java | 13 +-
.../internal/network/message/ScaleCubeMessage.java | 10 +-
.../{BuiltinType.java => BuiltInType.java} | 30 +-
.../{FieldAccessor.java => BuiltInTypeIds.java} | 28 +-
.../network/serialization/ClassDescriptor.java | 198 ++++-
.../serialization/ClassDescriptorFactory.java | 63 +-
...ryContext.java => ClassDescriptorRegistry.java} | 39 +-
...ors.java => CompositeIdIndexedDescriptors.java} | 38 +-
.../network/serialization/FieldAccessor.java | 136 +++-
.../network/serialization/FieldAccessorImpl.java | 83 ---
.../network/serialization/FieldDescriptor.java | 35 +-
.../serialization/IdIndexedDescriptors.java | 9 +
.../PerSessionSerializationService.java | 133 ++--
.../internal/network/serialization/Primitives.java | 52 ++
.../network/serialization/Serialization.java | 38 +-
...amCommands.java => SerializationException.java} | 15 +-
.../serialization/SerializationService.java | 102 ++-
.../network/serialization/SerializationType.java | 2 +-
.../SpecialSerializationMethodsImpl.java | 94 ++-
.../network/serialization/UnsafeFieldAccessor.java | 192 +++++
.../UserObjectSerializationContext.java | 53 ++
....java => UserObjectSerializationException.java} | 25 +-
.../serialization/UserObjectSerializer.java | 48 --
.../network/serialization/marshal/Bits.java | 103 +++
.../marshal/BuiltInContainerMarshallers.java | 6 +-
.../serialization/marshal/BuiltInMarshalling.java | 70 +-
.../marshal/BuiltInNonContainerMarshallers.java | 5 +-
.../network/serialization/marshal/Classes.java} | 34 +-
.../marshal/DefaultUserObjectMarshaller.java | 187 +++--
.../marshal/ExternalizableMarshaller.java | 26 +-
.../marshal/MarshallingNotSupportedException.java} | 12 +-
.../serialization/marshal/ProxyMarshaller.java | 122 +++
.../marshal/StructuredObjectMarshaller.java | 115 ++-
.../marshal/UnmarshallingContext.java | 8 +-
.../marshal/UosObjectInputStream.java | 131 ++++
.../marshal/UosObjectOutputStream.java | 138 +++-
.../marshal/UserObjectMarshaller.java | 9 +
.../scalecube/ScaleCubeClusterServiceFactory.java | 49 +-
.../ScaleCubeDirectMarshallerTransport.java | 34 +-
.../scalecube/ScaleCubeMessagingService.java | 10 +-
.../internal/network/netty/InboundDecoderTest.java | 8 +-
.../internal/network/netty/NettyServerTest.java | 3 +-
...iptorsTest.java => BuiltInDescriptorsTest.java} | 96 +--
.../serialization/ClassDescriptorFactoryTest.java | 76 +-
.../network/serialization/MarshallableTest.java | 71 +-
.../network/serialization/PrimitivesTest.java | 58 ++
.../network/serialization/marshal/ClassesTest.java | 101 +++
.../marshal/ContextBasedIdIndexedDescriptors.java | 12 +-
.../DefaultUserObjectMarshallerCommonTest.java | 6 +-
...erObjectMarshallerWithArbitraryObjectsTest.java | 304 ++++++--
...efaultUserObjectMarshallerWithBuiltinsTest.java | 122 +--
...UserObjectMarshallerWithExternalizableTest.java | 4 +-
...shallerWithSerializableOverrideStreamsTest.java | 270 ++++++-
...ltUserObjectMarshallerWithSerializableTest.java | 32 +-
.../network/serialization/marshal/IntHolder.java | 29 +
.../marshal/NoArgConstructorInstantiationTest.java | 2 +-
...=> NonSerializableWithoutNoArgConstructor.java} | 4 +-
.../marshal/UnsafeInstantiationTest.java | 4 +-
.../Table/CustomTestIgniteTuple.cs | 6 +-
.../Apache.Ignite.Tests/Table/IgniteTupleTests.cs | 49 +-
.../dotnet/Apache.Ignite.Tests/Table/TableTests.cs | 2 +-
.../Apache.Ignite.Tests/Table/TablesTests.cs | 2 +-
.../dotnet/Apache.Ignite/Table/IgniteTuple.cs | 21 +-
modules/raft/pom.xml | 6 +
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 21 +-
.../ignite/raft/jraft/core/CliServiceImpl.java | 2 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 12 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 21 +-
.../raft/jraft/entity/LocalFileMetaOutter.java | 6 +-
.../raft/jraft/entity/LocalStorageOutter.java | 12 +-
.../ignite/raft/jraft/entity/RaftOutter.java | 26 +-
.../ignite/raft/jraft/rpc/ActionRequest.java | 5 +-
.../ignite/raft/jraft/rpc/ActionResponse.java | 5 +-
.../apache/ignite/raft/jraft/rpc/CliRequests.java | 70 +-
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 40 +-
.../raft/jraft/rpc/impl/RaftGroupServiceImpl.java | 9 +-
.../ignite/raft/jraft/rpc/AbstractRpcTest.java | 8 +-
modules/runner/pom.xml | 6 +
.../runner/app/AbstractSchemaChangeTest.java | 19 +-
.../runner/app/ItTableApiContractTest.java | 10 +-
.../app/client/ItAbstractThinClientTest.java | 2 +-
.../sql/engine/ItProjectScanMergeRuleTest.java | 16 +-
.../sql/engine/extension/TestExtension.java | 6 +-
.../sql/engine/extension/TestPhysTableScan.java | 21 +-
.../sql/engine/extension/TestTableImpl.java | 3 +-
...ite.internal.sql.engine.extension.SqlExtension} | 0
.../org/apache/ignite/internal/app/IgniteImpl.java | 10 +-
.../ignite/internal/schema/SchemaRegistry.java | 9 +
.../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 +-
.../schema/registry/SchemaRegistryImpl.java | 6 +
.../schema/registry/UpgradingRowAdapter.java | 8 +
.../org/apache/ignite/internal/schema/row/Row.java | 10 +
.../ignite/internal/schema/row/RowAssembler.java | 16 +-
.../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 +-
modules/sql-engine/pom.xml | 4 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 2 +-
.../sql/engine/exec/LogicalRelImplementor.java | 5 +
.../sql/engine/exec/QueryTaskExecutorImpl.java | 7 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 55 +-
.../internal/sql/engine/exec/rel/AbstractNode.java | 5 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 30 +-
.../sql/engine/exec/rel/TableScanNode.java | 11 +-
.../internal/sql/engine/message/ErrorMessage.java | 4 +-
.../sql/engine/message/QueryBatchMessage.java | 4 +-
.../sql/engine/message/QueryStartRequest.java | 5 +-
.../sql/engine/message/QueryStartResponse.java | 4 +-
.../sql/engine/metadata/RelMetadataQueryEx.java | 30 +-
.../internal/sql/engine/prepare/PlannerHelper.java | 2 +-
.../sql/engine/schema/ColumnDescriptor.java | 6 +-
.../sql/engine/schema/ColumnDescriptorImpl.java | 22 +-
.../sql/engine/schema/IgniteTableImpl.java | 158 +++-
.../sql/engine/schema/InternalIgniteTable.java | 10 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 26 +-
.../sql/engine/schema/TableDescriptorImpl.java | 2 +-
.../ignite/internal/sql/engine/util/TypeUtils.java | 2 +-
.../internal/sql/engine/StopCalciteModuleTest.java | 4 +-
.../sql/engine/planner/AbstractPlannerTest.java | 20 +-
.../index/RocksDbSortedIndexStorageTest.java | 2 +-
modules/table/pom.xml | 6 +
.../internal/table/AbstractRowTupleAdapter.java | 7 +-
.../internal/table/distributed/TableManager.java | 9 +-
.../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 | 11 +-
.../table/impl/DummySchemaManagerImpl.java | 6 +
.../internal/table/impl/TestTupleBuilder.java | 7 +-
.../org/apache/ignite/table/TupleImplTest.java | 4 +-
.../internal/tx/message/TxFinishRequest.java | 5 +-
.../internal/tx/message/TxFinishResponse.java | 2 +-
parent/pom.xml | 8 +-
195 files changed, 5711 insertions(+), 2608 deletions(-)