You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2022/08/17 02:19:15 UTC
[pulsar] 03/03: [imp][managed-ledger] Optimize filterReadEntries usage of Entry interface ledger (#17108)
This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 5fbc911ae380c6126e4d0150357d58315c09c20e
Author: Michael Marshall <mm...@apache.org>
AuthorDate: Tue Aug 16 13:47:00 2022 -0500
[imp][managed-ledger] Optimize filterReadEntries usage of Entry interface ledger (#17108)
---
.../java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java
index 4c688b2d9be..78ec42b7183 100644
--- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java
+++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java
@@ -2288,9 +2288,7 @@ public class ManagedCursorImpl implements ManagedCursor {
} else {
// Remove from the entry list all the entries that were already marked for deletion
return Lists.newArrayList(Collections2.filter(entries, entry -> {
- boolean includeEntry = !individualDeletedMessages.contains(
- ((PositionImpl) entry.getPosition()).getLedgerId(),
- ((PositionImpl) entry.getPosition()).getEntryId());
+ boolean includeEntry = !individualDeletedMessages.contains(entry.getLedgerId(), entry.getEntryId());
if (!includeEntry) {
if (log.isDebugEnabled()) {
log.debug("[{}] [{}] Filtering entry at {} - already deleted", ledger.getName(), name,