You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2021/03/26 14:20:18 UTC
[ignite-3] branch ignite-14330 updated (0915caa -> 29e03cf)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-14330
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
discard 0915caa WIP. Extract InternalTable facade. Add remove operation.
discard d6d147f WIP. Fix Row classes hierarchy.
discard 96280b4 WIP. Upsert operation.
discard 19f0c71 WIP. Add basic TupleBuilder implementation.
discard 29b2d72 Merge branch 'main' into ignite-14330
omit a42e27b Javadoc.
omit 38d60d8 Styles.
omit 7cb514b Styles.
omit 878cc53 Minor.
omit 7209835 Minor.
omit 945e9b5 Rename Tuple->Row and TupleAssembler->RowAssembler.
omit 8c49e77 Rename ColSpan to Tuple. Fix javadocs.
omit 88694d9 Segregate BinaryObject and Column span.
omit 7601b84 Merge branch 'main' into ignite-14035-alt
omit 6745a8c Add IgniteFuture, a future with chaining capabilities.
omit b99740d WIP. Add async operations.
omit 2ee5983 WIP.
omit 31e06c5 Suppress warnings.
omit 38f79be Minor.
omit 688dd51 Minor.
omit 8004888 Minor.
omit fed5da9 Minor.
omit c21e4de WIP.
omit 72998df Minor.
omit 2d6ac58 WIP.
omit 23c31ba Add README.md for modules.
omit a471f30 Merge branch 'main' into ignite-14035
omit 9a5f7a7 Styles.
omit 520bae0 Styles.
omit b434b3b Styles.
omit a27ffa4 Styles.
omit 06c1bf0 Styles.
omit 0ae3bbf Rename modules. Fix packages. Styles.
omit 6d5d007 Rename modules. Fix packages. Styles.
omit 8707ff4 WIP.
omit 6e9ac7c WIP.
omit 2774166 WIP.
omit d6d5f8b WIP.
omit efcff58 WIP.
omit 917a27a WIP.
omit 620c2a1 WIP.
omit d7db905 Rename packages.
omit 1219a9f Extend RecordView API.
omit 15b3751 Styles.
omit 11528f6 Fix dependencies.
omit 1188767 Merge branch 'main' into ignite-14035
omit 0e77ba5 WIP.
omit 8c14d8c WIP.
omit 1349eec WIP.
omit 8eb8de1 Fix styles.
omit 10c2aa6 Minor.
omit 6f3eea0 Minor.
omit 88ba769 Minor.
omit f2514d7 Table access API. Draft. Simple examples added.
add ba5467c IGNITE-14114 Added Spinner ui element. Fixes #48
add d9e88e9 IGNITE-14202 Netty-based REST API sub-library for Ignite. Fixes #71
add 2e6ea88 IGNITE-14371 JSON representation for configuration & partial code for JSON update requests parsing. (#72)
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 20fc054 WIP. Add basic TupleBuilder implementation.
add b57511f WIP. Upsert operation.
add 71b0655 WIP. Fix Row classes hierarchy.
add 29e03cf WIP. Extract InternalTable facade. Add remove operation.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (0915caa)
\
N -- N -- N refs/heads/ignite-14330 (29e03cf)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../ignite/cli/builtins/node/NodeManager.java | 17 +-
.../apache/ignite/cli/spec/NodeCommandSpec.java | 2 -
.../java/org/apache/ignite/cli/ui/ProgressBar.java | 28 +-
.../java/org/apache/ignite/cli/ui/Spinner.java | 72 ++++
.../apache/ignite/cli/IgniteCliInterfaceTest.java | 26 +-
.../java/org/apache/ignite/cli/ui/SpinnerTest.java | 89 +++++
.../org/apache/ignite/cli/ui}/package-info.java | 4 +-
.../ignite/configuration/ConfigurationChanger.java | 10 +
.../configuration/ConfigurationRegistry.java | 42 ++
.../apache/ignite/configuration/Configurator.java | 28 --
.../configuration/annotation/ConfigValue.java | 4 -
.../ignite/configuration/internal/SuperRoot.java | 6 +
.../internal/util/ConfigurationUtil.java | 17 +-
.../configuration/tree/ConfigurationVisitor.java | 2 +-
.../ignite/configuration/tree/NamedListNode.java | 12 +-
modules/{table => core}/pom.xml | 39 +-
.../java/org/apache/ignite/lang/IgniteUuid.java | 135 +++++++
.../apache/ignite/lang/IgniteUuidGenerator.java | 84 ++++
.../java/org/apache/ignite/lang/LogWrapper.java | 80 ++++
.../org/apache/ignite/network/NetworkCluster.java | 7 +-
.../network/scalecube/ScaleCubeNetworkCluster.java | 2 +-
modules/raft-client/README.md | 3 +
modules/{network => raft-client}/pom.xml | 40 +-
.../org/apache/ignite/raft/client/Command.java} | 8 +-
.../ignite/raft/client/ElectionPriority.java} | 27 +-
.../java/org/apache/ignite/raft/client/Peer.java | 96 +++++
.../apache/ignite/raft/client/RaftErrorCode.java} | 42 +-
.../apache/ignite/raft/client/ReadCommand.java} | 8 +-
.../apache/ignite/raft/client/WriteCommand.java} | 8 +-
.../raft/client/exception/RaftException.java} | 25 +-
.../ignite/raft/client/message/ActionRequest.java} | 53 +--
.../raft/client/message/ActionResponse.java} | 36 +-
.../raft/client/message/AddLearnersRequest.java} | 53 +--
.../raft/client/message/AddPeersRequest.java} | 47 ++-
.../raft/client/message/ChangePeersResponse.java} | 47 ++-
.../raft/client/message/GetLeaderRequest.java} | 36 +-
.../raft/client/message/GetLeaderResponse.java} | 36 +-
.../raft/client/message/GetPeersRequest.java} | 53 +--
.../raft/client/message/GetPeersResponse.java} | 47 ++-
.../raft/client/message/RaftErrorResponse.java | 58 +++
.../client/message/RemoveLearnersRequest.java} | 47 ++-
.../raft/client/message/RemovePeersRequest.java} | 47 ++-
.../raft/client/message/SnapshotRequest.java} | 36 +-
.../client/message/TransferLeadershipRequest.java} | 53 +--
.../client/message/impl/ActionRequestImpl.java} | 46 ++-
.../client/message/impl/ActionResponseImpl.java} | 36 +-
.../message/impl/AddLearnersRequestImpl.java} | 55 +--
.../client/message/impl/AddPeersRequestImpl.java} | 50 ++-
.../message/impl/ChangePeersResponseImpl.java} | 47 ++-
.../client/message/impl/GetLeaderRequestImpl.java} | 40 +-
.../message/impl/GetLeaderResponseImpl.java} | 36 +-
.../client/message/impl/GetPeersRequestImpl.java} | 45 ++-
.../client/message/impl/GetPeersResponseImpl.java} | 46 ++-
.../message/impl/RaftClientMessageFactory.java | 108 ++++++
.../message/impl/RaftClientMessageFactoryImpl.java | 108 ++++++
.../message/impl/RaftErrorResponseImpl.java} | 48 +--
.../message/impl/RemoveLearnersRequestImpl.java} | 48 ++-
.../message/impl/RemovePeersRequestImpl.java} | 47 ++-
.../client/message/impl/SnapshotRequestImpl.java} | 36 +-
.../impl/TransferLeadershipRequestImpl.java} | 48 ++-
.../client/service/RaftGroupCommandListener.java} | 21 +-
.../raft/client/service/RaftGroupService.java | 196 ++++++++++
.../client/service/impl/RaftGroupServiceImpl.java | 389 +++++++++++++++++++
.../raft/client/service/RaftGroupServiceTest.java | 421 +++++++++++++++++++++
modules/rest/pom.xml | 43 ++-
.../java/org/apache/ignite/rest/RestModule.java | 178 +++++----
.../configuration/RestConfigurationSchema.java | 15 +-
.../apache/ignite/rest/netty/RestApiHandler.java | 112 ++++++
.../ignite/rest/netty/RestApiHttpRequest.java} | 46 ++-
.../ignite/rest/netty/RestApiHttpResponse.java | 134 +++++++
.../ignite/rest/netty/RestApiInitializer.java | 50 +++
.../rest/presentation/json/JsonConverter.java | 236 +++++++++++-
.../rest/presentation/json/JsonPresentation.java | 14 +-
.../java/org/apache/ignite/rest/routes/Route.java | 152 ++++++++
.../java/org/apache/ignite/rest/routes/Router.java | 126 ++++++
.../rest/presentation/json/JsonConverterTest.java | 211 +++++++++++
.../json/TestConfigurationStorage.java | 63 +++
.../org/apache/ignite/rest/routes/RouteTest.java | 97 +++++
modules/runner/pom.xml | 5 -
.../java/org/apache/ignite/app/IgniteRunner.java | 2 +-
.../ignite/configuration/ConfigurationModule.java | 2 +-
.../src/main/resources/simplelogger.properties | 2 +-
parent/pom.xml | 38 +-
pom.xml | 2 +
84 files changed, 4144 insertions(+), 867 deletions(-)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/ui/Spinner.java
create mode 100644 modules/cli/src/test/java/org/apache/ignite/cli/ui/SpinnerTest.java
copy modules/{api/src/main/java/org/apache/ignite/table => cli/src/test/java/org/apache/ignite/cli/ui}/package-info.java (91%)
delete mode 100644 modules/configuration/src/main/java/org/apache/ignite/configuration/Configurator.java
copy modules/{table => core}/pom.xml (71%)
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
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/table/mapper/KeyMapper.java => raft-client/src/main/java/org/apache/ignite/raft/client/Command.java} (81%)
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} (54%)
copy modules/{api/src/main/java/org/apache/ignite/table/mapper/KeyMapper.java => raft-client/src/main/java/org/apache/ignite/raft/client/ReadCommand.java} (83%)
copy modules/{api/src/main/java/org/apache/ignite/table/mapper/KeyMapper.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%)
copy modules/{rest/src/main/java/org/apache/ignite/rest/ErrorResult.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/ActionRequest.java} (50%)
copy modules/{cli/src/main/java/org/apache/ignite/cli/IgniteCLIException.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/ActionResponse.java} (56%)
copy modules/{table/src/main/java/org/apache/ignite/binary/BinaryObjects.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/AddLearnersRequest.java} (51%)
copy modules/{cli/src/main/java/org/apache/ignite/cli/builtins/module/ResolveResult.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/AddPeersRequest.java} (52%)
copy modules/{cli/src/main/java/org/apache/ignite/cli/builtins/module/ResolveResult.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/ChangePeersResponse.java} (50%)
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/IndexColumnImpl.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/GetLeaderRequest.java} (58%)
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/IndexColumnImpl.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/GetLeaderResponse.java} (57%)
copy modules/{rest/src/main/java/org/apache/ignite/rest/ErrorResult.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/GetPeersRequest.java} (50%)
copy modules/{cli/src/main/java/org/apache/ignite/cli/builtins/module/ResolveResult.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/GetPeersResponse.java} (50%)
create mode 100644 modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/RaftErrorResponse.java
copy modules/{cli/src/main/java/org/apache/ignite/cli/builtins/module/ResolveResult.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/RemoveLearnersRequest.java} (50%)
copy modules/{cli/src/main/java/org/apache/ignite/cli/builtins/module/ResolveResult.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/RemovePeersRequest.java} (51%)
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/IndexColumnImpl.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/SnapshotRequest.java} (58%)
copy modules/{rest/src/main/java/org/apache/ignite/rest/ErrorResult.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/TransferLeadershipRequest.java} (50%)
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} (55%)
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/IndexColumnImpl.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/ActionResponseImpl.java} (61%)
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/AddLearnersRequestImpl.java} (50%)
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/AddPeersRequestImpl.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/ChangePeersResponseImpl.java} (52%)
copy modules/{configuration/src/main/java/org/apache/ignite/configuration/ConfigurationChangeException.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/GetLeaderRequestImpl.java} (61%)
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} (59%)
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} (55%)
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} (54%)
create mode 100644 modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/RaftClientMessageFactory.java
create mode 100644 modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/RaftClientMessageFactoryImpl.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/RaftErrorResponseImpl.java} (51%)
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/RemoveLearnersRequestImpl.java} (51%)
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} (54%)
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/IndexColumnImpl.java => raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/SnapshotRequestImpl.java} (61%)
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/TransferLeadershipRequestImpl.java} (52%)
copy modules/{api/src/main/java/org/apache/ignite/schema/builder/SchemaObjectBuilder.java => raft-client/src/main/java/org/apache/ignite/raft/client/service/RaftGroupCommandListener.java} (64%)
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
create mode 100644 modules/rest/src/main/java/org/apache/ignite/rest/netty/RestApiHandler.java
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/builder/AbstractIndexBuilder.java => rest/src/main/java/org/apache/ignite/rest/netty/RestApiHttpRequest.java} (50%)
create mode 100644 modules/rest/src/main/java/org/apache/ignite/rest/netty/RestApiHttpResponse.java
create mode 100644 modules/rest/src/main/java/org/apache/ignite/rest/netty/RestApiInitializer.java
create mode 100644 modules/rest/src/main/java/org/apache/ignite/rest/routes/Route.java
create mode 100644 modules/rest/src/main/java/org/apache/ignite/rest/routes/Router.java
create mode 100644 modules/rest/src/test/java/org/apache/ignite/rest/presentation/json/JsonConverterTest.java
create mode 100644 modules/rest/src/test/java/org/apache/ignite/rest/presentation/json/TestConfigurationStorage.java
create mode 100644 modules/rest/src/test/java/org/apache/ignite/rest/routes/RouteTest.java