This is an automated email from the ASF dual-hosted git repository.

agura pushed a commit to branch ignite-14389
in repository https://gitbox.apache.org/repos/asf/ignite-3.git

commit 1bd716bf5f5f7081327f4eb9459ae75b5cc20faa
Author: Andrey Gura <[email protected]>
AuthorDate: Thu Apr 15 21:18:56 2021 +0300

    IGNITE-14389 putAll initial (WIP)
---
 .../apache/ignite/internal/metastorage/server/KeyValueStorage.java | 2 ++
 .../internal/metastorage/server/SimpleInMemoryKeyValueStorage.java | 7 +++++++
 2 files changed, 9 insertions(+)

diff --git 
a/modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/KeyValueStorage.java
 
b/modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/KeyValueStorage.java
index 0596c4a..0f18ece 100644
--- 
a/modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/KeyValueStorage.java
+++ 
b/modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/KeyValueStorage.java
@@ -29,6 +29,8 @@ public interface KeyValueStorage {
     @NotNull
     Entry getAndPut(byte[] key, byte[] value);
 
+    void putAll(List<byte[]> keys, List<byte[]> values);
+
     void remove(byte[] key);
 
     @NotNull
diff --git 
a/modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/SimpleInMemoryKeyValueStorage.java
 
b/modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/SimpleInMemoryKeyValueStorage.java
index 8523f51..f532005 100644
--- 
a/modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/SimpleInMemoryKeyValueStorage.java
+++ 
b/modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/SimpleInMemoryKeyValueStorage.java
@@ -63,6 +63,13 @@ public class SimpleInMemoryKeyValueStorage implements 
KeyValueStorage {
         }
     }
 
+    @Override
+    public void putAll(List<byte[]> keys, List<byte[]> values) {
+        synchronized (mux) {
+
+        }
+    }
+
     @NotNull
     @Override public Entry get(byte[] key) {
         synchronized (mux) {

Reply via email to