This is an automated email from the ASF dual-hosted git repository.
agoncharuk pushed a commit to branch ignite-14393
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit f6ac843ccf1de28c923aa6333d505ac577c8d900
Merge: 2687266 15166f8
Author: Alexey Goncharuk <alexey.goncha...@gmail.com>
AuthorDate: Mon Apr 5 13:07:46 2021 +0300
Merge branch 'main' of https://gitbox.apache.org/repos/asf/ignite-3 into
ignite-14393
assembly/NOTICE | 0
assembly/README | 0
assembly/assembly.xml | 50 +++
check-rules/checkstyle-rules.xml | 11 +-
modules/README.md | 7 +-
modules/api/pom.xml | 38 +-
.../org/apache/ignite/binary/BinaryObject.java} | 12 +-
.../java/org/apache/ignite/lang/IgniteFuture.java} | 14 +-
.../org/apache/ignite/table/InvocationContext.java | 68 +++
.../org/apache/ignite/table/InvokeProcessor.java | 47 +++
.../ignite/table/InvokeProcessorException.java} | 9 +-
.../apache/ignite/table/KeyValueBinaryView.java} | 15 +-
.../java/org/apache/ignite/table/KeyValueView.java | 349 ++++++++++++++++
.../java/org/apache/ignite/table/RecordView.java | 42 ++
.../main/java/org/apache/ignite/table/Table.java | 92 +++++
.../java/org/apache/ignite/table/TableView.java | 309 ++++++++++++++
.../main/java/org/apache/ignite/table/Tuple.java | 100 +++++
.../org/apache/ignite/table/TupleBuilder.java} | 21 +-
.../org/apache/ignite/table/mapper/KeyMapper.java} | 8 +-
.../org/apache/ignite/table/mapper/Mappers.java} | 37 +-
.../apache/ignite/table/mapper/RecordMapper.java} | 20 +-
.../apache/ignite/table/mapper/ValueMapper.java} | 22 +-
.../org/apache/ignite/table}/package-info.java | 5 +-
.../presto/bytecode/DynamicClassLoader.java | 9 -
.../expression/ConstantBytecodeExpression.java | 2 +-
modules/cli-common/README.md | 5 +
modules/cli/README.md | 32 ++
modules/configuration-annotation-processor/pom.xml | 12 -
.../processor/internal/Processor.java | 31 +-
.../configuration/processor/internal/Utils.java | 109 +----
.../storage => }/ConfigurationChangerTest.java | 28 +-
.../internal/util/ConfigurationUtilTest.java | 82 +++-
.../internal/validation/ValidationUtilTest.java | 2 +-
.../notifications/ConfigurationListenerTest.java | 245 +++++++++++
.../sample/LocalConfigurationSchema.java | 2 +-
.../sample/NetworkConfigurationSchema.java | 2 +-
.../ignite/configuration/sample/UsageTest.java | 16 +-
.../storage/TestConfigurationStorage.java | 25 +-
modules/configuration/pom.xml | 13 -
.../ignite/configuration/ConfigurationChanger.java | 209 ++++++----
.../configuration/ConfigurationProperty.java | 14 +-
.../configuration/ConfigurationRegistry.java | 59 ++-
.../ignite/configuration/ConfigurationTree.java | 4 +-
.../ignite/configuration/ConfigurationValue.java | 6 +-
.../configuration/NamedConfigurationTree.java | 9 +-
.../ignite/configuration/PropertyListener.java | 61 ---
.../configuration/internal/ConfigurationNode.java | 19 +-
.../internal/DynamicConfiguration.java | 9 +-
.../configuration/internal/DynamicProperty.java | 16 +-
.../internal/NamedListConfiguration.java | 25 +-
.../ConfigurationNotificationEventImpl.java} | 41 +-
.../util/ConfigurationNotificationsUtil.java | 184 +++++++++
.../internal/util/ConfigurationUtil.java | 42 ++
.../ConfigurationListener.java} | 28 +-
.../ConfigurationNamedListListener.java} | 37 +-
.../ConfigurationNotificationEvent.java} | 45 +-
.../storage/ConfigurationStorage.java | 16 +-
.../storage/ConfigurationStorageListener.java | 1 +
.../apache/ignite/configuration/storage/Data.java | 22 +-
.../ignite/configuration/tree/NamedListNode.java | 5 +
.../ignite/configuration/tree/NamedListView.java | 5 +
modules/{configuration => core}/pom.xml | 36 +-
.../java/org/apache/ignite/lang/IgniteUuid.java | 135 ++++++
.../apache/ignite/lang/IgniteUuidGenerator.java | 84 ++++
.../java/org/apache/ignite/lang/LogWrapper.java | 80 ++++
modules/metastorage-client/pom.xml | 42 ++
.../metastorage/client/MetaStorageService.java | 345 ++++++++++++++++
.../ignite/metastorage/client}/package-info.java | 5 +-
modules/metastorage-common/pom.xml | 47 +++
.../metastorage/common/CompactedException.java | 59 +++
.../ignite/metastorage/common/Condition.java | 356 ++++++++++++++++
.../ignite/metastorage/common/Conditions.java} | 46 +--
.../apache/ignite/metastorage/common/Cursor.java} | 14 +-
.../apache/ignite/metastorage/common/Entry.java} | 39 +-
.../org/apache/ignite/metastorage/common/Key.java | 80 ++++
.../ignite/metastorage/common/Operation.java | 84 ++++
.../common/OperationTimeoutException.java | 59 +++
.../ignite/metastorage/common/Operations.java | 64 +++
.../ignite/metastorage/common/WatchEvent.java} | 47 +--
.../ignite/metastorage/common/WatchListener.java} | 35 +-
.../ignite/metastorage/common}/package-info.java | 5 +-
modules/network/pom.xml | 12 -
.../ITScaleCubeNetworkClusterMessagingTest.java | 107 ++++-
.../ignite/network/scalecube/TestMessage.java | 16 +-
.../scalecube/TestMessageMapperProvider.java | 54 +++
.../scalecube/TestNetworkHandlersProvider.java | 4 +-
.../ignite/network/scalecube/TestRequest.java} | 30 +-
.../scalecube/TestRequestMapperProvider.java | 54 +++
.../ignite/network/scalecube/TestResponse.java} | 35 +-
.../scalecube/TestResponseMapperProvider.java | 54 +++
.../java/org/apache/ignite/network/Network.java | 66 +++
.../org/apache/ignite/network/NetworkCluster.java | 24 +-
.../ignite/network/NetworkClusterContext.java | 57 +++
.../ignite/network/NetworkClusterFactory.java | 56 +--
...ler.java => NetworkConfigurationException.java} | 21 +-
...rkMessageHandler.java => NetworkException.java} | 22 +-
.../org/apache/ignite/network/NetworkMember.java | 3 +-
.../org/apache/ignite/network/NetworkMessage.java | 59 ---
.../ignite/network/NetworkMessageHandler.java | 6 +-
.../MessageReader.java} | 16 +-
.../MessageWriter.java} | 16 +-
.../AckResponse.java} | 15 +-
.../message/DefaultMessageMapperProvider.java | 54 +++
.../network/message/MessageDeserializer.java} | 25 +-
.../network/message/MessageMapperProvider.java} | 22 +-
.../network/message/MessageMappingException.java} | 25 +-
.../ignite/network/message/MessageSerializer.java} | 25 +-
.../ignite/network/message/NetworkMessage.java} | 11 +-
.../network/scalecube/ScaleCubeMessageCodec.java | 133 ++++++
.../network/scalecube/ScaleCubeMessageHandler.java | 8 +-
.../network/scalecube/ScaleCubeMessageReader.java} | 28 +-
.../network/scalecube/ScaleCubeMessageWriter.java} | 28 +-
.../network/scalecube/ScaleCubeNetworkCluster.java | 37 +-
.../ScaleCubeNetworkClusterFactory.java} | 71 +++-
modules/raft-client/README.md | 3 +
modules/{network => raft-client}/pom.xml | 40 +-
.../org/apache/ignite/raft/client/Command.java} | 12 +-
.../ignite/raft/client/ElectionPriority.java} | 25 +-
.../java/org/apache/ignite/raft/client/Peer.java | 97 +++++
.../apache/ignite/raft/client/RaftErrorCode.java | 67 +++
.../apache/ignite/raft/client/ReadCommand.java} | 10 +-
.../apache/ignite/raft/client/WriteCommand.java} | 10 +-
.../raft/client/exception/RaftException.java} | 28 +-
.../ignite/raft/client/message/ActionRequest.java | 58 +++
.../raft/client/message/ActionResponse.java} | 30 +-
.../raft/client/message/AddLearnersRequest.java | 59 +++
.../raft/client/message/AddPeersRequest.java | 59 +++
.../raft/client/message/ChangePeersResponse.java | 59 +++
.../raft/client/message/GetLeaderRequest.java} | 30 +-
.../raft/client/message/GetLeaderResponse.java} | 31 +-
.../raft/client/message/GetPeersRequest.java | 55 +++
.../raft/client/message/GetPeersResponse.java | 59 +++
.../client/message/RaftClientMessageFactory.java | 93 +++++
.../raft/client/message/RaftErrorResponse.java | 60 +++
.../raft/client/message/RemoveLearnersRequest.java | 59 +++
.../raft/client/message/RemovePeersRequest.java | 59 +++
.../raft/client/message/SnapshotRequest.java} | 30 +-
.../client/message/TransferLeadershipRequest.java | 58 +++
.../client/message/impl/ActionRequestImpl.java} | 51 ++-
.../client/message/impl/ActionResponseImpl.java} | 37 +-
.../message/impl/AddLearnersRequestImpl.java | 68 +++
.../client/message/impl/AddPeersRequestImpl.java | 68 +++
.../message/impl/ChangePeersResponseImpl.java} | 52 ++-
.../client/message/impl/GetLeaderRequestImpl.java} | 37 +-
.../message/impl/GetLeaderResponseImpl.java} | 38 +-
.../client/message/impl/GetPeersRequestImpl.java} | 50 ++-
.../client/message/impl/GetPeersResponseImpl.java} | 51 ++-
.../message/impl/RaftClientMessageFactoryImpl.java | 109 +++++
.../client/message/impl/RaftErrorResponseImpl.java | 64 +++
.../message/impl/RemoveLearnersRequestImpl.java | 66 +++
.../message/impl/RemovePeersRequestImpl.java} | 52 ++-
.../client/message/impl/SnapshotRequestImpl.java} | 37 +-
.../impl/TransferLeadershipRequestImpl.java} | 53 ++-
.../raft/client/service/CommandClosure.java} | 30 +-
.../client/service/RaftGroupCommandListener.java} | 22 +-
.../raft/client/service/RaftGroupService.java | 196 +++++++++
.../client/service/impl/RaftGroupServiceImpl.java | 354 ++++++++++++++++
.../raft/client/service/RaftGroupServiceTest.java | 421 +++++++++++++++++++
modules/{configuration => raft}/pom.xml | 30 +-
.../ignite/raft/server/CounterCommandListener.java | 53 +++
.../ignite/raft/server/GetValueCommand.java} | 14 +-
.../raft/server/ITRaftCounterServerTest.java | 186 +++++++++
.../raft/server/IncrementAndGetCommand.java} | 26 +-
.../org/apache/ignite/raft/server/RaftServer.java | 56 +++
.../ignite/raft/server/impl/RaftServerImpl.java | 264 ++++++++++++
.../java/org/apache/ignite/rest/RestModule.java | 11 +-
.../InMemoryConfigurationStorage.java} | 51 +--
.../configuration/RestConfigurationSchema.java | 2 +-
.../rest/presentation/json/JsonConverter.java | 9 +-
.../rest/presentation/json/JsonConverterTest.java | 7 +
.../json/TestConfigurationStorage.java | 14 +-
.../java/org/apache/ignite/app/IgniteRunner.java | 5 +-
.../ignite/configuration/ConfigurationModule.java | 41 +-
.../extended/LocalConfigurationSchema.java | 3 +-
modules/schema/README.md | 12 +-
.../ignite/internal/schema/AssemblyException.java | 2 +-
.../org/apache/ignite/internal/schema/Bitmask.java | 2 +-
.../{ByteBufferTuple.java => ByteBufferRow.java} | 28 +-
.../org/apache/ignite/internal/schema/Columns.java | 4 +-
.../ignite/internal/schema/ExpandableByteBuf.java | 4 +-
.../internal/schema/InvalidTypeException.java | 2 +-
.../ignite/internal/schema/NativeTypeSpec.java | 30 +-
.../org/apache/ignite/internal/schema/README.md | 28 +-
.../internal/schema/{Tuple.java => Row.java} | 72 +++-
.../{TupleAssembler.java => RowAssembler.java} | 44 +-
.../ignite/internal/schema/SchemaDescriptor.java | 22 +
.../schema/marshaller/AbstractSerializer.java | 40 +-
.../internal/schema/marshaller/MarshallerUtil.java | 4 +-
.../internal/schema/marshaller/Serializer.java | 2 +-
.../marshaller/asm/AsmSerializerGenerator.java | 22 +-
...nerator.java => ColumnAccessCodeGenerator.java} | 44 +-
.../asm/IdentityMarshallerCodeGenerator.java | 10 +-
.../marshaller/asm/MarshallerCodeGenerator.java | 6 +-
.../asm/ObjectMarshallerCodeGenerator.java | 16 +-
.../marshaller/reflection/FieldAccessor.java | 74 ++--
.../marshaller/reflection/JavaSerializer.java | 24 +-
.../schema/marshaller/reflection/Marshaller.java | 16 +-
.../ignite/internal/schema/package-info.java | 2 +-
.../schema/{TupleTest.java => RowTest.java} | 14 +-
.../marshaller/reflection/FieldAccessorTest.java | 76 ++--
modules/table/README.md | 2 +
modules/{configuration => table}/pom.xml | 25 +-
.../org/apache/ignite/binary/BinaryObjects.java} | 35 +-
.../internal/schema/marshaller/Marshaller.java | 74 ++++
.../ignite/internal/storage/TableStorage.java} | 25 +-
.../apache/ignite/internal/table/KVViewImpl.java | 228 +++++++++++
.../internal/table/KeyValueBinaryViewImpl.java | 241 +++++++++++
.../ignite/internal/table/RecordViewImpl.java | 249 +++++++++++
.../apache/ignite/internal/table/RowChunk.java} | 13 +-
.../ignite/internal/table/RowChunkAdapter.java | 106 +++++
.../apache/ignite/internal/table/TableImpl.java | 265 ++++++++++++
.../apache/ignite/internal/table/TableRow.java} | 22 +-
.../ignite/internal/table/TableRowAdapter.java | 142 +++++++
.../ignite/internal/table}/package-info.java | 5 +-
.../test/java/org/apache/ignite/table/Example.java | 456 +++++++++++++++++++++
.../apache/ignite/table/impl/TestTableRowImpl.java | 132 ++++++
.../ignite/table/impl/TestTableStorageImpl.java | 82 ++++
parent/pom.xml | 7 -
pom.xml | 30 ++
219 files changed, 10349 insertions(+), 1713 deletions(-)
