fix ut.

Author: tanghaodong25

geaflow/geaflow-plugins/geaflow-store/geaflow-store-cstore/src/main/java/com/antgroup/geaflow/store/cstore/StaticGraphCStore.java

@@ -33,6 +33,7 @@
 import com.antgroup.geaflow.state.pushdown.inner.PushDownPbGenerator;
 import com.antgroup.geaflow.store.api.graph.BaseGraphStore;
 import com.antgroup.geaflow.store.api.graph.IStaticGraphStore;
+import com.antgroup.geaflow.store.config.StoreConfigKeys;
 import com.antgroup.geaflow.store.context.StoreContext;
 import com.antgroup.geaflow.store.cstore.encoder.EdgeEncoder;
 import com.antgroup.geaflow.store.cstore.encoder.EncoderFactory;
@@ -101,6 +102,7 @@ public void drop() {
     }
 
     private void rewriteConfig() {
+        this.config.put(StoreConfigKeys.STORE_FILTER_CODEGEN_ENABLE.getKey(), "false");
         String jobName = Configuration.getString(ExecutionConfigKeys.JOB_APP_NAME, this.config);
         String workerPath = Configuration.getString(ExecutionConfigKeys.JOB_WORK_PATH, this.config);
         this.config.put(CStoreConfigKeys.CSTORE_NAME_KEY, jobName);

geaflow/geaflow-plugins/geaflow-store/geaflow-store-memory/src/main/java/com/antgroup/geaflow/store/memory/KListMemoryStore.java

@@ -14,7 +14,7 @@
 
 package com.antgroup.geaflow.store.memory;
 
-import com.antgroup.geaflow.store.IBaseStore;
+import com.antgroup.geaflow.store.IStatefulStore;
 import com.antgroup.geaflow.store.api.key.IKListStore;
 import com.antgroup.geaflow.store.context.StoreContext;
 import java.util.ArrayList;
@@ -23,7 +23,7 @@
 import java.util.List;
 import java.util.Map;
 
-public class KListMemoryStore<K, V> implements IBaseStore, IKListStore<K, V> {
+public class KListMemoryStore<K, V> implements IStatefulStore, IKListStore<K, V> {
 
     private Map<K, List<V>> memoryStore = new HashMap<>();
 
@@ -58,4 +58,29 @@ public void flush() {
     public void close() {
         this.memoryStore.clear();
     }
+
+    @Override
+    public void archive(long checkpointId) {
+
+    }
+
+    @Override
+    public void recovery(long checkpointId) {
+
+    }
+
+    @Override
+    public long recoveryLatest() {
+        return 0;
+    }
+
+    @Override
+    public void compact() {
+
+    }
+
+    @Override
+    public void drop() {
+
+    }
 }

geaflow/geaflow-plugins/geaflow-store/geaflow-store-memory/src/main/java/com/antgroup/geaflow/store/memory/KMapMemoryStore.java

@@ -14,7 +14,7 @@
 
 package com.antgroup.geaflow.store.memory;
 
-import com.antgroup.geaflow.store.IBaseStore;
+import com.antgroup.geaflow.store.IStatefulStore;
 import com.antgroup.geaflow.store.api.key.IKMapStore;
 import com.antgroup.geaflow.store.context.StoreContext;
 import java.util.ArrayList;
@@ -23,7 +23,7 @@
 import java.util.List;
 import java.util.Map;
 
-public class KMapMemoryStore<K, UK, UV> implements IBaseStore, IKMapStore<K, UK, UV> {
+public class KMapMemoryStore<K, UK, UV> implements IStatefulStore, IKMapStore<K, UK, UV> {
 
     private Map<K, Map<UK, UV>> memoryStore = new HashMap<>();
 
@@ -79,4 +79,29 @@ public void flush() {
     public void close() {
         this.memoryStore.clear();
     }
+
+    @Override
+    public void archive(long checkpointId) {
+
+    }
+
+    @Override
+    public void recovery(long checkpointId) {
+
+    }
+
+    @Override
+    public long recoveryLatest() {
+        return 0;
+    }
+
+    @Override
+    public void compact() {
+
+    }
+
+    @Override
+    public void drop() {
+
+    }
 }

geaflow/geaflow-plugins/geaflow-store/geaflow-store-memory/src/main/java/com/antgroup/geaflow/store/memory/KVMemoryStore.java

@@ -14,13 +14,13 @@
 
 package com.antgroup.geaflow.store.memory;
 
-import com.antgroup.geaflow.store.IBaseStore;
+import com.antgroup.geaflow.store.IStatefulStore;
 import com.antgroup.geaflow.store.api.key.IKVStore;
 import com.antgroup.geaflow.store.context.StoreContext;
 import java.util.HashMap;
 import java.util.Map;
 
-public class KVMemoryStore<K, V> implements IBaseStore, IKVStore<K, V> {
+public class KVMemoryStore<K, V> implements IStatefulStore, IKVStore<K, V> {
 
     private Map<K, V> memoryStore = new HashMap<>();
 
@@ -53,4 +53,29 @@ public void flush() {
     public void close() {
         this.memoryStore.clear();
     }
+
+    @Override
+    public void archive(long checkpointId) {
+
+    }
+
+    @Override
+    public void recovery(long checkpointId) {
+
+    }
+
+    @Override
+    public long recoveryLatest() {
+        return 0;
+    }
+
+    @Override
+    public void compact() {
+
+    }
+
+    @Override
+    public void drop() {
+
+    }
 }