commit e8e5878e798a58ed79ab51b943bb08f0a73ad553
author dxichen <xrchen@uwaterloo.ca> Tue May 31 15:08:15 2022 -0700
committer dxichen <xrchen@uwaterloo.ca> Tue May 31 15:08:15 2022 -0700
tree c6474d0a5711a28d724a7b0302405c59763f32e7
parent 1c1e945a648de5b5277612296b923628937cf15f

exclude null for get all in rocksdb

samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala

diff --git a/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala b/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala
index fa093da..6a115c2 100644
--- a/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala
+++ b/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala
@@ -167,7 +167,9 @@
     }
     val map = new util.HashMap[Array[Byte], Array[Byte]]
     for (i <- 0 until keys.size()) {
-      map.put(keys.get(i), values.get(i))
+      if (values.get(i) != null) {
+        map.put(keys.get(i), values.get(i))
+      }
     }
     map
   }