You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2021/04/05 10:07:57 UTC
[ignite-3] branch ignite-14393 updated (2687266 -> f6ac843)
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
[ignite-3] 01/01: Merge branch 'main' of
https://gitbox.apache.org/repos/asf/ignite-3 into ignite-14393
Posted by ag...@apache.org.
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 <al...@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(-)