Type Changes:

Home

Projects

Type Before Type After No. of Instances No. of Commits No. of Projects Hierarchy Relation Primitive Info Namespace
java.util.concurrent.ScheduledExecutorService java.util.concurrent.ExecutorService 1 1 1 R_SUPER_T - Jdk -> Jdk
io.netty.buffer.ByteBuf void 1 1 1 - - External -> Jdk
java.lang.String com.yahoo.pulsar.common.policies.data.loadbalancer.LoadReport 2 1 1 Composition - Jdk -> Internal
long int 12 5 1 - Narrowing Jdk -> Jdk
com.yahoo.pulsar.discovery.service.DiscoveryService com.yahoo.pulsar.discovery.service.DiscoveryServiceServlet 3 1 1 - - Internal -> Internal
com.yahoo.pulsar.common.policies.data.BundlesData java.lang.reflect.AccessibleObject 1 1 1 - - Internal -> Jdk
org.json.JSONObject java.lang.String 1 1 1 - - External -> Jdk
void java.util.Set<? extendsorg.apache.bookkeeper.mledger.Position> 2 1 1 - - Jdk -> Jdk
com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashSet com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashMap 2 1 1 - - Internal -> Internal
java.text.SimpleDateFormat java.time.format.DateTimeFormatter 4 1 1 - - Jdk -> Jdk
void int 1 1 1 - - Jdk -> Jdk
io.netty.channel.ChannelPromise org.apache.commons.lang3.tuple.Pair<io.netty.channel.ChannelPromise, java.lang.Integer> 1 1 1 SIBLING - External -> External
com.yahoo.pulsar.client.impl.ConsumerBase com.yahoo.pulsar.client.impl.ConsumerImpl 1 1 1 R_SUPER_T - Internal -> Internal
com.yahoo.pulsar.broker.lookup.LookupResult java.util.concurrent.CompletableFuture<com.yahoo.pulsar.broker.lookup.LookupResult> 1 1 1 - - Internal -> Jdk
com.yahoo.pulsar.common.naming.ServiceUnitId com.yahoo.pulsar.common.naming.NamespaceBundle 23 1 1 T_SUPER_R - Internal -> Internal
java.util.Map.Entry java.util.Optional 3 1 1 - - Jdk -> Jdk
com.google.common.cache.LoadingCache com.github.benmanes.caffeine.cache.AsyncLoadingCache 2 1 1 SIBLING - External -> External
com.google.common.cache.Cache com.github.benmanes.caffeine.cache.AsyncLoadingCache 1 1 1 SIBLING - External -> External
com.yahoo.pulsar.broker.namespace.NamespaceEphemeralData java.util.Optional<com.yahoo.pulsar.broker.namespace.NamespaceEphemeralData> 1 1 1 - - Internal -> Jdk
void java.util.concurrent.CompletableFuture<java.util.Optional<com.yahoo.pulsar.common.policies.data.LocalPolicies>> 1 1 1 - - Jdk -> Jdk
com.yahoo.pulsar.common.naming.NamespaceName com.yahoo.pulsar.common.naming.NamespaceBundle 2 1 1 Composition - Internal -> Internal
com.yahoo.pulsar.common.lookup.data.LookupData void 1 1 1 - - Internal -> Jdk
com.yahoo.pulsar.common.policies.impl.NamespaceIsolationPolicies java.util.Optional<com.yahoo.pulsar.common.policies.impl.NamespaceIsolationPolicies> 1 1 1 - - Internal -> Jdk
com.yahoo.pulsar.common.policies.data.Policies java.util.Optional<com.yahoo.pulsar.common.policies.data.Policies> 1 1 1 - - Internal -> Jdk
java.util.concurrent.ExecutorService io.netty.channel.EventLoopGroup 2 1 1 - - Jdk -> External
com.ning.http.client.AsyncHttpClientConfig.Builder org.asynchttpclient.DefaultAsyncHttpClientConfig.Builder 1 1 1 SIBLING - External -> External
javax.net.ssl.SSLContext io.netty.handler.ssl.SslContext 1 1 1 - - Jdk -> External
boolean java.util.concurrent.CompletableFuture<java.lang.Boolean> 5 1 1 - - Jdk -> Jdk
java.util.List java.util.Set 19 4 1 SIBLING - Jdk -> Jdk
java.util.List java.lang.Iterable 1 1 1 R_SUPER_T - Jdk -> Jdk
com.yahoo.pulsar.client.impl.ConnectionPool com.yahoo.pulsar.client.impl.PulsarClientImpl 2 1 1 SIBLING - Internal -> Internal
org.json.JSONObject com.google.gson.JsonObject 13 1 1 SIBLING - External -> External
int java.lang.String 8 3 1 - - Jdk -> Jdk
org.json.JSONArray com.google.gson.JsonArray 7 1 1 SIBLING - External -> External
com.yahoo.pulsar.discovery.service.BrokerDiscoveryProvider com.yahoo.pulsar.discovery.service.DiscoveryService 2 1 1 Composition - Internal -> Internal
com.yahoo.pulsar.common.policies.data.PersistentTopicStats com.yahoo.pulsar.common.policies.data.PartitionedTopicStats 1 1 1 R_SUPER_T - Internal -> Internal
java.util.List<java.lang.String> com.yahoo.pulsar.common.policies.data.PersistentTopicInternalStats 1 1 1 - - Jdk -> Internal
com.yahoo.pulsar.common.policies.data.PartitionedTopicStats com.yahoo.pulsar.common.policies.data.PersistentTopicStats 1 1 1 R_SUPER_T - Internal -> Internal
com.yahoo.pulsar.common.policies.data.PersistentTopicInternalStats java.util.List<java.lang.String> 1 1 1 - - Internal -> Jdk
void java.util.concurrent.CompletableFuture<java.lang.Void> 16 6 1 - - Jdk -> Jdk
com.yahoo.pulsar.broker.ServiceConfiguration com.yahoo.pulsar.websocket.service.WebSocketProxyConfiguration 6 1 1 - - Internal -> Internal
com.yahoo.pulsar.client.api.Producer com.yahoo.pulsar.client.impl.ProducerImpl 2 1 1 - - Internal -> Internal
java.util.concurrent.atomic.AtomicLong long 5 2 1 - - Jdk -> Jdk
java.util.concurrent.atomic.AtomicReference<org.apache.bookkeeper.mledger.impl.OpReadEntry> org.apache.bookkeeper.mledger.impl.OpReadEntry 1 1 1 - - Jdk -> Internal
java.util.concurrent.atomic.AtomicReference<com.yahoo.pulsar.client.impl.ClientCnx> com.yahoo.pulsar.client.impl.ClientCnx 1 1 1 - - Jdk -> Internal
java.util.concurrent.atomic.AtomicInteger int 8 1 1 - - Jdk -> Jdk
java.util.concurrent.atomic.AtomicBoolean int 3 1 1 - - Jdk -> Jdk
java.util.concurrent.atomic.AtomicReference<com.yahoo.pulsar.broker.service.Consumer> com.yahoo.pulsar.broker.service.Consumer 1 1 1 - - Jdk -> Internal
java.util.concurrent.atomic.AtomicReference<org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl.State> org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl.State 4 1 1 - - Jdk -> Internal
com.yahoo.pulsar.discovery.service.web.ZookeeperCacheLoader com.yahoo.pulsar.zookeeper.GlobalZooKeeperCache 1 1 1 SIBLING - Internal -> Internal
java.util.List<java.lang.Double> java.lang.Double 2 1 1 - - Jdk -> Jdk
org.apache.bookkeeper.mledger.impl.MetaStore.Version org.apache.bookkeeper.mledger.impl.MetaStore.Stat 22 1 1 - - Internal -> Internal
org.apache.bookkeeper.mledger.impl.MetaStoreImplZookeeper.ZKVersion org.apache.bookkeeper.mledger.impl.MetaStoreImplZookeeper.ZKStat 1 1 1 - - Internal -> Internal
com.yahoo.pulsar.broker.loadbalance.LoadManager java.util.concurrent.atomic.AtomicReference<com.yahoo.pulsar.broker.loadbalance.LoadManager> 9 1 1 - - Internal -> Jdk
org.apache.bookkeeper.mledger.impl.EntryImpl io.netty.util.Recycler.Handle 1 1 1 Composition - Internal -> External
void boolean 7 7 1 - - Jdk -> Jdk
io.netty.util.ResourceLeak io.netty.util.ResourceLeakTracker<com.yahoo.pulsar.common.api.DoubleByteBuf> 1 1 1 SIBLING - External -> External
java.util.concurrent.ConcurrentSkipListMap java.util.concurrent.ConcurrentNavigableMap 1 1 1 R_SUPER_T - Jdk -> Jdk
com.yahoo.pulsar.client.api.PulsarClient com.yahoo.pulsar.client.impl.PulsarClientImpl 2 1 1 T_SUPER_R - Internal -> Internal
org.eclipse.jetty.websocket.servlet.WebSocketServlet javax.servlet.Servlet 1 1 1 - - External -> External
long com.yahoo.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers 1 1 1 - - Jdk -> Internal
com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashMap<org.apache.bookkeeper.mledger.impl.PositionImpl, java.lang.Integer> org.apache.bookkeeper.util.collections.ConcurrentLongLongPairHashMap 2 1 1 - - Internal -> External
java.util.TreeSet<org.apache.bookkeeper.mledger.impl.PositionImpl> com.yahoo.pulsar.common.util.collections.ConcurrentLongPairSet 1 1 1 - - Jdk -> Internal
com.yahoo.pulsar.broker.service.Subscription ? extendscom.yahoo.pulsar.broker.service.Subscription 3 1 1 R_SUPER_T - Internal -> Internal
com.yahoo.pulsar.utils.StatsOutputStream com.yahoo.pulsar.utils.SimpleTextOutputStream 5 1 1 R_SUPER_T - Internal -> Internal
java.util.concurrent.CompletableFuture<java.lang.Boolean> java.lang.Boolean 3 1 1 - - Jdk -> Jdk
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandUnsubscribe.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandUnsubscribe.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSuccess.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandSuccess.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConsumerStats org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStats 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadata org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadata 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSendReceipt org.apache.pulsar.common.api.proto.PulsarApi.CommandSendReceipt 18 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.MessageMetadata org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadata 15 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPing.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandPing.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessages org.apache.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessages 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConnect.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandConnect.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.ServerError org.apache.pulsar.common.api.proto.PulsarApi.ServerError 20 1 1 - - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConsumerStats.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStats.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandError.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandError.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandFlow.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandFlow.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSuccess org.apache.pulsar.common.api.proto.PulsarApi.CommandSuccess 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.BaseCommand.Type org.apache.pulsar.common.api.proto.PulsarApi.BaseCommand.Type 4 1 1 - - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConnected org.apache.pulsar.common.api.proto.PulsarApi.CommandConnected 15 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSendError org.apache.pulsar.common.api.proto.PulsarApi.CommandSendError 15 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponse.LookupType org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponse.LookupType 4 1 1 - - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer 20 1 1 SIBLING - Internal -> Internal
java.net.URL java.io.InputStream 1 1 1 - - Jdk -> Jdk
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandLookupTopic org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopic 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandProducer.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandProducer.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConsumerStatsResponse org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStatsResponse 15 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.BaseCommand org.apache.pulsar.common.api.proto.PulsarApi.BaseCommand 15 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopic org.apache.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopic 20 1 1 SIBLING - Internal -> Internal
java.io.InputStream java.net.URL 1 1 1 - - Jdk -> Jdk
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandLookupTopic.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopic.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandMessage.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandMessage.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CompressionType org.apache.pulsar.common.api.proto.PulsarApi.CompressionType 4 1 1 - - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSend org.apache.pulsar.common.api.proto.PulsarApi.CommandSend 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandCloseProducer org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseProducer 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPong.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandPong.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandProducerSuccess org.apache.pulsar.common.api.proto.PulsarApi.CommandProducerSuccess 15 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadata.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadata.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.KeyValue org.apache.pulsar.common.api.proto.PulsarApi.KeyValue 27 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConnect org.apache.pulsar.common.api.proto.PulsarApi.CommandConnect 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandProducer org.apache.pulsar.common.api.proto.PulsarApi.CommandProducer 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandAck.AckType org.apache.pulsar.common.api.proto.PulsarApi.CommandAck.AckType 4 1 1 - - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.AuthMethod org.apache.pulsar.common.api.proto.PulsarApi.AuthMethod 4 1 1 - - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandError org.apache.pulsar.common.api.proto.PulsarApi.CommandError 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponse org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponse 15 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSubscribe.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandSubscribe.Builder 1 1 1 SIBLING - Internal -> Internal
java.util.concurrent.CompletableFuture<java.lang.Void> void 12 4 1 - - Jdk -> Jdk
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandFlow org.apache.pulsar.common.api.proto.PulsarApi.CommandFlow 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponse org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponse 15 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandMessage org.apache.pulsar.common.api.proto.PulsarApi.CommandMessage 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.KeyValue.Builder org.apache.pulsar.common.api.proto.PulsarApi.KeyValue.Builder 6 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandAck.ValidationError org.apache.pulsar.common.api.proto.PulsarApi.CommandAck.ValidationError 4 1 1 - - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopic.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopic.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.MessageIdData.Builder org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData.Builder 7 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSubscribe.SubType org.apache.pulsar.common.api.proto.PulsarApi.CommandSubscribe.SubType 4 1 1 - - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSend.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandSend.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandAck org.apache.pulsar.common.api.proto.PulsarApi.CommandAck 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.MessageIdData org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData 41 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSubscribe org.apache.pulsar.common.api.proto.PulsarApi.CommandSubscribe 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandCloseProducer.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseProducer.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandAck.Builder org.apache.pulsar.common.api.proto.PulsarApi.CommandAck.Builder 1 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponse.LookupType org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponse.LookupType 4 1 1 - - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPing org.apache.pulsar.common.api.proto.PulsarApi.CommandPing 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.SingleMessageMetadata org.apache.pulsar.common.api.proto.PulsarApi.SingleMessageMetadata 15 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPong org.apache.pulsar.common.api.proto.PulsarApi.CommandPong 20 1 1 SIBLING - Internal -> Internal
com.yahoo.pulsar.common.api.proto.PulsarApi.CommandUnsubscribe org.apache.pulsar.common.api.proto.PulsarApi.CommandUnsubscribe 20 1 1 SIBLING - Internal -> Internal
java.net.InetSocketAddress org.apache.commons.lang3.tuple.Pair<java.net.InetSocketAddress, java.net.InetSocketAddress> 4 1 1 SIBLING - Jdk -> External
org.apache.pulsar.common.api.proto.PulsarApi.CommandConnect int 1 1 1 Composition - Internal -> Jdk
org.apache.pulsar.broker.stats.TopicLoadStats org.apache.pulsar.broker.stats.DimensionStats 1 1 1 - - Internal -> Internal
org.apache.pulsar.broker.service.persistent.PersistentReplicator org.apache.pulsar.broker.service.Replicator 4 1 1 - - Internal -> Internal
org.apache.pulsar.broker.service.persistent.PersistentTopic org.apache.pulsar.broker.service.Topic 26 1 1 R_SUPER_T - Internal -> Internal
org.apache.pulsar.broker.service.persistent.PersistentSubscription org.apache.pulsar.broker.service.Subscription 7 1 1 R_SUPER_T - Internal -> Internal
? extendsorg.apache.pulsar.broker.service.Subscription org.apache.pulsar.broker.service.Subscription 1 1 1 T_SUPER_R - Internal -> Internal
org.apache.commons.lang3.tuple.MutablePair<io.netty.channel.ChannelPromise, java.lang.Integer> org.apache.pulsar.broker.service.Consumer.SendMessageInfo 1 1 1 - - External -> Internal
org.apache.commons.lang3.tuple.Pair<io.netty.channel.ChannelPromise, java.lang.Integer> org.apache.pulsar.broker.service.Consumer.SendMessageInfo 1 1 1 - - External -> Internal
int void 1 1 1 - - Jdk -> Jdk
org.apache.pulsar.broker.lookup.LookupResult java.util.Optional<org.apache.pulsar.broker.lookup.LookupResult> 5 1 1 - - Internal -> Jdk
java.net.URL java.util.Optional<java.net.URL> 4 1 1 - - Jdk -> Jdk
java.lang.String byte 15 6 1 - - Jdk -> Jdk
java.lang.reflect.Field org.apache.pulsar.broker.service.BrokerService.ConfigField 3 1 1 Composition - Jdk -> Internal
java.lang.String java.util.Optional<java.lang.String> 9 4 1 - - Jdk -> Jdk
org.apache.pulsar.client.impl.MessageIdImpl org.apache.pulsar.client.impl.BatchMessageIdImpl 1 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.client.api.MessageId org.apache.pulsar.client.impl.BatchMessageIdImpl 1 1 1 - - Internal -> Internal
org.apache.bookkeeper.mledger.Position org.apache.bookkeeper.mledger.impl.PositionImpl 2 1 1 T_SUPER_R - Internal -> Internal
org.apache.bookkeeper.mledger.impl.PositionImpl org.apache.bookkeeper.mledger.impl.ManagedCursorImpl.MarkDeleteEntry 2 1 1 Composition - Internal -> Internal
org.apache.pulsar.broker.service.Topic.PublishCallback org.apache.pulsar.broker.service.Topic.PublishContext 4 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.Message java.util.List<org.apache.pulsar.client.api.Message> 3 1 1 - - Internal -> Jdk
java.lang.String org.apache.commons.lang3.tuple.Pair<java.lang.String, java.lang.Long> 6 1 1 SIBLING - Jdk -> External
java.util.List org.apache.pulsar.common.util.collections.ConcurrentOpenHashSet 6 1 1 - - Jdk -> Internal
org.apache.pulsar.common.api.proto.PulsarApi.KeyByteValue.Builder org.apache.pulsar.common.api.proto.PulsarApi.EncryptionKeys.Builder 3 1 1 SIBLING - Internal -> Internal
byte org.apache.pulsar.client.api.EncryptionKeyInfo 3 1 1 - - Jdk -> Internal
org.apache.pulsar.common.partition.PartitionedTopicMetadata int 1 1 1 Composition - Internal -> Jdk
org.apache.pulsar.policies.data.loadbalancer.LoadReport org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport 15 2 1 R_SUPER_T - Internal -> Internal
void org.apache.pulsar.policies.data.loadbalancer.LocalBrokerData 2 1 1 - - Jdk -> Internal
com.google.gson.JsonObject org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport 1 1 1 - - External -> Internal
org.apache.pulsar.policies.data.loadbalancer.LoadReport org.apache.pulsar.policies.data.loadbalancer.LocalBrokerData 1 1 1 SIBLING - Internal -> Internal
org.apache.kafka.clients.producer.Producer org.apache.pulsar.client.impl.ProducerImpl 1 1 1 - - Internal -> Internal
org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport 5 1 1 R_SUPER_T - Internal -> Internal
java.lang.Void org.apache.pulsar.common.policies.data.ClusterData 2 1 1 - - Jdk -> Internal
org.apache.pulsar.client.impl.PulsarClientImpl org.apache.pulsar.client.api.ClientConfiguration 1 1 1 Composition - Internal -> Internal
org.apache.pulsar.client.impl.MessageIdImpl org.apache.pulsar.client.api.MessageId 18 4 1 R_SUPER_T - Internal -> Internal
java.util.Map<java.lang.String, java.lang.String> java.lang.String 5 5 1 - - Jdk -> Jdk
boolean int 1 1 1 - - Jdk -> Jdk
io.netty.buffer.ByteBuf org.apache.pulsar.common.api.ByteBufPair 19 1 1 Composition - External -> Internal
long java.lang.Long 4 2 1 - Boxing Jdk -> Jdk
org.apache.pulsar.common.api.ByteBufPair io.netty.buffer.ByteBuf 2 1 1 Composition - Internal -> External
org.apache.pulsar.broker.loadbalance.ResourceUnit java.util.Optional<org.apache.pulsar.broker.loadbalance.ResourceUnit> 5 1 1 - - Internal -> Jdk
org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies java.util.Optional<org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies> 2 1 1 - - Internal -> Jdk
org.apache.pulsar.common.policies.NamespaceIsolationPolicy java.util.Optional<org.apache.pulsar.common.policies.NamespaceIsolationPolicy> 4 1 1 - - Internal -> Jdk
java.lang.String org.apache.pulsar.broker.service.Subscription 4 1 1 - - Jdk -> Internal
java.net.ServerSocket java.io.FileReader 1 1 1 SIBLING - Jdk -> Jdk
int double 1 1 1 - Widening Jdk -> Jdk
java.lang.Integer java.lang.Double 3 1 1 SIBLING - Jdk -> Jdk
boolean org.apache.pulsar.client.api.ClientConfiguration 1 1 1 Composition - Jdk -> Internal
org.apache.pulsar.broker.authorization.AuthorizationManager org.apache.pulsar.broker.authorization.AuthorizationService 15 1 1 - - Internal -> Internal
org.apache.pulsar.broker.authorization.AuthorizationManager org.apache.pulsar.broker.authorization.PulsarAuthorizationProvider 3 1 1 - - Internal -> Internal
org.apache.bookkeeper.mledger.impl.PositionImpl org.apache.bookkeeper.mledger.Position 2 2 1 R_SUPER_T - Internal -> Internal
java.lang.String java.util.Set<java.lang.String> 2 2 1 - - Jdk -> Jdk
org.apache.pulsar.client.api.ClientConfiguration org.apache.pulsar.client.impl.conf.ClientConfigurationData 18 4 1 SIBLING - Internal -> Internal
org.apache.pulsar.client.api.ProducerConfiguration.HashingScheme org.apache.pulsar.client.api.HashingScheme 3 1 1 - - Internal -> Internal
org.apache.pulsar.common.util.collections.ConcurrentOpenHashSet java.util.Set 2 1 1 - - Internal -> Jdk
org.apache.pulsar.client.api.ProducerConfiguration org.apache.pulsar.client.impl.conf.ProducerConfigurationData 10 2 1 SIBLING - Internal -> Internal
org.apache.pulsar.client.api.ConsumerConfiguration org.apache.pulsar.client.impl.conf.ConsumerConfigurationData 17 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.client.api.ReaderConfiguration org.apache.pulsar.client.impl.conf.ReaderConfigurationData 2 1 1 SIBLING - Internal -> Internal
java.util.Optional<org.apache.pulsar.client.api.MessageId> org.apache.pulsar.client.api.MessageId 1 1 1 - - Jdk -> Internal
org.apache.commons.configuration.Configuration org.apache.bookkeeper.conf.ClientConfiguration 1 1 1 - - External -> External
org.apache.bookkeeper.net.BookieSocketAddress java.lang.String 12 2 1 - - External -> Jdk
org.apache.bookkeeper.util.OrderedSafeExecutor org.apache.bookkeeper.common.util.OrderedScheduler 23 1 1 - - External -> External
org.apache.bookkeeper.client.EnsemblePlacementPolicy org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl 1 1 1 - - Internal -> Internal
java.util.Queue org.apache.pulsar.common.util.collections.GrowableArrayBlockingQueue 1 1 1 - - Jdk -> Internal
org.apache.bookkeeper.conf.ClientConfiguration org.apache.bookkeeper.conf.ServerConfiguration 1 1 1 - - External -> External
org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl 2 1 1 - - Internal -> Internal
void java.util.concurrent.CompletableFuture<?> 2 1 1 - - Jdk -> Jdk
org.apache.pulsar.client.impl.MessageImpl org.apache.pulsar.client.api.Message<T> 1 1 1 R_SUPER_T - Internal -> Internal
org.apache.pulsar.client.api.Reader org.apache.pulsar.client.api.Reader<T> 6 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.Producer org.apache.pulsar.client.api.Producer<byte[]> 77 4 1 - - Internal -> Internal
org.apache.pulsar.client.impl.ConsumerImpl org.apache.pulsar.client.impl.ConsumerImpl<T> 19 4 1 - - Internal -> Internal
org.apache.pulsar.client.api.Reader org.apache.pulsar.client.api.Reader<byte[]> 6 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.Producer org.apache.pulsar.client.api.Producer<T> 10 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.Message org.apache.pulsar.client.api.Message<T> 62 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.Consumer org.apache.pulsar.client.api.Producer<T> 2 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.client.impl.ProducerImpl org.apache.pulsar.client.impl.ProducerImpl<T> 1 1 1 - - Internal -> Internal
org.apache.pulsar.client.impl.conf.ConsumerConfigurationData org.apache.pulsar.client.impl.conf.ProducerConfigurationData 1 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.client.impl.ProducerBase org.apache.pulsar.client.impl.ProducerBase<?> 3 2 1 - - Internal -> Internal
org.apache.pulsar.client.impl.ConsumerBase org.apache.pulsar.client.impl.ConsumerBase<?> 3 2 1 - - Internal -> Internal
org.apache.pulsar.client.api.Consumer org.apache.pulsar.client.api.Consumer<T> 21 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.Consumer org.apache.pulsar.client.api.Consumer<byte[]> 59 3 1 - - Internal -> Internal
org.apache.pulsar.client.api.Message org.apache.pulsar.client.api.Message<byte[]> 334 4 1 - - Internal -> Internal
org.apache.pulsar.client.api.ClientConfiguration org.apache.pulsar.client.api.ClientBuilder 3 2 1 SIBLING - Internal -> Internal
org.apache.pulsar.client.api.ProducerConfiguration org.apache.pulsar.client.api.ProducerBuilder<byte[]> 2 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.client.api.ConsumerConfiguration org.apache.pulsar.client.impl.conf.ConsumerConfigurationData<byte[]> 2 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.client.api.PulsarClient org.apache.pulsar.client.impl.PulsarClientImpl 9 4 1 T_SUPER_R - Internal -> Internal
org.apache.pulsar.client.api.Message org.apache.pulsar.client.api.Message<?> 44 2 1 - - Internal -> Internal
org.apache.pulsar.client.impl.MessageImpl org.apache.pulsar.client.impl.MessageImpl<?> 10 1 1 - - Internal -> Internal
org.apache.pulsar.client.impl.ConsumerImpl org.apache.pulsar.client.impl.ConsumerImpl<?> 11 2 1 - - Internal -> Internal
org.apache.pulsar.client.impl.ProducerImpl org.apache.pulsar.client.impl.ProducerImpl<?> 7 1 1 - - Internal -> Internal
java.lang.reflect.Method java.lang.Class<?> 1 1 1 SIBLING - Jdk -> Jdk
java.lang.String org.apache.pulsar.functions.runtime.FunctionID 1 1 1 - - Jdk -> Internal
java.io.ByteArrayInputStream java.io.ObjectOutput 1 1 1 SIBLING - Jdk -> Jdk
org.apache.pulsar.functions.spawner.ExecutionResult org.apache.pulsar.functions.instance.JavaExecutionResult 4 2 1 T_SUPER_R - Internal -> Internal
org.apache.pulsar.functions.instance.JavaInstance.ExecutionResult org.apache.pulsar.functions.spawner.ExecutionResult 2 1 1 - - Internal -> Internal
byte java.lang.reflect.AccessibleObject 1 1 1 - - Jdk -> Jdk
java.lang.reflect.AccessibleObject java.lang.String 3 2 1 - - Jdk -> Jdk
org.apache.pulsar.functions.runtime.subscribermanager.ResultsProcessor org.apache.pulsar.client.api.ConsumerConfiguration 1 1 1 - - Internal -> Internal
org.apache.pulsar.admin.cli.CmdFunctions.SubmitFunction org.apache.pulsar.admin.cli.CmdFunctions.CreateFunction 1 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.admin.cli.CmdFunctions.SubmitFunction org.apache.pulsar.admin.cli.CmdFunctions.UpdateFunction 1 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.functions.runtime.container.FunctionContainer org.apache.pulsar.functions.runtime.subscribermanager.TopicSubscription.ContainerWithStats 2 1 1 Composition - Internal -> Internal
byte java.lang.String 25 5 1 - - Jdk -> Jdk
org.apache.pulsar.functions.runtime.worker.FunctionState org.apache.pulsar.functions.fs.FunctionConfig 1 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.functions.runtime.container.ThreadFunctionContainerFactory org.apache.pulsar.functions.runtime.container.FunctionContainerFactory 1 1 1 R_SUPER_T - Internal -> Internal
org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer.Payload org.apache.pulsar.client.api.Message 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.runtime.container.ExecutionResult org.apache.pulsar.functions.runtime.instance.JavaExecutionResult 1 1 1 - - Internal -> Internal
java.net.URI void 1 1 1 - - Jdk -> Jdk
java.lang.String org.apache.pulsar.functions.runtime.worker.PackageLocationMetaData 1 1 1 SIBLING - Jdk -> Internal
org.apache.pulsar.functions.runtime.worker.request.ServiceRequestManager org.apache.distributedlog.api.namespace.Namespace 2 1 1 - - Internal -> Internal
org.apache.distributedlog.api.namespace.Namespace java.util.concurrent.LinkedBlockingQueue<org.apache.pulsar.functions.runtime.worker.FunctionAction> 1 1 1 - - Internal -> Jdk
org.apache.pulsar.client.api.ConsumerConfiguration org.apache.pulsar.client.api.ReaderConfiguration 1 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.client.api.Consumer org.apache.pulsar.client.api.Reader 3 1 1 SIBLING - Internal -> Internal
boolean void 6 5 1 - - Jdk -> Jdk
org.apache.pulsar.functions.runtime.worker.FunctionMetaData org.apache.pulsar.functions.runtime.worker.FunctionRuntimeInfo 15 1 1 Composition - Internal -> Internal
void org.apache.pulsar.functions.fs.FunctionConfig 1 1 1 - - Jdk -> Internal
org.apache.pulsar.functions.worker.request.ServiceRequest org.apache.pulsar.functions.generated.ServiceRequest.Request 1 1 1 Composition - Internal -> Internal
org.apache.pulsar.functions.fs.InstanceID java.lang.String 11 1 1 - - Internal -> Jdk
org.apache.pulsar.functions.fs.FunctionID java.lang.String 12 1 1 - - Internal -> Jdk
org.apache.pulsar.functions.generated.ServiceRequest.PackageLocationMetaData.Builder org.apache.pulsar.functions.proto.ServiceRequest.PackageLocationMetaData.Builder 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.generated.ServiceRequest.FunctionConfig.Builder org.apache.pulsar.functions.proto.ServiceRequest.FunctionConfig.Builder 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.generated.ServiceRequest.Request.ServiceRequestType org.apache.pulsar.functions.proto.ServiceRequest.Request.ServiceRequestType 2 1 1 - - Internal -> Internal
org.apache.pulsar.functions.generated.ServiceRequest.Request org.apache.pulsar.functions.proto.ServiceRequest.Request 9 1 1 - - Internal -> Internal
org.apache.pulsar.functions.generated.ServiceRequest.Request.Builder org.apache.pulsar.functions.proto.ServiceRequest.Request.Builder 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.generated.ServiceRequest.FunctionMetaData.Builder org.apache.pulsar.functions.proto.ServiceRequest.FunctionMetaData.Builder 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.worker.PackageLocationMetaData org.apache.pulsar.functions.proto.Function.PackageLocationMetaData.Builder 2 1 1 - - Internal -> Internal
org.apache.pulsar.functions.fs.FunctionConfig org.apache.pulsar.functions.proto.Function.FunctionConfig.Builder 2 1 1 - - Internal -> Internal
org.apache.pulsar.functions.worker.FunctionMetaData org.apache.pulsar.functions.proto.Function.FunctionMetaData.Builder 2 1 1 - - Internal -> Internal
org.apache.pulsar.functions.worker.request.ServiceRequest org.apache.pulsar.functions.worker.request.ServiceRequestInfo 2 1 1 - - Internal -> Internal
org.apache.pulsar.functions.worker.request.MarkerRequest org.apache.pulsar.functions.proto.Request.ServiceRequest 2 1 1 R_SUPER_T - Internal -> Internal
org.apache.pulsar.functions.proto.ServiceRequest.Request org.apache.pulsar.functions.proto.Request.ServiceRequest 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.worker.request.UpdateRequest org.apache.pulsar.functions.proto.Request.ServiceRequest 1 1 1 R_SUPER_T - Internal -> Internal
org.apache.pulsar.functions.worker.request.DeregisterRequest org.apache.pulsar.functions.proto.Request.ServiceRequest 1 1 1 R_SUPER_T - Internal -> Internal
org.apache.pulsar.functions.fs.FunctionStatus org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatus.Builder 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatusResponseProto org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatus 4 1 1 - - Internal -> Internal
org.apache.pulsar.functions.worker.request.ServiceRequestManager org.apache.pulsar.client.api.PulsarClient 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.runtime.serde.SerDe java.util.Map<java.lang.String, org.apache.pulsar.functions.runtime.serde.SerDe> 1 1 1 - - Internal -> Jdk
org.apache.pulsar.client.api.Message org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable.InputMessage 3 1 1 Composition - Internal -> Internal
org.apache.pulsar.functions.runtime.serde.SerDe java.util.List<org.apache.pulsar.functions.runtime.serde.SerDe> 3 1 1 - - Internal -> Jdk
org.apache.pulsar.functions.api.RequestHandler org.apache.pulsar.functions.api.PulsarFunction 1 1 1 - - Internal -> Internal
java.lang.String org.apache.pulsar.client.api.MessageId 3 1 1 - - Jdk -> Internal
org.apache.pulsar.functions.stats.FunctionStats InstanceCommunication.FunctionStatus.Builder 1 1 1 - - Internal -> External
java.util.concurrent.atomic.LongAdder long 5 1 1 - - Jdk -> Jdk
java.lang.Class<? extendsorg.apache.pulsar.functions.api.SerDe> java.lang.String 5 1 1 SIBLING - Jdk -> Jdk
org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable org.apache.pulsar.functions.runtime.spawner.Spawner 2 1 1 SIBLING - Internal -> Internal
java.lang.reflect.AccessibleObject org.apache.pulsar.functions.api.PulsarFunction 1 1 1 - - Jdk -> Internal
java.lang.reflect.Type java.lang.reflect.AccessibleObject 1 1 1 - - Jdk -> Jdk
java.lang.reflect.Type java.lang.Class 2 1 1 T_SUPER_R - Jdk -> Jdk
java.lang.reflect.AccessibleObject java.lang.Class 6 2 1 SIBLING - Jdk -> Jdk
java.lang.String org.apache.pulsar.functions.worker.MembershipManager.WorkerInfo 2 1 1 Composition - Jdk -> Internal
org.apache.pulsar.functions.api.PulsarFunction java.lang.reflect.AccessibleObject 1 1 1 - - Internal -> Jdk
org.apache.pulsar.functions.api.PulsarFunction java.lang.Class<?> 3 1 1 - - Internal -> Jdk
org.apache.pulsar.functions.proto.Function.Assignment java.util.Collection<org.apache.pulsar.functions.proto.Function.Assignment> 1 1 1 - - Internal -> Jdk
org.apache.pulsar.functions.proto.Function.Assignment java.util.Map<java.lang.String, org.apache.pulsar.functions.proto.Function.Assignment> 1 1 1 - - Internal -> Jdk
org.apache.pulsar.functions.runtime.spawner.AssignmentInfo org.apache.pulsar.functions.runtime.container.InstanceConfig 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatus org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatusList 4 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.Function.FunctionMetaData org.apache.pulsar.functions.proto.Function.Instance 7 1 1 - - Internal -> Internal
java.lang.String org.apache.pulsar.functions.proto.Function.Instance 6 1 1 - - Jdk -> Internal
org.apache.pulsar.client.api.Producer org.apache.pulsar.functions.runtime.instance.producers.Producers 1 1 1 - - Internal -> Internal
java.util.concurrent.LinkedBlockingQueue java.util.concurrent.LinkedBlockingDeque 1 1 1 SIBLING - Jdk -> Jdk
org.apache.pulsar.functions.worker.ClusterServiceCoordinator org.apache.pulsar.functions.worker.WorkerService 1 1 1 Composition - Internal -> Internal
java.util.List java.util.Map 4 1 1 - - Jdk -> Jdk
void java.util.concurrent.Future<?> 1 1 1 - - Jdk -> Jdk
org.apache.pulsar.client.impl.ConsumerImpl org.apache.pulsar.client.impl.ConsumerImpl<byte[]> 6 2 1 - - Internal -> Internal
org.apache.pulsar.client.api.Consumer org.apache.pulsar.client.api.Consumer<?> 12 1 1 - - Internal -> Internal
byte[] ? 2 1 1 - - Jdk -> TypeVariable
org.apache.pulsar.client.impl.ProducerImpl org.apache.pulsar.client.impl.ProducerImpl<byte[]> 8 1 1 - - Internal -> Internal
org.apache.pulsar.client.impl.ProducerBase org.apache.pulsar.client.impl.ProducerBase<byte[]> 2 1 1 - - Internal -> Internal
org.apache.bookkeeper.conf.ClientConfiguration org.apache.pulsar.client.impl.conf.ClientConfigurationData 3 1 1 - - External -> Internal
org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2Resource org.apache.pulsar.functions.worker.rest.api.FunctionsImpl 1 1 1 - - Internal -> Internal
org.apache.pulsar.client.impl.ProducerStats org.apache.pulsar.client.impl.ProducerStatsRecorder 2 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.common.policies.data.ConsumerStats org.apache.pulsar.client.impl.ConsumerStatsRecorder 2 1 1 - - Internal -> Internal
io.netty.util.Timeout java.util.Optional<io.netty.util.Timeout> 1 1 1 - - External -> Jdk
org.apache.pulsar.common.policies.data.ConsumerStats org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl 2 1 1 - - Internal -> Internal
org.apache.pulsar.functions.metrics.MetricsSink java.lang.Long 2 1 1 - - Internal -> Jdk
org.apache.pulsar.client.api.RawMessage org.apache.commons.lang3.tuple.ImmutablePair<org.apache.pulsar.client.api.MessageId, java.lang.String> 1 1 1 - - Internal -> External
java.util.Collection java.util.List 2 2 1 T_SUPER_R - Jdk -> Jdk
java.lang.String org.apache.pulsar.common.naming.TopicName 5 3 1 Composition - Jdk -> Internal
java.lang.String java.lang.Void 1 1 1 - - Jdk -> Jdk
java.lang.String org.apache.pulsar.common.naming.NamespaceName 1 1 1 Composition - Jdk -> Internal
java.lang.Long int 1 1 1 - - Jdk -> Jdk
org.apache.bookkeeper.mledger.Position java.lang.Iterable<org.apache.bookkeeper.mledger.Position> 1 1 1 - - Internal -> Jdk
java.lang.Class java.lang.Class<?> 3 2 1 - - Jdk -> Jdk
java.net.URL java.lang.String 4 1 1 SIBLING - Jdk -> Jdk
java.util.function.BiFunction java.util.function.Function 3 1 1 - - Jdk -> Jdk
org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData.Builder org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData 1 1 1 - - Internal -> Internal
org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData java.util.List<org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData> 5 1 1 - - Internal -> Jdk
org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData org.apache.pulsar.client.impl.MessageIdImpl 1 1 1 - - Internal -> Internal
org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData.Builder 1 1 1 - - Internal -> Internal
org.apache.bookkeeper.mledger.impl.PositionImpl java.util.List<org.apache.bookkeeper.mledger.Position> 3 1 1 - - Internal -> Jdk
java.util.concurrent.ScheduledExecutorService org.apache.bookkeeper.common.util.OrderedScheduler 10 2 1 T_SUPER_R - Jdk -> External
java.util.concurrent.ScheduledExecutorService org.apache.bookkeeper.common.util.OrderedExecutor 1 1 1 - - Jdk -> External
org.apache.bookkeeper.common.util.OrderedScheduler org.apache.bookkeeper.common.util.OrderedExecutor 16 2 1 - - External -> External
org.apache.bookkeeper.common.util.SafeRunnable java.lang.Runnable 1 1 1 - - External -> Jdk
org.apache.pulsar.client.api.Message org.apache.pulsar.client.impl.TopicMessageImpl 1 1 1 T_SUPER_R - Internal -> Internal
java.util.List java.util.concurrent.ConcurrentHashMap 1 1 1 - - Jdk -> Jdk
org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl org.apache.pulsar.client.impl.ConsumerStatsRecorder 1 1 1 R_SUPER_T - Internal -> Internal
org.apache.pulsar.client.api.MessageId org.apache.pulsar.client.impl.TopicMessageIdImpl 1 1 1 T_SUPER_R - Internal -> Internal
org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl org.apache.pulsar.client.api.ConsumerStats 1 1 1 - - Internal -> Internal
java.util.Map com.google.common.collect.Multimap 5 1 1 - - Jdk -> External
org.apache.pulsar.broker.service.Topic java.util.Optional<org.apache.pulsar.broker.service.Topic> 19 2 1 - - Internal -> Jdk
org.apache.pulsar.client.admin.PulsarAdminWithFunctions org.apache.pulsar.client.admin.PulsarAdmin 1 1 1 R_SUPER_T - Internal -> Internal
org.apache.commons.lang3.tuple.Pair<java.lang.Long, java.lang.String> org.apache.pulsar.client.impl.ProducerResponse 6 1 1 - - External -> Internal
java.lang.String org.apache.commons.lang3.tuple.Pair<java.lang.String, java.lang.Integer> 2 1 1 SIBLING - Jdk -> External
java.util.ArrayDeque org.jctools.queues.MpmcArrayQueue 1 1 1 - - Jdk -> External
int java.lang.Throwable 1 1 1 - - Jdk -> Jdk
org.apache.bookkeeper.client.BookKeeper.DigestType org.apache.bookkeeper.client.api.DigestType 1 1 1 - - Internal -> Internal
org.apache.bookkeeper.client.LedgerHandle org.apache.bookkeeper.client.api.ReadHandle 17 1 1 - - Internal -> Internal
org.jctools.queues.MpmcArrayQueue org.jctools.queues.MessagePassingQueue 1 1 1 R_SUPER_T - External -> External
org.apache.pulsar.common.util.collections.GrowableArrayBlockingQueue java.util.concurrent.ConcurrentLinkedQueue 1 1 1 SIBLING - Internal -> Jdk
org.apache.pulsar.functions.proto.Function.FunctionConfig.Runtime org.apache.pulsar.functions.proto.Function.FunctionDetails.Runtime 2 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.Function.FunctionConfig.ProcessingGuarantees org.apache.pulsar.functions.proto.Function.FunctionDetails.ProcessingGuarantees 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.Function.FunctionConfig.Builder org.apache.pulsar.functions.proto.Function.FunctionDetails.Builder 7 1 1 - - Internal -> Internal
org.apache.pulsar.functions.shaded.proto.Function.FunctionConfig.Builder org.apache.pulsar.functions.utils.FunctionConfig 2 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.Function.FunctionConfig org.apache.pulsar.functions.proto.Function.FunctionDetails 38 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.Function.FunctionConfig org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.shaded.proto.Function.FunctionConfig.Builder org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails.Builder 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.shaded.proto.Function.FunctionConfig org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails 6 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.Function.FunctionConfig.SubscriptionType org.apache.pulsar.functions.proto.Function.FunctionDetails.SubscriptionType 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.Function.FunctionConfig.Builder org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails.Builder 1 1 1 - - Internal -> Internal
java.util.function.Consumer java.util.function.Consumer<?> 1 1 1 - - Jdk -> Jdk
org.apache.pulsar.client.admin.Properties org.apache.pulsar.client.admin.Tenants 1 1 1 - - Internal -> Internal
org.apache.pulsar.client.admin.internal.PropertiesImpl org.apache.pulsar.client.admin.internal.TenantsImpl 2 1 1 SIBLING - Internal -> Internal
CustomPropertyAdmin CustomTenantAdmin 1 1 1 - - External -> External
org.apache.pulsar.common.util.KeyValue org.apache.pulsar.connect.core.Message 3 1 1 - - Internal -> Internal
byte org.apache.pulsar.connect.core.Message<byte[]> 4 1 1 - - Jdk -> Internal
java.lang.String org.apache.pulsar.connect.core.Message<java.lang.String> 2 1 1 - - Jdk -> Internal
org.apache.pulsar.broker.web.RestException javax.ws.rs.WebApplicationException 1 1 1 R_SUPER_T - Internal -> External
java.util.Map<java.lang.String, org.apache.pulsar.client.api.Consumer> org.apache.pulsar.client.api.Consumer 3 1 1 - - Jdk -> Internal
org.jctools.queues.MessagePassingQueue java.util.ArrayDeque 1 1 1 - - External -> Jdk
org.apache.pulsar.connect.core.Message org.apache.pulsar.common.util.KeyValue 3 1 1 - - Internal -> Internal
org.apache.pulsar.connect.core.Message org.apache.pulsar.connect.core.Record 8 1 1 - - Internal -> Internal
java.lang.String java.lang.reflect.AccessibleObject 26 3 1 - - Jdk -> Jdk
org.apache.pulsar.client.api.Message org.apache.pulsar.connect.core.Record 2 1 1 - - Internal -> Internal
byte java.util.UUID 4 1 1 - - Jdk -> Jdk
byte java.lang.Void 3 1 1 - - Jdk -> Jdk
org.apache.pulsar.client.api.ConsumerConfiguration org.apache.pulsar.client.api.SubscriptionType 1 1 1 - - Internal -> Internal
boolean java.util.concurrent.atomic.AtomicBoolean 1 1 1 - - Jdk -> Jdk
org.apache.pulsar.functions.instance.InputMessage org.apache.pulsar.connect.core.Record 5 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.Consumer org.apache.pulsar.connect.core.Source 1 1 1 - - Internal -> Internal
org.apache.pulsar.client.admin.PersistentTopics org.apache.pulsar.client.admin.internal.TopicsImpl 1 1 1 T_SUPER_R - Internal -> Internal
org.apache.pulsar.common.policies.data.NonPersistentTopicStats org.apache.pulsar.common.policies.data.TopicStats 1 1 1 - - Internal -> Internal
org.apache.pulsar.common.policies.data.TopicStats org.apache.pulsar.broker.service.persistent.PersistentTopic.TopicStatsHelper 2 1 1 - - Internal -> Internal
org.apache.pulsar.common.policies.data.PersistentTopicStats org.apache.pulsar.common.policies.data.TopicStats 59 1 1 R_SUPER_T - Internal -> Internal
java.lang.IllegalAccessException void 1 1 1 - - Jdk -> Jdk
java.lang.Long long 7 2 1 - Unboxing Jdk -> Jdk
SchemaRegistryFormat.SchemaInfo.SchemaType org.apache.pulsar.broker.service.schema.proto.SchemaRegistryFormat.SchemaInfo.SchemaType 7 1 1 - - Internal -> Internal
SchemaRegistryFormat.SchemaInfo.KeyValuePair.Builder org.apache.pulsar.broker.service.schema.proto.SchemaRegistryFormat.SchemaInfo.KeyValuePair.Builder 3 1 1 - - Internal -> Internal
SchemaRegistryFormat.SchemaInfo.KeyValuePair org.apache.pulsar.broker.service.schema.proto.SchemaRegistryFormat.SchemaInfo.KeyValuePair 25 1 1 Composition - Internal -> Internal
SchemaRegistryFormat.SchemaInfo.KeyValuePairOrBuilder org.apache.pulsar.broker.service.schema.proto.SchemaRegistryFormat.SchemaInfo.KeyValuePairOrBuilder 1 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.MessageId java.util.concurrent.CompletableFuture<org.apache.pulsar.client.api.MessageId> 1 1 1 - - Internal -> Jdk
org.apache.pulsar.client.api.Message<byte[]> byte 1 1 1 - - Internal -> Jdk
org.apache.pulsar.client.api.Message org.apache.pulsar.client.api.TypedMessageBuilder 3 2 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.Function.FunctionDetails.ProcessingGuarantees org.apache.pulsar.functions.proto.Function.ProcessingGuarantees 1 1 1 - - Internal -> Internal
java.util.Map java.lang.Class 2 1 1 - - Jdk -> Jdk
org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails.SubscriptionType org.apache.pulsar.functions.shaded.proto.Function.SubscriptionType 2 1 1 - - Internal -> Internal
org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails.ProcessingGuarantees org.apache.pulsar.functions.shaded.proto.Function.ProcessingGuarantees 2 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.Function.ConnectorDetails org.apache.pulsar.functions.proto.Function.SourceSpec 1 1 1 - - Internal -> Internal
io.netty.util.collection.IntObjectMap java.util.Map 4 1 1 R_SUPER_T - External -> Jdk
org.apache.pulsar.functions.source.PulsarRecord org.apache.pulsar.connect.core.RecordContext 4 1 1 R_SUPER_T - Internal -> Internal
java.util.Map org.apache.pulsar.client.api.Producer 1 1 1 - - Jdk -> Internal
org.apache.pulsar.admin.cli.CmdConnectors.DeleteConnector org.apache.pulsar.admin.cli.CmdSources.DeleteSource 1 1 1 SIBLING - Internal -> Internal
byte int 1 1 1 - Widening Jdk -> Jdk
java.util.function.Function java.util.function.Consumer 6 1 1 - - Jdk -> Jdk
org.apache.bookkeeper.client.api.ReadHandle long 2 1 1 - - External -> Jdk
org.apache.pulsar.functions.sink.RuntimeSink org.apache.pulsar.io.core.Sink 1 1 1 R_SUPER_T - Internal -> Internal
org.apache.pulsar.zookeeper.ZooKeeperCache java.util.concurrent.atomic.AtomicReference<org.apache.pulsar.zookeeper.ZooKeeperCache> 2 1 1 - - Internal -> Jdk
com.google.protobuf.CodedInputStream org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream 120 1 1 - - External -> Internal
com.google.protobuf.ByteString org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString 290 1 1 - - External -> Internal
com.google.protobuf.LazyStringList org.apache.pulsar.shaded.com.google.protobuf.v241.LazyStringList 4 1 1 - - External -> Internal
com.google.protobuf.CodedOutputStream org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream 40 1 1 - - External -> Internal
com.google.protobuf.ExtensionRegistryLite org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite 281 1 1 - - External -> Internal
org.apache.pulsar.common.util.KeyValue<K, V> byte 3 1 1 - - Internal -> Jdk
int long 7 3 1 - Widening Jdk -> Jdk
java.io.InputStream org.apache.pulsar.broker.s3offload.OffloadIndexBlock.IndexInputStream 3 1 1 - - Jdk -> Internal
java.lang.String java.lang.Integer 3 2 1 SIBLING - Jdk -> Jdk
java.lang.annotation.Annotation java.util.List<java.lang.annotation.Annotation> 1 1 1 - - Jdk -> Jdk
org.apache.pulsar.client.admin.LongRunningProcessStatus java.lang.String 1 1 1 Composition - Internal -> Jdk
org.apache.pulsar.functions.utils.FunctionConfig.SubscriptionType org.apache.pulsar.client.api.SubscriptionType 1 1 1 - - Internal -> Internal
java.util.function.Consumer<org.apache.pulsar.io.core.Record<byte[]>> org.apache.pulsar.io.rabbitmq.RabbitMQSource 2 1 1 Composition - Jdk -> Internal
java.io.File java.lang.String 3 2 1 SIBLING - Jdk -> Jdk
org.apache.pulsar.broker.service.schema.AvroSchemaCompatibilityCheck.CompatibilityStrategy org.apache.pulsar.broker.service.schema.SchemaCompatibilityStrategy 3 1 1 - - Internal -> Internal
org.apache.pulsar.common.schema.SchemaVersion long 2 1 1 - - Internal -> Jdk
java.lang.Class<?> java.lang.String 2 1 1 SIBLING - Jdk -> Jdk
org.apache.pulsar.functions.api.SerDe org.apache.pulsar.functions.api.SerDe<T> 1 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.Consumer java.util.Map<java.lang.String, org.apache.pulsar.client.api.Consumer<T>> 1 1 1 - - Internal -> Jdk
org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker 3 1 1 R_SUPER_T - Internal -> Internal
java.util.Map<java.lang.String, org.apache.pulsar.client.api.Consumer<T>> org.apache.pulsar.client.api.Consumer 1 1 1 - - Jdk -> Internal
org.apache.pulsar.functions.api.SerDe<T> org.apache.pulsar.functions.api.SerDe 1 1 1 - - Internal -> Internal
java.lang.Class<? extendsorg.apache.pulsar.common.compression.CompressionCodec> org.apache.pulsar.common.compression.CompressionCodec 1 1 1 - - Jdk -> Internal
java.util.zip.Deflater io.netty.util.concurrent.FastThreadLocal<java.util.zip.Deflater> 1 1 1 - - Jdk -> External
java.util.zip.Inflater io.netty.util.concurrent.FastThreadLocal<java.util.zip.Inflater> 1 1 1 - - Jdk -> External
java.util.Map java.util.Optional 1 1 1 - - Jdk -> Jdk
java.util.Map<java.util.Map<java.lang.String, org.apache.pulsar.common.policies.data.BookieInfo>, java.lang.String> org.apache.pulsar.common.policies.data.BookiesRackConfiguration 4 1 1 - - Jdk -> Internal
org.apache.pulsar.broker.PulsarService org.apache.pulsar.broker.authentication.AuthenticationService 1 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.Message org.apache.pulsar.client.impl.MessageImpl 2 1 1 - - Internal -> Internal
org.apache.pulsar.client.impl.MessageImpl org.apache.pulsar.client.impl.TopicMessageImpl 2 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.tests.integration.functions.runtime.PulsarFunctionsRuntimeTest.ContainerFactory org.apache.pulsar.functions.runtime.RuntimeFactory 2 1 1 - - Internal -> Internal
java.lang.IllegalAccessException java.lang.Throwable 18 2 1 R_SUPER_T - Jdk -> Jdk
java.lang.Void org.apache.pulsar.functions.api.examples.serde.CustomObject 1 1 1 - - Jdk -> Internal
java.lang.String org.apache.pulsar.functions.api.examples.serde.CustomObject 1 1 1 - - Jdk -> Internal
byte java.nio.ByteBuffer 1 1 1 - - Jdk -> Jdk
java.lang.String int 7 2 1 - - Jdk -> Jdk
org.apache.pulsar.io.core.RecordContext org.apache.pulsar.io.core.Record<T> 3 1 1 R_SUPER_T - Internal -> Internal
long java.util.Optional<java.lang.Long> 1 1 1 - - Jdk -> Jdk
org.apache.pulsar.io.core.RecordContext org.apache.pulsar.io.core.Record<byte[]> 7 1 1 R_SUPER_T - Internal -> Internal
byte org.apache.pulsar.io.core.Record<byte[]> 5 1 1 - - Jdk -> Internal
org.apache.pulsar.tests.containers.CassandraContainer java.util.Map<java.lang.String, org.testcontainers.containers.GenericContainer<?>> 1 1 1 - - Internal -> Jdk
org.apache.pulsar.client.api.Consumer java.util.List<java.lang.String> 3 1 1 - - Internal -> Jdk
org.apache.pulsar.client.api.MessageId org.apache.pulsar.functions.api.Record<?> 2 1 1 - - Internal -> Internal
byte org.apache.pulsar.functions.api.Record<?> 3 1 1 - - Jdk -> Internal
com.amazonaws.services.s3.AmazonS3 org.jclouds.blobstore.BlobStore 8 1 1 - - External -> External
org.apache.pulsar.broker.service.BrokerService org.apache.pulsar.broker.PulsarService 3 1 1 Composition - Internal -> Internal
java.lang.StringBuffer java.lang.AbstractStringBuilder 1 1 1 R_SUPER_T - Jdk -> Jdk
org.testcontainers.containers.Container.ExecResult org.apache.pulsar.tests.integration.docker.ContainerExecResult 32 1 1 - - External -> Internal
java.lang.String org.apache.pulsar.tests.integration.docker.ContainerExecResult 1 1 1 Composition - Jdk -> Internal
long double 1 1 1 - Widening Jdk -> Jdk
javax.ws.rs.core.Response java.util.List<org.apache.pulsar.functions.worker.WorkerInfo> 3 1 1 - - External -> Jdk
org.apache.pulsar.io.core.SinkContext org.apache.pulsar.io.kinesis.KinesisSink 1 1 1 Composition - Internal -> Internal
java.lang.ref.Finalizer.FinalizerThread org.apache.pulsar.functions.worker.rest.WorkerServer 1 1 1 - - Jdk -> Internal
org.apache.pulsar.common.naming.NamespaceBundles java.util.List<org.apache.pulsar.common.naming.NamespaceBundle> 1 1 1 - - Internal -> Jdk
javax.ws.rs.core.Response java.util.Collection<org.apache.pulsar.common.stats.Metrics> 2 1 1 - - External -> Jdk
org.apache.pulsar.broker.ServiceConfiguration org.apache.pulsar.broker.offload.TieredStorageConfigurationData 2 1 1 - - Internal -> Internal
org.jclouds.blobstore.BlobStoreContext java.lang.String 1 1 1 - - External -> Jdk
org.apache.pulsar.client.api.MessageBuilder org.apache.pulsar.client.api.TypedMessageBuilder<T> 1 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.Producer org.apache.pulsar.client.api.Producer<?> 1 1 1 - - Internal -> Internal
java.lang.String org.apache.pulsar.functions.utils.ConsumerConfig 1 1 1 Composition - Jdk -> Internal
org.apache.pulsar.client.api.PulsarClient org.apache.pulsar.functions.worker.WorkerService 1 1 1 Composition - Internal -> Internal
java.lang.String org.apache.pulsar.io.twitter.TweetData 3 1 1 Composition - Jdk -> Internal
org.apache.pulsar.client.api.Consumer org.apache.pulsar.client.impl.ConsumerImpl 3 1 1 - - Internal -> Internal
org.apache.pulsar.functions.worker.WorkerConfig org.apache.pulsar.functions.worker.WorkerService 1 1 1 Composition - Internal -> Internal
org.apache.pulsar.functions.worker.rest.api.v2.WorkerStats org.apache.pulsar.client.admin.Worker 2 1 1 - - Internal -> Internal
java.lang.Class<T> org.apache.avro.Schema 1 1 1 - - Jdk -> External
java.util.concurrent.CountDownLatch java.util.concurrent.CompletableFuture<org.apache.pulsar.common.api.proto.PulsarApi.BaseCommand> 5 1 1 - - Jdk -> Jdk
java.lang.Boolean boolean 1 1 1 - Unboxing Jdk -> Jdk
org.apache.pulsar.client.impl.schema.GenericAvroSchema org.apache.pulsar.client.impl.schema.generic.GenericSchema 2 1 1 SIBLING - Internal -> Internal
java.lang.String org.apache.pulsar.tests.integration.io.SinkTester.SinkType 3 1 1 - - Jdk -> Internal
java.lang.Integer java.lang.Integer[] 2 1 1 - - Jdk -> Jdk
org.apache.bookkeeper.client.MockBookKeeper org.apache.bookkeeper.client.PulsarMockBookKeeper 2 1 1 - - Internal -> Internal
byte org.apache.pulsar.client.api.schema.GenericRecord 1 1 1 - - Jdk -> Internal
org.apache.pulsar.io.jdbc.JdbcAvroSchemaSink org.apache.pulsar.io.jdbc.JdbcAutoSchemaSink 1 1 1 SIBLING - Internal -> Internal
java.lang.String org.apache.pulsar.tests.integration.io.JdbcSinkTester.Foo 1 1 1 Composition - Jdk -> Internal
java.util.Queue java.util.concurrent.ArrayBlockingQueue 1 1 1 T_SUPER_R - Jdk -> Jdk
long java.util.concurrent.atomic.AtomicLong 1 1 1 - - Jdk -> Jdk
org.apache.bookkeeper.mledger.ManagedLedgerFactory org.apache.pulsar.sql.presto.PulsarConnectorCache 1 1 1 Composition - Internal -> Internal
org.apache.pulsar.io.elasticsearch.ElasticSearchStringSink org.apache.pulsar.io.elasticsearch.ElasticSearchSink 1 1 1 - - Internal -> Internal
java.util.concurrent.ExecutorService java.util.concurrent.ScheduledExecutorService 1 1 1 T_SUPER_R - Jdk -> Jdk
org.apache.pulsar.functions.proto.Request.AssignmentsUpdate org.apache.pulsar.functions.proto.Function.Assignment 6 1 1 - - Internal -> Internal
org.apache.pulsar.functions.worker.ConnectorsManager org.apache.pulsar.functions.worker.WorkerService 1 1 1 Composition - Internal -> Internal
int java.lang.Integer 21 3 1 - Boxing Jdk -> Jdk
java.util.List org.apache.commons.lang3.tuple.Pair 2 1 1 - - Jdk -> External
java.io.File java.lang.ClassLoader 2 1 1 - - Jdk -> Jdk
java.io.InputStream java.io.File 2 1 1 - - Jdk -> Jdk
org.apache.pulsar.common.nar.NarClassLoader java.lang.ClassLoader 2 2 1 - - Internal -> Jdk
java.net.URLClassLoader java.lang.ClassLoader 1 1 1 R_SUPER_T - Jdk -> Jdk
org.apache.pulsar.functions.proto.Function.FunctionDetails org.apache.pulsar.functions.utils.FunctionConfig 19 3 1 - - Internal -> Internal
void java.lang.ClassLoader 1 1 1 - - Jdk -> Jdk
org.apache.pulsar.shade.io.netty.buffer.ByteBuf io.netty.buffer.ByteBuf 2 2 1 - - Internal -> External
io.netty.buffer.ByteBuf org.apache.pulsar.shade.io.netty.buffer.ByteBuf 2 1 1 - - External -> Internal
java.lang.String java.util.concurrent.ThreadFactory 1 1 1 - - Jdk -> Jdk
org.apache.pulsar.client.admin.Functions org.apache.pulsar.client.admin.Sink 1 1 1 - - Internal -> Internal
org.apache.pulsar.client.admin.Functions org.apache.pulsar.client.admin.Source 1 1 1 - - Internal -> Internal
java.lang.String java.lang.ClassLoader 2 1 1 - - Jdk -> Jdk
org.apache.pulsar.functions.proto.Function.FunctionDetails org.apache.pulsar.functions.utils.SinkConfig 2 1 1 - - Internal -> Internal
java.lang.String org.apache.pulsar.functions.proto.Function.FunctionMetaData 3 1 1 - - Jdk -> Internal
org.apache.pulsar.functions.proto.Function.FunctionDetails org.apache.pulsar.functions.utils.SourceConfig 2 1 1 - - Internal -> Internal
java.util.concurrent.ExecutorService org.eclipse.jetty.util.thread.ExecutorThreadPool 5 1 1 SIBLING - Jdk -> External
boolean java.lang.String 2 1 1 - - Jdk -> Jdk
java.lang.String java.nio.file.Path 2 1 1 SIBLING - Jdk -> Jdk
java.lang.ClassLoader org.apache.pulsar.common.nar.NarClassLoader 1 1 1 - - Jdk -> Internal
java.lang.String ? 2 1 1 - - Jdk -> TypeVariable
java.util.IdentityHashMap<org.apache.kafka.connect.source.SourceRecord, org.apache.kafka.connect.source.SourceRecord> java.util.concurrent.atomic.AtomicInteger 1 1 1 SIBLING - Jdk -> Jdk
byte org.apache.pulsar.common.schema.KeyValue<byte[], byte[]> 3 1 1 - - Jdk -> Internal
boolean java.lang.Boolean 9 4 1 - Boxing Jdk -> Jdk
org.apache.pulsar.common.policies.data.FunctionStats org.apache.pulsar.functions.instance.FunctionStatsManager 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.InstanceCommunication.MetricsData java.util.Map<java.lang.Double, java.lang.String> 6 1 1 - - Internal -> Jdk
InstanceCommunication.MetricsData.DataDigest java.lang.Double 2 1 1 - - External -> Jdk
javax.ws.rs.core.Response FunctionStats.FunctionInstanceStats.FunctionInstanceStatsData 3 1 1 - - External -> Internal
javax.ws.rs.core.Response org.apache.pulsar.common.policies.data.FunctionStats 3 1 1 - - External -> Internal
org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatusList org.apache.pulsar.common.policies.data.FunctionStats 1 1 1 - - Internal -> Internal
org.apache.flink.api.java.tuple.Tuple4<java.lang.String, java.lang.String, java.lang.String, java.lang.Integer> org.apache.flink.api.java.tuple.Tuple4<java.lang.Integer, java.lang.Integer, java.lang.String, java.lang.Integer> 3 1 1 - - External -> External
double java.lang.Double 2 1 1 - Boxing Jdk -> Jdk
java.lang.String org.apache.pulsar.common.functions.FunctionState 4 1 1 Composition - Jdk -> Internal
org.apache.pulsar.websocket.data.ConsumerAck org.apache.pulsar.websocket.data.ConsumerCommand 1 1 1 - - Internal -> Internal
java.util.Timer java.util.concurrent.ScheduledFuture 1 1 1 - - Jdk -> Jdk
java.util.concurrent.ScheduledExecutorService java.util.concurrent.ScheduledFuture 1 1 1 - - Jdk -> Jdk
java.util.concurrent.atomic.AtomicBoolean boolean 2 1 1 - - Jdk -> Jdk
java.util.concurrent.ArrayBlockingQueue org.jctools.queues.SpscArrayQueue 2 1 1 - - Jdk -> External
org.apache.pulsar.shade.com.google.gson.JsonObject java.util.Map 1 1 1 - - Internal -> Jdk
org.apache.pulsar.shade.com.google.gson.JsonElement java.lang.reflect.AccessibleObject 1 1 1 - - Internal -> Jdk
org.apache.pulsar.client.api.Message org.apache.pulsar.common.api.raw.RawMessage 10 1 1 - - Internal -> Internal
java.lang.String long 1 1 1 - - Jdk -> Jdk
byte org.apache.pulsar.shade.io.netty.buffer.ByteBuf 2 1 1 - - Jdk -> Internal
org.apache.pulsar.client.api.Message<?> org.apache.pulsar.common.api.raw.RawMessage 2 1 1 - - Internal -> Internal
org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData long 1 1 1 Composition - Internal -> Jdk
io.netty.util.concurrent.FastThreadLocal java.lang.ThreadLocal 2 1 1 - - External -> Jdk
org.apache.pulsar.common.nar.NarClassLoader org.apache.pulsar.functions.utils.SourceConfigUtils.ExtractedSourceDetails 2 1 1 - - Internal -> Internal
org.apache.pulsar.common.nar.NarClassLoader org.apache.pulsar.functions.utils.SinkConfigUtils.ExtractedSinkDetails 2 1 1 - - Internal -> Internal
org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadata org.apache.pulsar.common.api.raw.ReferenceCountedObject<org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadata> 3 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.InstanceCommunication.Metrics java.util.List<org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats> 2 1 1 - - Internal -> Jdk
javax.ws.rs.core.Response java.util.Map<java.util.Collection<java.lang.String>, java.lang.String> 3 1 1 - - External -> Jdk
javax.ws.rs.core.Response org.apache.pulsar.common.functions.WorkerInfo 3 1 1 - - External -> Internal
javax.ws.rs.core.Response java.util.List<org.apache.pulsar.common.functions.WorkerInfo> 3 1 1 - - External -> Jdk
javax.ws.rs.core.Response java.util.List<org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats> 4 1 1 - - External -> Jdk
com.google.gson.JsonArray java.util.List<org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats> 1 1 1 SIBLING - External -> Jdk
int java.util.Optional<java.lang.Integer> 16 2 1 - - Jdk -> Jdk
org.eclipse.jetty.util.thread.ExecutorThreadPool org.apache.pulsar.broker.web.WebExecutorThreadPool 4 1 1 T_SUPER_R - External -> Internal
javax.ws.rs.core.Response org.apache.pulsar.common.io.SinkConfig 3 1 1 - - External -> Internal
javax.ws.rs.core.Response org.apache.pulsar.common.functions.FunctionConfig 5 1 1 - - External -> Internal
javax.ws.rs.core.Response void 68 2 1 - - External -> Jdk
javax.ws.rs.core.Response javax.ws.rs.core.StreamingOutput 3 1 1 SIBLING - External -> External
javax.ws.rs.core.Response org.apache.pulsar.common.io.SourceConfig 4 1 1 - - External -> Internal
javax.ws.rs.core.Response org.apache.pulsar.common.functions.FunctionState 3 1 1 - - External -> Internal
javax.ws.rs.core.Response java.lang.String 3 1 1 - - External -> Jdk
javax.ws.rs.core.Response java.util.List<java.lang.String> 15 1 1 - - External -> Jdk
org.apache.pulsar.common.util.collections.ConcurrentOpenHashSet java.util.concurrent.ConcurrentHashMap 1 1 1 - - Internal -> Jdk
java.lang.String javax.ws.rs.core.Response 1 1 1 - - Jdk -> External
org.apache.pulsar.common.policies.data.FunctionStatus javax.ws.rs.core.Response 1 1 1 - - Internal -> External
void javax.ws.rs.core.Response 8 1 1 - - Jdk -> External
org.apache.pulsar.common.functions.FunctionState javax.ws.rs.core.Response 1 1 1 - - Internal -> External
FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData javax.ws.rs.core.Response 1 1 1 - - Internal -> External
org.apache.pulsar.common.functions.FunctionConfig org.apache.pulsar.functions.proto.Function.FunctionDetails 2 1 1 - - Internal -> Internal
org.apache.pulsar.common.functions.FunctionConfig javax.ws.rs.core.Response 1 1 1 - - Internal -> External
org.apache.pulsar.functions.worker.rest.api.FunctionsImpl org.apache.pulsar.functions.worker.rest.api.FunctionsImplV2 2 1 1 Composition - Internal -> Internal
javax.ws.rs.core.StreamingOutput javax.ws.rs.core.Response 1 1 1 SIBLING - External -> External
org.apache.pulsar.functions.instance.stats.FunctionStatsManager org.apache.pulsar.functions.instance.stats.ComponentStatsManager 1 1 1 R_SUPER_T - Internal -> Internal
io.netty.bootstrap.ServerBootstrap io.netty.bootstrap.Bootstrap 1 1 1 SIBLING - External -> External
org.apache.pulsar.client.api.MessageBuilder org.apache.pulsar.client.api.TypedMessageBuilder 2 1 1 - - Internal -> Internal
java.lang.String java.util.Map<java.lang.String, java.lang.String> 4 1 1 - - Jdk -> Jdk
org.apache.pulsar.common.api.proto.PulsarApi.CompressionType org.apache.pulsar.client.api.CompressionType 1 1 1 - - Internal -> Internal
org.apache.pulsar.common.api.proto.PulsarApi.CommandGetTopicsOfNamespace.Mode org.apache.pulsar.client.api.RegexSubscriptionMode 1 1 1 - - Internal -> Internal
org.apache.pulsar.common.naming.TopicName java.lang.String 2 2 1 Composition - Internal -> Jdk
java.lang.Long org.apache.pulsar.functions.api.Record<java.lang.Long> 5 1 1 - - Jdk -> Internal
java.util.function.Function<O, java.util.Collection<I>> void 1 1 1 - - Jdk -> Jdk
java.util.function.Function org.apache.pulsar.functions.api.WindowFunction 1 1 1 - - Jdk -> Internal
java.util.concurrent.ConcurrentHashMap java.util.Map 1 1 1 R_SUPER_T - Jdk -> Jdk
org.apache.pulsar.broker.service.persistent.SubscribeRateLimiter java.util.Optional<org.apache.pulsar.broker.service.persistent.SubscribeRateLimiter> 2 1 1 - - Internal -> Jdk
org.apache.pulsar.broker.service.persistent.DispatchRateLimiter java.util.Optional<org.apache.pulsar.broker.service.persistent.DispatchRateLimiter> 7 1 1 - - Internal -> Jdk
boolean io.netty.handler.ssl.SslContext 3 1 1 - - Jdk -> External
java.util.Set java.util.List 1 1 1 SIBLING - Jdk -> Jdk
org.apache.bookkeeper.net.BookieSocketAddress PlacementResult<org.apache.bookkeeper.net.BookieSocketAddress> 1 1 1 - - External -> External
java.util.ArrayList java.util.List 3 1 1 R_SUPER_T - Jdk -> Jdk
java.util.ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieSocketAddress>> 1 1 1 - - Jdk -> External
java.lang.reflect.AccessibleObject byte 1 1 1 - - Jdk -> Jdk
io.netty.handler.ssl.SslContext org.apache.pulsar.common.util.ClientSslContextRefresher 1 1 1 Composition - External -> Internal
org.apache.pulsar.discovery.service.server.ServiceConfig org.apache.pulsar.common.util.ServerSslContextRefresher 1 1 1 - - Internal -> Internal
java.security.cert.X509Certificate java.security.cert.Certificate 1 1 1 R_SUPER_T - Jdk -> Jdk
java.lang.String java.util.Optional<java.lang.reflect.AccessibleObject> 2 1 1 - - Jdk -> Jdk
org.apache.pulsar.common.util.ServerSslContextRefresher org.apache.pulsar.common.util.NettySslContextBuilder 3 1 1 - - Internal -> Internal
java.util.concurrent.ConcurrentHashMap<org.apache.bookkeeper.mledger.Position, java.util.concurrent.atomic.AtomicInteger> org.apache.bookkeeper.util.collections.ConcurrentLongLongPairHashMap 1 1 1 - - Jdk -> External
java.lang.Runnable java.util.function.Consumer<org.apache.pulsar.functions.utils.Actions.ActionResult> 2 1 1 - - Jdk -> Jdk
RuntimeUtils.Actions.ActionResult org.apache.pulsar.functions.utils.Actions.ActionResult 2 1 1 - - Internal -> Internal
org.apache.pulsar.common.util.collections.ConcurrentLongPairSet org.apache.pulsar.common.util.collections.LongPairSet 1 1 1 R_SUPER_T - Internal -> Internal
java.util.Map<java.lang.String, java.lang.String> int 1 1 1 - - Jdk -> Jdk
java.lang.String org.apache.pulsar.client.api.schema.SchemaDefinition<T> 1 1 1 - - Jdk -> Internal
java.lang.Class<T> org.apache.pulsar.client.api.schema.SchemaDefinition 2 2 1 - - Jdk -> Internal
java.lang.String org.apache.pulsar.client.api.schema.SchemaDefinition 2 1 1 - - Jdk -> Internal
java.util.Map<java.lang.String, java.lang.String> org.apache.pulsar.client.api.schema.SchemaDefinition 1 1 1 - - Jdk -> Internal
java.util.Map<java.util.Map<org.apache.pulsar.common.policies.data.BookieInfo, org.apache.bookkeeper.net.BookieSocketAddress>, java.lang.String> org.apache.pulsar.common.policies.data.BookiesRackConfiguration 2 1 1 - - Jdk -> Internal
org.apache.pulsar.io.rabbitmq.RabbitMQConfig org.apache.pulsar.io.rabbitmq.RabbitMQSourceConfig 1 1 1 SIBLING - Internal -> Internal
org.apache.pulsar.functions.utils.Utils.ComponentType org.apache.pulsar.functions.utils.ComponentType 7 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.Producer java.util.Map 1 1 1 - - Internal -> Jdk
org.apache.pulsar.client.admin.PersistentTopics org.apache.pulsar.client.admin.Topics 2 1 1 R_SUPER_T - Internal -> Internal
long java.util.concurrent.CompletableFuture<java.lang.Long> 2 1 1 - - Jdk -> Jdk
org.apache.pulsar.functions.proto.Function.FunctionDetails org.apache.pulsar.functions.proto.Function.FunctionMetaData 1 1 1 - - Internal -> Internal
org.apache.pulsar.functions.proto.Function.FunctionDetails.Builder Function.FunctionDetails.Builder 1 1 1 - - Internal -> External
java.lang.String org.apache.pulsar.common.api.AuthData 6 1 1 - - Jdk -> Internal
org.apache.pulsar.shade.com.google.common.collect.Range com.google.common.collect.Range 1 1 1 - - Internal -> External
org.apache.bookkeeper.mledger.ReadOnlyCursor org.apache.bookkeeper.mledger.impl.ReadOnlyCursorImpl 1 1 1 T_SUPER_R - Internal -> Internal
org.apache.pulsar.shade.com.google.common.base.Predicate com.google.common.base.Predicate 1 1 1 - - Internal -> External
java.io.InputStream javax.ws.rs.client.WebTarget 1 1 1 - - Jdk -> External
java.util.concurrent.BlockingQueue java.util.Queue 1 1 1 R_SUPER_T - Jdk -> Jdk
org.apache.pulsar.client.impl.schema.generic.MultiVersionGenericSchema org.apache.pulsar.client.impl.schema.AvroSchema 1 1 1 - - Internal -> Internal
org.apache.pulsar.client.api.schema.GenericSchema org.apache.pulsar.common.schema.SchemaInfo 4 1 1 - - Internal -> Internal
org.apache.pulsar.client.impl.schema.generic.GenericSchemaImpl org.apache.pulsar.client.api.schema.GenericSchema 2 1 1 R_SUPER_T - Internal -> Internal
java.lang.String org.apache.pulsar.client.impl.conf.ConsumerConfigurationData<byte[]> 2 2 1 SIBLING - Jdk -> Internal
org.apache.pulsar.client.api.ClientConfiguration org.apache.pulsar.client.api.Authentication 1 1 1 SIBLING - Internal -> Internal
org.apache.spark.streaming.api.java.JavaDStream org.apache.spark.streaming.api.java.JavaPairDStream 1 1 1 SIBLING - External -> External
org.apache.pulsar.client.api.ClientConfiguration java.lang.String 1 1 1 SIBLING - Internal -> Jdk
org.apache.pulsar.functions.proto.Function.FunctionAuthenticationSpec java.util.Optional<org.apache.pulsar.functions.proto.Function.FunctionAuthenticationSpec> 1 1 1 - - Internal -> Jdk
org.apache.pulsar.functions.auth.FunctionAuthData java.util.Optional<org.apache.pulsar.functions.auth.FunctionAuthData> 7 1 1 - - Internal -> Jdk
org.apache.pulsar.client.api.Authentication org.apache.pulsar.client.impl.conf.ClientConfigurationData 2 1 1 SIBLING - Internal -> Internal
java.lang.String org.apache.pulsar.client.impl.conf.ProducerConfigurationData 2 1 1 SIBLING - Jdk -> Internal
java.util.Map<java.lang.String, java.lang.reflect.AccessibleObject> org.apache.pulsar.client.impl.conf.ProducerConfigurationData 1 1 1 - - Jdk -> Internal
org.apache.pulsar.functions.utils.ComponentType Function.FunctionDetails.ComponentType 8 1 1 - - Internal -> External
org.apache.pulsar.functions.utils.ComponentType org.apache.pulsar.functions.proto.Function.FunctionDetails.ComponentType 5 1 1 - - Internal -> Internal
java.lang.String java.lang.reflect.Type 2 1 1 - - Jdk -> Jdk
java.lang.Integer java.util.Optional<java.lang.Integer> 14 1 1 - - Jdk -> Jdk
org.apache.pulsar.client.api.Consumer<byte[]> org.apache.pulsar.storm.PulsarSpoutConsumer 1 1 1 - - Internal -> Internal
com.google.common.collect.RangeSet org.apache.pulsar.common.util.collections.LongPairRangeSet 1 1 1 - - External -> Internal
java.lang.String org.apache.pulsar.common.schema.KeyValue<byte[], byte[]> 3 1 1 - - Jdk -> Internal
org.apache.pulsar.client.api.Consumer java.util.Map.Entry<java.lang.Integer, org.apache.pulsar.client.api.Consumer> 1 1 1 - - Internal -> Jdk
org.apache.pulsar.broker.service.StickyKeyConsumerSelector org.apache.pulsar.broker.service.HashRangeStickyKeyConsumerSelector 1 1 1 R_SUPER_T - Internal -> Internal
org.apache.pulsar.client.admin.Source org.apache.pulsar.client.admin.Sources 1 1 1 R_SUPER_T - Internal -> Internal
org.apache.pulsar.client.admin.Sink org.apache.pulsar.client.admin.Sinks 1 1 1 R_SUPER_T - Internal -> Internal
org.apache.pulsar.io.core.Sink org.apache.pulsar.client.admin.Sinks 1 1 1 - - Internal -> Internal
org.apache.pulsar.io.core.Source org.apache.pulsar.client.admin.Sources 1 1 1 - - Internal -> Internal
byte java.lang.Integer 18 1 1 - - Jdk -> Jdk
java.util.Map<java.lang.String, java.lang.reflect.AccessibleObject> java.lang.reflect.AccessibleObject 4 1 1 - - Jdk -> Jdk
org.apache.pulsar.client.impl.conf.ClientConfigurationData boolean 1 1 1 Composition - Internal -> Jdk
io.netty.handler.ssl.SslContext java.util.function.Supplier<io.netty.handler.ssl.SslContext> 1 1 1 - - External -> Jdk
java.lang.Boolean org.apache.pulsar.tests.integration.docker.ContainerExecResult 1 1 1 - - Jdk -> Internal
org.apache.bookkeeper.client.BookKeeper org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl.BookkeeperFactoryForCustomEnsemblePlacementPolicy 1 1 1 - - Internal -> Internal
org.jclouds.domain.Credentials org.apache.pulsar.jcloud.shade.com.google.common.base.Supplier<org.jclouds.domain.Credentials> 6 1 1 - - Internal -> Internal
java.lang.Integer int 1 1 1 - Unboxing Jdk -> Jdk
org.apache.pulsar.common.policies.data.PartitionedTopicStats void 2 1 1 - - Internal -> Jdk
org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats void 3 1 1 - - Internal -> Jdk
java.lang.String org.apache.pulsar.common.policies.data.BookieAffinityGroupData 11 1 1 Composition - Jdk -> Internal
org.apache.pulsar.client.api.BatchMessageContainer org.apache.pulsar.client.impl.BatchMessageContainerBase 1 1 1 T_SUPER_R - Internal -> Internal
java.lang.String org.apache.pulsar.common.functions.FunctionConfig 4 1 1 Composition - Jdk -> Internal
java.lang.String org.apache.pulsar.common.io.SourceConfig 4 1 1 Composition - Jdk -> Internal
java.lang.String org.apache.pulsar.common.io.SinkConfig 4 1 1 Composition - Jdk -> Internal