This is an automated email from the ASF dual-hosted git repository.
agoncharuk pushed a change to branch ignite-14393
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 2687266 IGNITE-14393 Components interaction
add a8919fe IGNITE-14403 Added ignite-core module and IgniteUuid class
add cb518de IGNITE-14149 RAFT client module. (#59)
add 96b8e3a IGNITE-14035: Table access API. (#33)
add 53e870d IGNITE-14198 Meta storage client interface
add 8cf0bb2 IGNITE-14442 Fixed NPE in IgniteRunner caused by broken REST
module. (#77)
add 4d82a7e IGNITE-14438 Added README.md for cli and cli-common modules.
Fixes #75
add e9ef6d4 IGNITE-14295 Network messages refactored to have a common
interface and proper serializers/deserializers. (#70)
add 297468b IGNITE-14180 Implemented the ability to subscribe to
configuration updates. (#76)
add ed2b820 IGNITE-14460 Single-node RAFT server (#80).
add 15166f8 IGNITE-14457 Update Ignite 3 binary build structure (#79)
new f6ac843 Merge branch 'main' of
https://gitbox.apache.org/repos/asf/ignite-3 into ignite-14393
The 1 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:
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 +-
.../BinaryObject.java} | 11 +-
.../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 +-
.../KeyValueBinaryView.java} | 18 +-
.../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 +++++
.../TableIndex.java => table/TupleBuilder.java} | 20 +-
.../org/apache/ignite/table/mapper/KeyMapper.java} | 7 +-
.../org/apache/ignite/table/mapper/Mappers.java} | 37 +-
.../apache/ignite/table/mapper/RecordMapper.java} | 19 +-
.../apache/ignite/table/mapper/ValueMapper.java} | 24 +-
.../java/org/apache/ignite/table/package-info.java | 10 +-
.../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 ++
.../notifications/ConfigurationListener.java} | 20 +-
.../ConfigurationNamedListListener.java} | 45 +-
.../ConfigurationNotificationEvent.java} | 52 +--
.../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/{cli-common => metastorage-client}/pom.xml | 7 +-
.../metastorage/client/MetaStorageService.java | 345 ++++++++++++++++
.../ignite/metastorage/client}/package-info.java | 4 +-
modules/{cli-common => metastorage-common}/pom.xml | 12 +-
.../metastorage/common/CompactedException.java} | 37 +-
.../ignite/metastorage/common/Condition.java | 356 ++++++++++++++++
.../ignite/metastorage/common/Conditions.java} | 42 +-
.../apache/ignite/metastorage/common/Cursor.java} | 15 +-
.../apache/ignite/metastorage/common/Entry.java} | 45 +-
.../org/apache/ignite/metastorage/common/Key.java | 80 ++++
.../ignite/metastorage/common/Operation.java | 84 ++++
.../common/OperationTimeoutException.java} | 37 +-
.../ignite/metastorage/common/Operations.java | 64 +++
.../ignite/metastorage/common/WatchEvent.java} | 45 +-
.../ignite/metastorage/common/WatchListener.java} | 28 +-
.../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} | 33 +-
.../scalecube/TestRequestMapperProvider.java | 54 +++
.../ignite/network/scalecube/TestResponse.java} | 34 +-
.../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 +--
.../network/NetworkConfigurationException.java} | 17 +-
...rkMessageHandler.java => NetworkException.java} | 22 +-
.../org/apache/ignite/network/NetworkMember.java | 3 +-
.../org/apache/ignite/network/NetworkMessage.java | 59 ---
.../ignite/network/NetworkMessageHandler.java | 6 +-
.../ignite/network/internal/MessageReader.java} | 16 +-
.../ignite/network/internal/MessageWriter.java} | 22 +-
.../ignite/network/message/AckResponse.java} | 10 +-
.../message/DefaultMessageMapperProvider.java | 54 +++
.../network/message/MessageDeserializer.java} | 24 +-
.../network/message/MessageMapperProvider.java} | 20 +-
.../network/message/MessageMappingException.java} | 17 +-
.../ignite/network/message/MessageSerializer.java} | 28 +-
.../ignite/network/message/NetworkMessage.java} | 11 +-
.../network/scalecube/ScaleCubeMessageCodec.java | 133 ++++++
.../network/scalecube/ScaleCubeMessageHandler.java | 8 +-
.../network/scalecube/ScaleCubeMessageReader.java} | 26 +-
.../network/scalecube/ScaleCubeMessageWriter.java} | 26 +-
.../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} | 14 +-
.../ignite/raft/client/ElectionPriority.java} | 27 +-
.../java/org/apache/ignite/raft/client/Peer.java | 97 +++++
.../apache/ignite/raft/client/RaftErrorCode.java} | 48 ++-
.../apache/ignite/raft/client/ReadCommand.java} | 9 +-
.../apache/ignite/raft/client/WriteCommand.java} | 9 +-
.../raft/client/exception/RaftException.java} | 25 +-
.../ignite/raft/client/message/ActionRequest.java | 58 +++
.../raft/client/message/ActionResponse.java} | 47 +--
.../raft/client/message/AddLearnersRequest.java | 59 +++
.../raft/client/message/AddPeersRequest.java | 59 +++
.../raft/client/message/ChangePeersResponse.java | 59 +++
.../raft/client/message/GetLeaderRequest.java} | 47 +--
.../raft/client/message/GetLeaderResponse.java} | 48 ++-
.../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} | 47 +--
.../client/message/TransferLeadershipRequest.java | 58 +++
.../client/message/impl/ActionRequestImpl.java} | 51 ++-
.../client/message/impl/ActionResponseImpl.java} | 42 +-
.../message/impl/AddLearnersRequestImpl.java | 68 +++
.../client/message/impl/AddPeersRequestImpl.java} | 62 +--
.../message/impl/ChangePeersResponseImpl.java} | 57 +--
.../client/message/impl/GetLeaderRequestImpl.java} | 42 +-
.../message/impl/GetLeaderResponseImpl.java} | 43 +-
.../client/message/impl/GetPeersRequestImpl.java} | 50 ++-
.../client/message/impl/GetPeersResponseImpl.java} | 51 ++-
.../message/impl/RaftClientMessageFactoryImpl.java | 109 +++++
.../message/impl/RaftErrorResponseImpl.java} | 56 +--
.../message/impl/RemoveLearnersRequestImpl.java | 66 +++
.../message/impl/RemovePeersRequestImpl.java} | 52 ++-
.../client/message/impl/SnapshotRequestImpl.java} | 42 +-
.../impl/TransferLeadershipRequestImpl.java} | 52 +--
.../raft/client/service/CommandClosure.java} | 32 +-
.../client/service/RaftGroupCommandListener.java} | 30 +-
.../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 +++
.../apache/ignite/raft/server/GetValueCommand.java | 13 +-
.../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/{bytecode => table}/pom.xml | 31 +-
.../org/apache/ignite/binary/BinaryObjects.java} | 43 +-
.../internal/schema/marshaller/Marshaller.java | 74 ++++
.../ignite/internal/storage/TableStorage.java} | 27 +-
.../apache/ignite/internal/table/KVViewImpl.java | 228 +++++++++++
.../internal/table/KeyValueBinaryViewImpl.java | 241 +++++++++++
.../ignite/internal/table/RecordViewImpl.java | 249 +++++++++++
.../apache/ignite/internal/table/RowChunk.java} | 12 +-
.../ignite/internal/table/RowChunkAdapter.java | 106 +++++
.../apache/ignite/internal/table/TableImpl.java | 265 ++++++++++++
.../apache/ignite/internal/table/TableRow.java} | 21 +-
.../ignite/internal/table/TableRowAdapter.java | 142 +++++++
.../ignite/internal/table}/package-info.java | 4 +-
.../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, 10050 insertions(+), 1971 deletions(-)
create mode 100644 assembly/NOTICE
create mode 100644 assembly/README
create mode 100644 assembly/assembly.xml
copy
modules/api/src/main/java/org/apache/ignite/{schema/SortedIndexColumn.java =>
binary/BinaryObject.java} (79%)
copy modules/{cli/src/test/java/org/apache/ignite/cli/AbstractCliTest.java =>
api/src/main/java/org/apache/ignite/lang/IgniteFuture.java} (74%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/table/InvocationContext.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/table/InvokeProcessor.java
copy
modules/{cli-common/src/main/java/org/apache/ignite/cli/common/package-info.java
=> api/src/main/java/org/apache/ignite/table/InvokeProcessorException.java}
(85%)
copy modules/api/src/main/java/org/apache/ignite/{schema/TableIndex.java =>
table/KeyValueBinaryView.java} (71%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/table/KeyValueView.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/table/RecordView.java
create mode 100644 modules/api/src/main/java/org/apache/ignite/table/Table.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/table/TableView.java
create mode 100644 modules/api/src/main/java/org/apache/ignite/table/Tuple.java
copy modules/api/src/main/java/org/apache/ignite/{schema/TableIndex.java =>
table/TupleBuilder.java} (72%)
copy modules/{cli/src/test/java/org/apache/ignite/cli/package-info.java =>
api/src/main/java/org/apache/ignite/table/mapper/KeyMapper.java} (91%)
copy
modules/{network/src/main/java/org/apache/ignite/network/NetworkHandlersProvider.java
=> api/src/main/java/org/apache/ignite/table/mapper/Mappers.java} (56%)
copy modules/{cli/src/test/java/org/apache/ignite/cli/AbstractCliTest.java =>
api/src/main/java/org/apache/ignite/table/mapper/RecordMapper.java} (68%)
copy
modules/{configuration-annotation-processor/src/main/java/org/apache/ignite/configuration/processor/internal/ProcessorException.java
=> api/src/main/java/org/apache/ignite/table/mapper/ValueMapper.java} (65%)
copy docs/assets/css/docs.scss =>
modules/api/src/main/java/org/apache/ignite/table/package-info.java (92%)
create mode 100644 modules/cli-common/README.md
create mode 100644 modules/cli/README.md
rename
modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/{sample/storage
=> }/ConfigurationChangerTest.java (87%)
create mode 100644
modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/notifications/ConfigurationListenerTest.java
copy
modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/{sample
=> }/storage/TestConfigurationStorage.java (80%)
delete mode 100644
modules/configuration/src/main/java/org/apache/ignite/configuration/PropertyListener.java
copy
modules/{network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestMessage.java
=>
configuration/src/main/java/org/apache/ignite/configuration/internal/notifications/ConfigurationNotificationEventImpl.java}
(51%)
create mode 100644
modules/configuration/src/main/java/org/apache/ignite/configuration/internal/util/ConfigurationNotificationsUtil.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/util/Factory.java =>
configuration/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationListener.java}
(61%)
copy
modules/{api/src/main/java/org/apache/ignite/schema/builder/TableColumnBuilder.java
=>
configuration/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationNamedListListener.java}
(50%)
copy modules/{api/src/main/java/org/apache/ignite/schema/SchemaTable.java =>
configuration/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationNotificationEvent.java}
(51%)
copy modules/{configuration => core}/pom.xml (70%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/lang/IgniteUuid.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/lang/IgniteUuidGenerator.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/lang/LogWrapper.java
copy modules/{cli-common => metastorage-client}/pom.xml (87%)
create mode 100644
modules/metastorage-client/src/main/java/org/apache/ignite/metastorage/client/MetaStorageService.java
copy modules/{cli/src/main/java/org/apache/ignite/cli/builtins/module =>
metastorage-client/src/main/java/org/apache/ignite/metastorage/client}/package-info.java
(88%)
copy modules/{cli-common => metastorage-common}/pom.xml (80%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/marshaller/SerializationException.java
=>
metastorage-common/src/main/java/org/apache/ignite/metastorage/common/CompactedException.java}
(52%)
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Condition.java
copy modules/{schema/src/main/java/org/apache/ignite/internal/util/Pair.java
=>
metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Conditions.java}
(53%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/util/Factory.java =>
metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Cursor.java}
(77%)
copy
modules/{api/src/main/java/org/apache/ignite/schema/builder/TableColumnBuilder.java
=>
metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Entry.java}
(52%)
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Key.java
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Operation.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/marshaller/SerializationException.java
=>
metastorage-common/src/main/java/org/apache/ignite/metastorage/common/OperationTimeoutException.java}
(53%)
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Operations.java
copy modules/{schema/src/main/java/org/apache/ignite/internal/util/Pair.java
=>
metastorage-common/src/main/java/org/apache/ignite/metastorage/common/WatchEvent.java}
(54%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/marshaller/SerializationException.java
=>
metastorage-common/src/main/java/org/apache/ignite/metastorage/common/WatchListener.java}
(52%)
copy modules/{cli-common/src/main/java/org/apache/ignite/cli =>
metastorage-common/src/main/java/org/apache/ignite/metastorage}/common/package-info.java
(86%)
create mode 100644
modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestMessageMapperProvider.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/IndexColumnImpl.java
=>
network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestRequest.java}
(59%)
create mode 100644
modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestRequestMapperProvider.java
copy
modules/{api/src/main/java/org/apache/ignite/schema/builder/HashIndexBuilder.java
=>
network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestResponse.java}
(58%)
create mode 100644
modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestResponseMapperProvider.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/Network.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/NetworkClusterContext.java
copy
modules/{configuration/src/main/java/org/apache/ignite/configuration/ConfigurationChangeException.java
=>
network/src/main/java/org/apache/ignite/network/NetworkConfigurationException.java}
(68%)
copy
modules/network/src/main/java/org/apache/ignite/network/{NetworkMessageHandler.java
=> NetworkException.java} (70%)
delete mode 100644
modules/network/src/main/java/org/apache/ignite/network/NetworkMessage.java
copy modules/{cli/src/test/java/org/apache/ignite/cli/AbstractCliTest.java =>
network/src/main/java/org/apache/ignite/network/internal/MessageReader.java}
(74%)
copy modules/{api/src/main/java/org/apache/ignite/schema/TableIndex.java =>
network/src/main/java/org/apache/ignite/network/internal/MessageWriter.java}
(74%)
copy modules/{api/src/main/java/org/apache/ignite/schema/HashIndex.java =>
network/src/main/java/org/apache/ignite/network/message/AckResponse.java} (76%)
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/message/DefaultMessageMapperProvider.java
copy
modules/{api/src/main/java/org/apache/ignite/schema/builder/SchemaObjectBuilder.java
=>
network/src/main/java/org/apache/ignite/network/message/MessageDeserializer.java}
(65%)
copy modules/{api/src/main/java/org/apache/ignite/schema/TableIndex.java =>
network/src/main/java/org/apache/ignite/network/message/MessageMapperProvider.java}
(62%)
copy
modules/{configuration/src/main/java/org/apache/ignite/configuration/ConfigurationChangeException.java
=>
network/src/main/java/org/apache/ignite/network/message/MessageMappingException.java}
(67%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/marshaller/SerializationException.java
=>
network/src/main/java/org/apache/ignite/network/message/MessageSerializer.java}
(65%)
copy modules/{api/src/main/java/org/apache/ignite/schema/IndexColumn.java =>
network/src/main/java/org/apache/ignite/network/message/NetworkMessage.java}
(81%)
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessageCodec.java
copy
modules/{configuration/src/main/java/org/apache/ignite/configuration/validation/ValidationIssue.java
=>
network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessageReader.java}
(65%)
copy
modules/{configuration/src/main/java/org/apache/ignite/configuration/validation/ValidationIssue.java
=>
network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessageWriter.java}
(65%)
copy
modules/network/src/main/java/org/apache/ignite/network/{NetworkClusterFactory.java
=> scalecube/ScaleCubeNetworkClusterFactory.java} (50%)
create mode 100644 modules/raft-client/README.md
copy modules/{network => raft-client}/pom.xml (78%)
copy modules/{api/src/main/java/org/apache/ignite/schema/SchemaObject.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/Command.java} (77%)
copy modules/{api/src/main/java/org/apache/ignite/schema/Column.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/ElectionPriority.java}
(61%)
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/Peer.java
copy modules/{rest/src/main/java/org/apache/ignite/rest/ErrorResult.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/RaftErrorCode.java}
(50%)
copy
modules/{cli/src/main/java/org/apache/ignite/cli/builtins/module/package-info.java
=> raft-client/src/main/java/org/apache/ignite/raft/client/ReadCommand.java}
(82%)
copy
modules/{cli/src/main/java/org/apache/ignite/cli/builtins/module/package-info.java
=> raft-client/src/main/java/org/apache/ignite/raft/client/WriteCommand.java}
(82%)
copy
modules/{network/src/main/java/org/apache/ignite/network/NetworkHandlersProvider.java
=>
raft-client/src/main/java/org/apache/ignite/raft/client/exception/RaftException.java}
(61%)
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/ActionRequest.java
copy modules/{rest/src/main/java/org/apache/ignite/rest/ErrorResult.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/message/ActionResponse.java}
(52%)
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/AddLearnersRequest.java
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/AddPeersRequest.java
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/ChangePeersResponse.java
copy modules/{rest/src/main/java/org/apache/ignite/rest/ErrorResult.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/message/GetLeaderRequest.java}
(54%)
copy modules/{rest/src/main/java/org/apache/ignite/rest/ErrorResult.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/message/GetLeaderResponse.java}
(53%)
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/GetPeersRequest.java
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/GetPeersResponse.java
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/RaftClientMessageFactory.java
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/RaftErrorResponse.java
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/RemoveLearnersRequest.java
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/RemovePeersRequest.java
copy modules/{rest/src/main/java/org/apache/ignite/rest/ErrorResult.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/message/SnapshotRequest.java}
(54%)
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/TransferLeadershipRequest.java
copy
modules/{network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestMessage.java
=>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/ActionRequestImpl.java}
(52%)
copy modules/{api/src/main/java/org/apache/ignite/schema/SortedIndex.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/ActionResponseImpl.java}
(59%)
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/AddLearnersRequestImpl.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/builder/HashIndexBuilderImpl.java
=>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/AddPeersRequestImpl.java}
(50%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/builder/HashIndexBuilderImpl.java
=>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/ChangePeersResponseImpl.java}
(50%)
copy modules/{api/src/main/java/org/apache/ignite/schema/SortedIndex.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/GetLeaderRequestImpl.java}
(59%)
copy modules/{api/src/main/java/org/apache/ignite/schema/SortedIndex.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/GetLeaderResponseImpl.java}
(58%)
copy
modules/{network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestMessage.java
=>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/GetPeersRequestImpl.java}
(52%)
copy
modules/{network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestMessage.java
=>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/GetPeersResponseImpl.java}
(51%)
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/RaftClientMessageFactoryImpl.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/builder/HashIndexBuilderImpl.java
=>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/RaftErrorResponseImpl.java}
(50%)
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/RemoveLearnersRequestImpl.java
copy
modules/{network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestMessage.java
=>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/RemovePeersRequestImpl.java}
(51%)
copy modules/{api/src/main/java/org/apache/ignite/schema/SortedIndex.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/SnapshotRequestImpl.java}
(59%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/builder/HashIndexBuilderImpl.java
=>
raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/TransferLeadershipRequestImpl.java}
(51%)
copy modules/{api/src/main/java/org/apache/ignite/schema/Column.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/service/CommandClosure.java}
(62%)
copy modules/{api/src/main/java/org/apache/ignite/schema/Column.java =>
raft-client/src/main/java/org/apache/ignite/raft/client/service/RaftGroupCommandListener.java}
(63%)
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/service/RaftGroupService.java
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/service/impl/RaftGroupServiceImpl.java
create mode 100644
modules/raft-client/src/test/java/org/apache/ignite/raft/client/service/RaftGroupServiceTest.java
copy modules/{configuration => raft}/pom.xml (71%)
create mode 100644
modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/CounterCommandListener.java
copy docs/assets/css/docs.scss =>
modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/GetValueCommand.java
(78%)
create mode 100644
modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/ITRaftCounterServerTest.java
copy modules/{api/src/main/java/org/apache/ignite/schema/ColumnarIndex.java =>
raft/src/integrationTest/java/org/apache/ignite/raft/server/IncrementAndGetCommand.java}
(64%)
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/server/RaftServer.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/server/impl/RaftServerImpl.java
rename
modules/{configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/sample/storage/TestConfigurationStorage.java
=>
rest/src/main/java/org/apache/ignite/rest/configuration/InMemoryConfigurationStorage.java}
(68%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{ByteBufferTuple.java
=> ByteBufferRow.java} (76%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{Tuple.java =>
Row.java} (85%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/{TupleAssembler.java
=> RowAssembler.java} (90%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/asm/{TupleColumnAccessCodeGenerator.java
=> ColumnAccessCodeGenerator.java} (59%)
rename
modules/schema/src/test/java/org/apache/ignite/internal/schema/{TupleTest.java
=> RowTest.java} (95%)
create mode 100644 modules/table/README.md
copy modules/{bytecode => table}/pom.xml (77%)
copy modules/{schema/src/main/java/org/apache/ignite/internal/util/Pair.java
=> table/src/main/java/org/apache/ignite/binary/BinaryObjects.java} (61%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/schema/marshaller/Marshaller.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/marshaller/SerializationException.java
=> table/src/main/java/org/apache/ignite/internal/storage/TableStorage.java}
(65%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/KVViewImpl.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/KeyValueBinaryViewImpl.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/RecordViewImpl.java
copy modules/{api/src/main/java/org/apache/ignite/schema/SchemaObject.java =>
table/src/main/java/org/apache/ignite/internal/table/RowChunk.java} (80%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/RowChunkAdapter.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/TableImpl.java
copy modules/{api/src/main/java/org/apache/ignite/schema/TableIndex.java =>
table/src/main/java/org/apache/ignite/internal/table/TableRow.java} (73%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/TableRowAdapter.java
copy modules/{cli/src/test/java/org/apache/ignite/cli =>
table/src/main/java/org/apache/ignite/internal/table}/package-info.java (91%)
create mode 100644
modules/table/src/test/java/org/apache/ignite/table/Example.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/table/impl/TestTableRowImpl.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/table/impl/TestTableStorageImpl.java
