Toggle navigation
Home
com.google.common.collect.RangeSet to org.apache.pulsar.common.util.collections.LongPairRangeSet
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'pulsar'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: External -> Internal
Mapping:
Add or Remove Method invocation
individualDeletedMessages.add(Range.openClosed(new PositionImpl(messageRange.getLowerEndpoint()),new PositionImpl(messageRange.getUpperEndpoint())))
to
individualDeletedMessages.addOpenClosed(messageRange.getLowerEndpoint().getLedgerId(),messageRange.getLowerEndpoint().getEntryId(),messageRange.getUpperEndpoint().getLedgerId(),messageRange.getUpperEndpoint().getEntryId())
individualDeletedMessages.asRanges()
to
individualDeletedMessages
positions.stream().filter(position -> individualDeletedMessages.contains((PositionImpl)position) || ((PositionImpl)position).compareTo(markDeletePosition) < 0)
to
positions.stream().filter(position -> individualDeletedMessages.contains(((PositionImpl)position).getLedgerId(),((PositionImpl)position).getEntryId()) || ((PositionImpl)position).compareTo(markDeletePosition) < 0)
individualDeletedMessages.contains(newMarkDeletePosition)
to
individualDeletedMessages.contains(newMarkDeletePosition.getLedgerId(),newMarkDeletePosition.getEntryId())
positionAfterNewMarkDelete
to
positionAfterNewMarkDelete.getLedgerId()
individualDeletedMessages.contains(positionAfterNewMarkDelete)
to
individualDeletedMessages.contains(positionAfterNewMarkDelete.getLedgerId(),positionAfterNewMarkDelete.getEntryId())
individualDeletedMessages.contains(position)
to
individualDeletedMessages.contains(position.getLedgerId(),position.getEntryId())
Collections2.filter(entries,entry -> { boolean includeEntry=!individualDeletedMessages.contains((PositionImpl)entry.getPosition()); if (!includeEntry) { if (log.isDebugEnabled()) { log.debug("[{}] [{}] Filtering entry at {} - already deleted",ledger.getName(),name,entry.getPosition()); } entry.release(); } return includeEntry; } )
to
Collections2.filter(entries,entry -> { boolean includeEntry=!individualDeletedMessages.contains(((PositionImpl)entry.getPosition()).getLedgerId(),((PositionImpl)entry.getPosition()).getEntryId()); if (!includeEntry) { if (log.isDebugEnabled()) { log.debug("[{}] [{}] Filtering entry at {} - already deleted",ledger.getName(),name,entry.getPosition()); } entry.release(); } return includeEntry; } )
individualDeletedMessages.asRanges().size()
to
individualDeletedMessages.size()
position
to
position.getLedgerId()
Update argument list (Method invocation)
rangeContaining
to
rangeContaining
rangeContaining
to
rangeContaining