This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push: new 89cf515 MINOR: replace deprecated remove with delete (#5565) 89cf515 is described below commit 89cf515aecd1ce3a5265a5df94357b3b55694522 Author: Guozhang Wang <wangg...@gmail.com> AuthorDate: Fri Aug 24 08:53:54 2018 -0700 MINOR: replace deprecated remove with delete (#5565) Reviewers: Matthias J. Sax <matth...@confluent.io> --- .../kafka/streams/state/internals/RocksDBSegmentedBytesStore.java | 2 +- .../java/org/apache/kafka/streams/state/internals/RocksDBStore.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java index fccb6c1..fa71465 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java @@ -237,7 +237,7 @@ class RocksDBSegmentedBytesStore implements SegmentedBytesStore { try { final WriteBatch batch = writeBatchMap.computeIfAbsent(segment, s -> new WriteBatch()); if (record.value == null) { - batch.remove(record.key); + batch.delete(record.key); } else { batch.put(record.key, record.value); } diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java index 559f4a5..fbf7df3 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java @@ -283,7 +283,7 @@ public class RocksDBStore implements KeyValueStore<Bytes, byte[]> { try (final WriteBatch batch = new WriteBatch()) { for (final KeyValue<byte[], byte[]> record : records) { if (record.value == null) { - batch.remove(record.key); + batch.delete(record.key); } else { batch.put(record.key, record.value); } @@ -323,7 +323,7 @@ public class RocksDBStore implements KeyValueStore<Bytes, byte[]> { for (final KeyValue<Bytes, byte[]> entry : entries) { Objects.requireNonNull(entry.key, "key cannot be null"); if (entry.value == null) { - batch.remove(entry.key.get()); + batch.delete(entry.key.get()); } else { batch.put(entry.key.get(), entry.value); }