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/05/20 14:54:37 UTC
[ignite-3] branch ignite-14388 updated (5a35e34 -> 74b7747)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-14388
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 5a35e34 Merge branch 'main' into ignite-14388
add 479ea87 IGNITE-14389 Added in-memory meta storage implementation.
add 1a32ff6 IGNITE-14692 Validate tuple for STRICT schema (#123)
add 74b7747 Merge branch 'main' into ignite-14388
No new revisions were added by this update.
Summary of changes:
.../ignite/internal/affinity/AffinityManager.java | 34 +-
.../main/java/org/apache/ignite/table/Tuple.java | 7 +
.../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 +-
.../{Bitmask.java => BitmaskNativeType.java} | 20 +-
.../org/apache/ignite/internal/schema/Column.java | 74 +-
.../org/apache/ignite/internal/schema/Columns.java | 22 +-
.../apache/ignite/internal/schema/NativeType.java | 68 +-
.../ignite/internal/schema/NativeTypeSpec.java | 61 +
.../apache/ignite/internal/schema/NativeTypes.java | 189 ++
.../ignite/internal/schema/NumericNativeType.java | 88 +
.../org/apache/ignite/internal/schema/Row.java | 8 +-
.../ignite/internal/schema/RowAssembler.java | 40 +-
.../ignite/internal/schema/SchemaDescriptor.java | 28 +-
.../ignite/internal/schema/SchemaManager.java | 75 +-
...dIndexColumnImpl.java => VarlenNativeType.java} | 27 +-
.../benchmarks/SerializerBenchmarkTest.java | 5 +-
.../apache/ignite/internal/schema/ColumnTest.java | 13 +-
.../apache/ignite/internal/schema/ColumnsTest.java | 280 +--
.../ignite/internal/schema/NativeTypeTest.java | 65 +-
.../ignite/internal/schema/RowAssemblerTest.java | 81 +-
.../org/apache/ignite/internal/schema/RowTest.java | 34 +-
.../internal/schema/SchemaDescriptorTest.java | 17 +-
.../internal/schema/SchemaRegistryImplTest.java | 73 +-
.../apache/ignite/internal/schema/TestUtils.java | 2 +-
.../schema/marshaller/JavaSerializerTest.java | 71 +-
.../marshaller/reflection/FieldAccessorTest.java | 30 +-
.../ignite/distributed/ITDistributedTableTest.java | 12 +-
.../ignite/internal/table/AbstractTableView.java | 2 +-
.../internal/table/ColumnNotFoundException.java} | 13 +-
.../ignite/internal/table/KVBinaryViewImpl.java | 3 +-
.../internal/table/SchemaMismatchException.java} | 11 +-
.../apache/ignite/internal/table/TableImpl.java | 2 +-
.../org/apache/ignite/internal/table/TableRow.java | 15 +
.../ignite/internal/table/TupleBuilderImpl.java | 32 +-
.../ignite/internal/table/TupleMarshallerImpl.java | 62 +-
.../internal/table/distributed/TableManager.java | 14 +-
.../internal/table/KVViewOperationsTest.java | 54 +-
.../internal/table/StrictSchemaOperationsTest.java | 108 ++
.../table/TableBinaryViewOperationsTest.java | 148 +-
.../internal/table/impl/TestTupleBuilder.java} | 25 +-
parent/pom.xml | 6 +
pom.xml | 1 +
116 files changed, 7785 insertions(+), 2562 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
rename modules/schema/src/main/java/org/apache/ignite/internal/schema/{Bitmask.java => BitmaskNativeType.java} (81%)
create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/NativeTypes.java
create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/NumericNativeType.java
copy modules/schema/src/main/java/org/apache/ignite/internal/schema/{SortedIndexColumnImpl.java => VarlenNativeType.java} (65%)
copy modules/{cli/src/test/java/org/apache/ignite/cli/AbstractCliTest.java => table/src/main/java/org/apache/ignite/internal/table/ColumnNotFoundException.java} (75%)
copy modules/{api/src/main/java/org/apache/ignite/table/InvokeProcessorException.java => table/src/main/java/org/apache/ignite/internal/table/SchemaMismatchException.java} (75%)
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/StrictSchemaOperationsTest.java
copy modules/table/src/{main/java/org/apache/ignite/internal/table/TupleBuilderImpl.java => test/java/org/apache/ignite/internal/table/impl/TestTupleBuilder.java} (85%)