Toggle navigation
Home
java.util.List to java.util.concurrent.ConcurrentHashMap
No. of Instances - 2
No. of Commits - 2
No. of Projects - {'hadoop', 'pulsar'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
Add or Remove Method invocation
((MessageIdImpl)messageId).getPartitionIndex()
to
messageId1.getTopicName()
Collectors.groupingBy(TopicMessageIdImpl,Collectors.toSet())
to
Collectors.groupingBy(TopicMessageIdImpl::getTopicName,Collectors.toSet())
(MessageId)mid
to
mid.getInnerMessageId()
consumers.stream().mapToInt(ConsumerImpl::getAvailablePermits)
to
consumers.values().stream().mapToInt(ConsumerImpl::getAvailablePermits)
consumers.stream()
to
consumers.values().stream()
consumers.stream().mapToInt(ConsumerImpl::numMessagesInQueue).sum()
to
consumers.values().stream().mapToInt(ConsumerImpl::numMessagesInQueue).sum()
Other
MessageIdImpl::getPartitionIndex
to
TopicMessageIdImpl
0
to
totalAckDataLength
Cascading Type Change (Different)
MessageIdImpl
to
TopicMessageIdImpl
Rename Variable
futureList
to
futureMap
futureList
to
futureMap
futureList
to
futureMap
futureList
to
futureMap
futureList
to
futureMap
futureList
to
futureMap