[samza] branch fix-rockdb updated: exclude null for get all in rocksdb

[dc...@apache.org]

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

dchen pushed a commit to branch fix-rockdb
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/fix-rockdb by this push:
     new e8e5878e7 exclude null for get all in rocksdb
e8e5878e7 is described below

commit e8e5878e798a58ed79ab51b943bb08f0a73ad553
Author: dxichen <xr...@uwaterloo.ca>
AuthorDate: Tue May 31 15:08:15 2022 -0700

    exclude null for get all in rocksdb
---
 .../main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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 fa093da16..6a115c2cf 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 @@ class RocksDbKeyValueStore(
     }
     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
   }