enable rollsite gc

Signed-off-by: sagewe <wbwmat@gmail.com>
FederatedAI · Dec 25, 2023 · 315a2ec · 315a2ec
1 parent b6c058f
commit 315a2ec
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/java/osx/osx-broker/src/main/java/org/fedai/osx/broker/grpc/QueuePushReqStreamObserver.java b/java/osx/osx-broker/src/main/java/org/fedai/osx/broker/grpc/QueuePushReqStreamObserver.java
@@ -195,6 +195,9 @@ private void initEggroll(OsxContext context, Proxy.Packet firstRequest) {
             rpOptions.put(Dict.SERDES, rsHeader.getOptions().getOrDefault("serdes", SerdesTypes.PICKLE.name()));
         }
 
+        // use in-memory store here
+        rpOptions.put(Dict.STORE_TYPE_SNAKECASE, "IN_MEMORY");
+
         // table creates here
         RollPair rp = ctx.load(namespace, name, rpOptions);
         Integer partitionId = rsHeader.getPartitionId();