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/05/19 15:37:33 UTC
[ignite-3] branch main updated (81e5476 -> 479ea87)
This is an automated email from the ASF dual-hosted git repository.
agura pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 81e5476 IGNITE-14077: Distributed schema manager. (#91)
add 479ea87 IGNITE-14389 Added in-memory meta storage implementation.
No new revisions were added by this update.
Summary of changes:
.../ignite/internal/affinity/AffinityManager.java | 34 +-
.../org/apache/ignite/internal/util/Cursor.java} | 15 +-
.../java/org/apache/ignite/lang/ByteArray.java | 17 +-
modules/metastorage-client/pom.xml | 6 +
.../client/ITMetaStorageServiceTest.java | 907 +++++----
.../internal/metastorage/client/CursorImpl.java | 84 +-
.../internal/metastorage/client/EntryImpl.java} | 73 +-
.../metastorage/client/MetaStorageServiceImpl.java | 268 ++-
.../metastorage/client}/CompactedException.java | 2 +-
.../ignite/metastorage/client/Condition.java | 347 ++++
.../ignite/metastorage/client}/Conditions.java | 48 +-
.../apache/ignite/metastorage/client}/Entry.java | 19 +-
.../ignite/metastorage/client/EntryEvent.java} | 24 +-
.../org/apache/ignite/metastorage/client}/Key.java | 2 +-
.../metastorage/client/MetaStorageService.java | 123 +-
.../ignite/metastorage/client/Operation.java | 166 ++
.../client}/OperationTimeoutException.java | 2 +-
.../ignite/metastorage/client}/Operations.java | 14 +-
.../ignite/metastorage/client/WatchEvent.java | 82 +
.../ignite/metastorage/client}/WatchListener.java | 6 +-
.../metastorage/common/ConditionType.java} | 58 +-
.../metastorage/common/OperationType.java} | 15 +-
.../metastorage/common/command/ConditionInfo.java | 89 +
.../metastorage/common/command/ErrorResponse.java} | 26 +-
.../metastorage/common/command/GetAllCommand.java | 34 +-
.../common/command/GetAndPutAllCommand.java | 28 +-
.../common/command/GetAndPutCommand.java | 13 +-
.../common/command/GetAndRemoveAllCommand.java | 23 +-
.../common/command/GetAndRemoveCommand.java | 13 +-
.../metastorage/common/command/GetCommand.java | 22 +-
.../metastorage/common/command/InvokeCommand.java | 75 +
...moveCommand.java => MultipleEntryResponse.java} | 30 +-
.../{PutCommand.java => OperationInfo.java} | 54 +-
.../metastorage/common/command/PutAllCommand.java | 51 +-
.../metastorage/common/command/PutCommand.java | 13 +-
.../metastorage/common/command/RangeCommand.java | 29 +-
.../common/command/RemoveAllCommand.java | 27 +-
.../metastorage/common/command/RemoveCommand.java | 13 +-
.../common/command/SingleEntryResponse.java | 92 +
.../common/command/WatchExactKeysCommand.java | 29 +-
.../common/command/WatchRangeKeysCommand.java | 30 +-
.../common/command/cursor/CursorCloseCommand.java | 3 +-
.../command/cursor/CursorHasNextCommand.java | 3 +-
.../common/command/cursor/CursorNextCommand.java | 3 +-
.../ignite/metastorage/common/Condition.java | 370 ----
.../apache/ignite/metastorage/common/Cursor.java | 27 -
.../ignite/metastorage/common/KeyValueStorage.java | 91 -
.../metastorage/common/KeyValueStorageImpl.java | 183 --
.../ignite/metastorage/common/Operation.java | 93 -
modules/metastorage-server/pom.xml | 64 +
.../metastorage/server/AbstractCondition.java} | 30 +-
.../metastorage/server}/CompactedException.java | 2 +-
.../internal/metastorage/server/Condition.java} | 34 +-
.../ignite/internal/metastorage/server/Entry.java | 190 ++
.../internal/metastorage/server/EntryEvent.java} | 42 +-
.../metastorage/server/ExistenceCondition.java | 74 +
.../metastorage/server/KeyValueStorage.java | 206 +++
.../internal/metastorage/server/Operation.java | 100 +
.../metastorage/server/RevisionCondition.java | 110 ++
.../server/SimpleInMemoryKeyValueStorage.java | 775 ++++++++
.../ignite/internal/metastorage/server/Value.java} | 55 +-
.../metastorage/server/ValueCondition.java | 82 +
.../internal/metastorage/server/WatchEvent.java | 72 +
.../server}/raft/MetaStorageCommandListener.java | 229 ++-
.../metastorage/server/ExistenceConditionTest.java | 71 +
.../metastorage/server/RevisionConditionTest.java | 113 ++
.../server/SimpleInMemoryKeyValueStorageTest.java | 1945 ++++++++++++++++++++
.../metastorage/server/ValueConditionTest.java | 60 +
modules/metastorage/pom.xml | 4 +-
.../internal/metastorage/MetaStorageManager.java | 173 +-
.../metastorage/watch/AggregatedWatch.java | 2 +-
.../internal/metastorage/watch/KeyCriterion.java | 44 +-
.../metastorage/watch/WatchAggregator.java | 49 +-
.../internal/metastorage/WatchAggregatorTest.java | 102 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 5 +-
.../storage/DistributedConfigurationStorage.java | 52 +-
.../ignite/internal/schema/SchemaManager.java | 47 +-
.../internal/table/distributed/TableManager.java | 14 +-
parent/pom.xml | 6 +
pom.xml | 1 +
80 files changed, 6489 insertions(+), 2040 deletions(-)
copy modules/{schema/src/main/java/org/apache/ignite/internal/util/Factory.java => core/src/main/java/org/apache/ignite/internal/util/Cursor.java} (83%)
rename modules/{metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/DummyEntry.java => metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/EntryImpl.java} (60%)
copy modules/{metastorage-common/src/main/java/org/apache/ignite/metastorage/common => metastorage-client/src/main/java/org/apache/ignite/metastorage/client}/CompactedException.java (97%)
create mode 100644 modules/metastorage-client/src/main/java/org/apache/ignite/metastorage/client/Condition.java
rename modules/{metastorage-common/src/main/java/org/apache/ignite/metastorage/common => metastorage-client/src/main/java/org/apache/ignite/metastorage/client}/Conditions.java (54%)
copy modules/{metastorage-common/src/main/java/org/apache/ignite/metastorage/common => metastorage-client/src/main/java/org/apache/ignite/metastorage/client}/Entry.java (77%)
rename modules/{metastorage-common/src/main/java/org/apache/ignite/metastorage/common/WatchEvent.java => metastorage-client/src/main/java/org/apache/ignite/metastorage/client/EntryEvent.java} (81%)
rename modules/{metastorage-common/src/main/java/org/apache/ignite/metastorage/common => metastorage-client/src/main/java/org/apache/ignite/metastorage/client}/Key.java (98%)
create mode 100644 modules/metastorage-client/src/main/java/org/apache/ignite/metastorage/client/Operation.java
rename modules/{metastorage-common/src/main/java/org/apache/ignite/metastorage/common => metastorage-client/src/main/java/org/apache/ignite/metastorage/client}/OperationTimeoutException.java (97%)
rename modules/{metastorage-common/src/main/java/org/apache/ignite/metastorage/common => metastorage-client/src/main/java/org/apache/ignite/metastorage/client}/Operations.java (79%)
create mode 100644 modules/metastorage-client/src/main/java/org/apache/ignite/metastorage/client/WatchEvent.java
rename modules/{metastorage-common/src/main/java/org/apache/ignite/metastorage/common => metastorage-client/src/main/java/org/apache/ignite/metastorage/client}/WatchListener.java (87%)
copy modules/{network/src/main/java/org/apache/ignite/network/internal/direct/DirectMarshallingUtils.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/ConditionType.java} (51%)
copy modules/{api/src/main/java/org/apache/ignite/table/InvokeProcessorException.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/OperationType.java} (76%)
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/ConditionInfo.java
copy modules/{api/src/main/java/org/apache/ignite/schema/ColumnarIndex.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/ErrorResponse.java} (63%)
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/InvokeCommand.java
copy modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/{RemoveCommand.java => MultipleEntryResponse.java} (57%)
copy modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/{PutCommand.java => OperationInfo.java} (51%)
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/SingleEntryResponse.java
delete mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Condition.java
delete mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Cursor.java
delete mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/KeyValueStorage.java
delete mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/KeyValueStorageImpl.java
delete mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Operation.java
create mode 100644 modules/metastorage-server/pom.xml
copy modules/{configuration/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationListener.java => metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/AbstractCondition.java} (60%)
rename modules/{metastorage-common/src/main/java/org/apache/ignite/metastorage/common => metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server}/CompactedException.java (97%)
copy modules/{vault/src/main/java/org/apache/ignite/internal/vault/common/Watcher.java => metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/Condition.java} (56%)
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/Entry.java
copy modules/{table/src/main/java/org/apache/ignite/binary/BinaryObjects.java => metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/EntryEvent.java} (55%)
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/ExistenceCondition.java
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/KeyValueStorage.java
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/Operation.java
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/RevisionCondition.java
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/SimpleInMemoryKeyValueStorage.java
rename modules/{metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Entry.java => metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/Value.java} (50%)
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/ValueCondition.java
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/WatchEvent.java
rename modules/{metastorage-common/src/main/java/org/apache/ignite/metastorage/common => metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server}/raft/MetaStorageCommandListener.java (53%)
create mode 100644 modules/metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/ExistenceConditionTest.java
create mode 100644 modules/metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/RevisionConditionTest.java
create mode 100644 modules/metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/SimpleInMemoryKeyValueStorageTest.java
create mode 100644 modules/metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/ValueConditionTest.java