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:23 UTC
[ignite-3] 01/02: Merge branch 'pr-563' into ignite-16244
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(-)